Struct OutgoingSeq 

pub struct OutgoingSeq { /* private fields */ }

Tracks outgoing sequence numbers for a single direction of a WebSocket connection. Assigns monotonically increasing numbers starting at 1.

Implementations

impl OutgoingSeq

pub fn new() -> Self

Create a new outgoing sequence counter (first message gets seq 1).

pub fn wrap_service( &mut self, message: ServiceMessage, trace_context: TraceContext, ) -> ServiceEnvelope

Wrap a ServiceMessage in a ServiceEnvelope, assigning the next sequence number, stamping CURRENT_PROTOCOL_VERSION, and attaching the given TraceContext for distributed tracing.

pub fn wrap_service_paginated( &mut self, message: ServiceMessage, trace_context: TraceContext, pagination: Option<ReportPagination>, ) -> ServiceEnvelope

Wrap a ServiceMessage in a ServiceEnvelope with optional pagination metadata.

pub fn wrap_controller( &mut self, message: ControllerMessage, trace_context: TraceContext, ) -> ControllerEnvelope

Wrap a ControllerMessage in a ControllerEnvelope, assigning the next sequence number, stamping CURRENT_PROTOCOL_VERSION, and attaching the given TraceContext for distributed tracing.

Trait Implementations

impl Debug for OutgoingSeq

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

Formats the value using the given formatter.

impl Default for OutgoingSeq

fn default() -> Self

Returns the “default value” for a type.