state.h

Go to the documentation of this file.

 
#pragma once
 
#include "metrics.h"
#include "topology.h"
#include <ascii-chat/asciichat_errno.h>
#include <stdint.h>
#include <stdbool.h>
 
typedef enum {
  CONSENSUS_STATE_IDLE = 0,                
  CONSENSUS_STATE_COLLECTION_START = 1,    
  CONSENSUS_STATE_COLLECTING = 2,          
  CONSENSUS_STATE_COLLECTION_COMPLETE = 3, 
  CONSENSUS_STATE_ELECTION_START = 4,      
  CONSENSUS_STATE_ELECTING = 5,            
  CONSENSUS_STATE_ELECTION_COMPLETE = 6,   
  CONSENSUS_STATE_FAILED = 7               
} consensus_state_machine_t;
 
typedef struct consensus_state consensus_state_t;
 
asciichat_error_t consensus_state_create(const uint8_t my_id[16], const consensus_topology_t *topology,
                                         consensus_state_t **out_state);
 
void consensus_state_destroy(consensus_state_t *state);
 
asciichat_error_t consensus_state_start_collection(consensus_state_t *state);
 
asciichat_error_t consensus_state_add_metrics(consensus_state_t *state, const participant_metrics_t *metrics);
 
asciichat_error_t consensus_state_collection_complete(consensus_state_t *state);
 
asciichat_error_t consensus_state_compute_election(consensus_state_t *state);
 
asciichat_error_t consensus_state_reset_to_idle(consensus_state_t *state);
 
consensus_state_machine_t consensus_state_get_current_state(const consensus_state_t *state);
 
asciichat_error_t consensus_state_get_elected_host(const consensus_state_t *state, uint8_t out_host_id[16]);
 
asciichat_error_t consensus_state_get_elected_backup(const consensus_state_t *state, uint8_t out_backup_id[16]);
 
bool consensus_state_is_leader(const consensus_state_t *state);
 
int consensus_state_get_metrics_count(const consensus_state_t *state);
 
asciichat_error_t consensus_state_get_metric_at(const consensus_state_t *state, int index,
                                                participant_metrics_t *out_metrics);