Enum SdkChannelHandle 

pub enum SdkChannelHandle {
    Embedded(EmbeddedChannelHandle),
    Remote(RemoteChannelHandle),
}

Runtime-selected channel handle that keeps deployment differences behind configuration.

Variants

Embedded(EmbeddedChannelHandle)

Embedded direct in-process handle.

Remote(RemoteChannelHandle)

Remote protocol-backed handle.

Implementations

impl SdkChannelHandle

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

Creates a channel handle selected by SDK configuration.

Errors

Returns SdkError if the selected handle cannot be initialized.

Trait Implementations

impl ChannelHandle for SdkChannelHandle

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 SdkChannelHandle

fn clone(&self) -> SdkChannelHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SdkChannelHandle

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

Formats the value using the given formatter.