Struct ConnectionLifecycle 

pub struct ConnectionLifecycle { /* private fields */ }

Owns the SDK connection lifecycle state and emits validated transitions.

Implementations

impl ConnectionLifecycle

pub fn new(reconnect_config: ReconnectConfig) -> Self

Creates a lifecycle in the ConnectionState::Connecting state.

pub const fn state(&self) -> &ConnectionState

Returns the current connection state.

pub const fn reconnect_config(&self) -> ReconnectConfig

Returns the reconnect backoff configuration.

pub fn observe( &mut self, observer: impl FnMut(&ConnectionEvent) + Send + 'static, )

Registers an observer that is called after each successful transition.

pub fn connect(&mut self) -> Result<(), SdkError>

Transitions from ConnectionState::Disconnected to connecting.

Errors

Returns SdkError when the lifecycle is not disconnected.

pub fn connected(&mut self) -> Result<(), SdkError>

Transitions from connecting or reconnecting to connected.

Errors

Returns SdkError when the lifecycle is disconnected or already connected.

pub fn reconnect<J>(&mut self, jitter: &mut J) -> Result<Duration, SdkError>

where J: ReconnectJitter + ?Sized,

Transitions to reconnecting and returns the next retry delay.

The first reconnect attempt after a successful connection uses attempt zero. Each subsequent reconnect attempt increments the counter until a successful Self::connected transition resets it.

Errors

Returns SdkError when reconnecting from the current state is invalid or when the jitter source exceeds the allowed jitter range.

pub fn disconnect(&mut self, reason: DisconnectReason) -> Result<(), SdkError>

Transitions to disconnected with the supplied reason.

Errors

Returns SdkError when the lifecycle is already disconnected.

Trait Implementations

impl Debug for ConnectionLifecycle

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

Formats the value using the given formatter.

impl Default for ConnectionLifecycle

fn default() -> Self

Returns the “default value” for a type.