Struct RemoteChannelHandle 

pub struct RemoteChannelHandle { /* private fields */ }

Channel handle that communicates through SDK-internal wire protocol transport.

Implementations

impl RemoteChannelHandle

pub fn new(config: &RemoteConfig) -> Result<Self, SdkError>

Creates a remote channel handle from validated configuration.

Errors

Returns SdkError if the connection pool cannot be created.

pub fn connection_state(&self) -> ConnectionState

Returns current lifecycle state from the SDK-003 state machine.

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

where J: ReconnectJitter + ?Sized,

Drives a reconnect attempt through the SDK-003 lifecycle state machine.

Errors

Returns SdkError when the lifecycle rejects the transition.

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

Marks the remote channel connected and builds subscription resume requests.

Errors

Returns SdkError if lifecycle transition or recovery state is invalid.

pub fn track_subscription(&self) -> Result<SubscriptionId, SdkError>

Marks a subscription active and assigns it to the configured pool.

Errors

Returns SdkError if a subscription id overflows or pool assignment fails.

pub fn acknowledge( &self, subscription_id: SubscriptionId, sequence: u64, ) -> Result<(), SdkError>

Records an acknowledged sequence for subscription recovery.

Errors

Returns SdkError if the subscription is not active in the pool.

pub const fn server_address(&self) -> &ServerAddress

Returns remote server address used by this handle.

impl RemoteChannelHandle

pub fn publish_with_idempotency_key<M>( &self, message: &M, idempotency_key: &str, ) -> Result<DeliveryAck, SdkError>

where M: Serialize + SchemaValidate,

Publishes a message with an idempotency key and returns a genuine delivery ack.

The idempotency key drives dedup-on-delivery on the server: a re-publish of the same key is delivered to subscribers at most once. The returned DeliveryAck reports whether this publish was genuinely accepted by a subscriber (DeliveryAck::is_accepted), which a caller such as the aion outbox uses to treat the send as done only on real acceptance. This is distinct from the backpressure-only publish.

Errors

Returns SdkError when the message cannot be serialized, the round trip fails, or the transport cannot produce a genuine delivery ack.

Trait Implementations

impl ChannelHandle for RemoteChannelHandle

type Subscription<M> = SdkSubscription<M> where M: DeserializeOwned

Stream returned by subscribe for message type M.

type ReplyFuture<'a, Resp> = ReadyResult<Resp> where Self: 'a, Resp: DeserializeOwned + 'a

Future returned by request_reply for reply type Resp.

fn publish<M>(&self, message: M) -> Result<PressureResponse, SdkError>

where M: Serialize + SchemaValidate,

Publishes a typed message to the channel.

fn subscribe<M>(&self) -> Self::Subscription<M>

where M: DeserializeOwned,

Subscribes to typed channel messages.

fn request_reply<Req, Resp>(&self, request: Req) -> ReadyResult<Resp>

where Req: Serialize + SchemaValidate, Resp: DeserializeOwned,

Sends a typed request and resolves with a typed reply.

impl Clone for RemoteChannelHandle

fn clone(&self) -> RemoteChannelHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RemoteChannelHandle

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

Formats the value using the given formatter.