coordinator.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/crypto/sizes.h>
#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[SESSION_ID_SIZE],
                                               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[SESSION_ID_SIZE],
                                                        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[SESSION_ID_SIZE],
                                                           const uint8_t backup_id[SESSION_ID_SIZE]);

asciichat_error_t consensus_coordinator_get_current_host(const consensus_coordinator_t *coordinator,
                                                         uint8_t out_host_id[SESSION_ID_SIZE],
                                                         uint8_t out_backup_id[SESSION_ID_SIZE]);

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);

typedef asciichat_error_t (*consensus_metrics_provider_fn)(void *, const uint8_t[16], participant_metrics_t *);
void consensus_coordinator_set_metrics_provider(consensus_coordinator_t *, consensus_metrics_provider_fn, void *);