Struct GtpClient 

pub struct GtpClient { /* private fields */ }

Stateful GTP client.

Tracks the set of already-seen (sender_id, message_id) pairs to enforce the idempotency contract of GTP §5. The seen-set is LRU-bounded at [GTP_SEEN_CAP] entries per epoch to prevent unbounded memory growth in long-lived groups.

The client observes the current group epoch on every GtpClient::send or GtpClient::accept call and automatically clears its idempotency set when the epoch advances. Callers may also drive a reset explicitly via GtpClient::reset.

Implementations

impl GtpClient

pub fn new() -> GtpClient

Creates an empty client.

pub fn send<S>( &mut self, node: &mut GroupNode, seal: &mut S, target: u32, message_id: u64, text: &str, codec: PayloadCodec, ) -> Result<OutboundFrame, GtpError>

where S: Sealer,

Sends a text message via the given GBP node and AEAD sealer.

Returns a wire-ready OutboundFrame that the caller MUST hand to the transport. Uses the O | R | A profile from GTP §5. codec controls how the GtpMessage payload is encoded inside the GBP frame; use PayloadCodec::Cbor for maximum compatibility.

pub fn accept( &mut self, plaintext: &[u8], current_epoch: u64, codec: PayloadCodec, ) -> Result<GtpAccept, GtpError>

Accepts a plaintext payload delivered by the GBP layer (Event::PayloadReceived).

current_epoch is the receiver node’s current epoch — passing it lets the client auto-reset its idempotency set when the epoch advances. codec must match the value from [DeliveredPayload::codec]. Returns either GtpAccept::New or GtpAccept::Duplicate, or GtpError::Decode if the plaintext is not a valid GTP message.

pub fn sync_epoch(&mut self, epoch: u64)

Synchronises the client’s view of the group epoch and resets idempotency state when the epoch has advanced. Called automatically by GtpClient::send and GtpClient::accept.

pub fn reset(&mut self)

Clears the idempotency set unconditionally.