metrics.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/common/limits.h>
#include <ascii-chat/crypto/sizes.h>
#include <ascii-chat/asciichat_errno.h>
#include <stdint.h>
#include <stddef.h>
 
#ifdef _WIN32
#pragma pack(push, 1)
#endif

typedef struct {
  uint8_t participant_id[SESSION_ID_SIZE];     
  uint8_t nat_tier;                            
  uint32_t upload_kbps;                        
  uint32_t rtt_ns;                             
  uint8_t stun_probe_success_pct;              
  char public_address[IP_ADDRESS_BUFFER_SIZE]; 
  uint16_t public_port;                        
  uint8_t connection_type;                     
  uint64_t measurement_time_ns;                
  uint64_t measurement_window_ns;              
} __attribute__((packed)) participant_metrics_t;
 
#ifdef _WIN32
#pragma pack(pop)
#endif
 
#ifdef __cplusplus
extern "C" {
#endif

typedef struct consensus_metrics_collection consensus_metrics_collection_t;

asciichat_error_t consensus_metrics_measure(const uint8_t my_id[SESSION_ID_SIZE], participant_metrics_t *out_metrics);

asciichat_error_t consensus_metrics_to_wire(const participant_metrics_t *metrics, participant_metrics_t *out_wire);

asciichat_error_t consensus_metrics_from_wire(const participant_metrics_t *wire_metrics,
                                              participant_metrics_t *out_metrics);

asciichat_error_t consensus_metrics_collection_create(consensus_metrics_collection_t **out_collection);

asciichat_error_t consensus_metrics_collection_add(consensus_metrics_collection_t *collection,
                                                   const participant_metrics_t *metrics);

asciichat_error_t consensus_metrics_collection_get(const consensus_metrics_collection_t *collection,
                                                   const participant_metrics_t **out_metrics, int *out_count);

void consensus_metrics_collection_destroy(consensus_metrics_collection_t *collection);
 
#ifdef __cplusplus
}
#endif