Struct ntp_proto::StandardClockController

pub struct StandardClockController<C: NtpClock, PeerID: Hash + Eq + Copy + Debug> { /* private fields */ }

Trait Implementations

impl<C: Debug + NtpClock, PeerID: Debug + Hash + Eq + Copy + Debug> Debug for StandardClockController<C, PeerID>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C: NtpClock, PeerID: Hash + Eq + Copy + Debug> TimeSyncController<C, PeerID> for StandardClockController<C, PeerID>

type AlgorithmConfig = AlgorithmConfig

fn new(clock: C, config: SystemConfig, algo_config: AlgorithmConfig) -> Self

Create a new clock controller controling the given clock

fn update_config(&mut self, config: SystemConfig, algo_config: AlgorithmConfig)

Update used system config

fn peer_add(&mut self, id: PeerID)

Notify the controller that there is a new peer

fn peer_remove(&mut self, id: PeerID)

Notify the controller that a previous peer has gone

fn peer_update(&mut self, id: PeerID, usable: bool)

Notify the controller that the status of a peer (whether or not it is usable for synchronization) has changed.

fn peer_measurement( &mut self, id: PeerID, measurement: Measurement, packet: NtpPacket<'static> ) -> StateUpdate<PeerID>

Notify the controller of a new measurement from a peer. The list of peerIDs is used for loop detection, with the first peerID given considered the primary peer used.

fn time_update(&mut self) -> StateUpdate<PeerID>

Non-measurement driven update (queued via next_update)

fn peer_snapshot(&self, id: PeerID) -> Option<ObservablePeerTimedata>

Get a snapshot of the timekeeping state of a peer.