coordinator.h

Go to the documentation of this file.

 
#pragma once
 
#include "state.h"
#include "topology.h"
#include "metrics.h"
#include <ascii-chat/asciichat_errno.h>
#include <stdint.h>
#include <stdbool.h>
 
typedef asciichat_error_t (*consensus_election_func_t)(void *context, consensus_state_t *state);
 
typedef struct consensus_coordinator consensus_coordinator_t;
 
asciichat_error_t consensus_coordinator_create(const uint8_t my_id[16], const consensus_topology_t *topology,
                                               consensus_election_func_t election_func, void *election_context,
                                               consensus_coordinator_t **out_coordinator);
 
void consensus_coordinator_destroy(consensus_coordinator_t *coordinator);
 
asciichat_error_t consensus_coordinator_process(consensus_coordinator_t *coordinator, uint32_t timeout_ms);
 
asciichat_error_t consensus_coordinator_on_ring_members(consensus_coordinator_t *coordinator,
                                                        const consensus_topology_t *new_topology);
 
asciichat_error_t consensus_coordinator_on_collection_start(consensus_coordinator_t *coordinator, uint32_t round_id,
                                                            uint64_t deadline_ns);
 
asciichat_error_t consensus_coordinator_on_stats_update(consensus_coordinator_t *coordinator,
                                                        const uint8_t sender_id[16],
                                                        const participant_metrics_t *metrics, uint8_t num_metrics);
 
asciichat_error_t consensus_coordinator_on_election_result(consensus_coordinator_t *coordinator,
                                                           const uint8_t host_id[16], const uint8_t backup_id[16]);
 
asciichat_error_t consensus_coordinator_get_current_host(const consensus_coordinator_t *coordinator,
                                                         uint8_t out_host_id[16], uint8_t out_backup_id[16]);
 
consensus_state_machine_t consensus_coordinator_get_state(const consensus_coordinator_t *coordinator);
 
uint64_t consensus_coordinator_time_until_next_round(const consensus_coordinator_t *coordinator);
 
int consensus_coordinator_get_metrics_count(const consensus_coordinator_t *coordinator);