Struct TrellisClient 

pub struct TrellisClient { /* private fields */ }

A low-level Trellis client over NATS request/reply and publish primitives.

Implementations

impl TrellisClient

pub fn nats(&self) -> &Client

Expose the underlying NATS client for advanced use.

pub fn auth(&self) -> &SessionAuth

Return the session auth helper used by this client.

pub async fn connect_service( opts: ServiceConnectOptions<'_>, ) -> Result<Self, TrellisClientError>

Connect using sentinel credentials plus an iat-based service token.

pub async fn connect_user( opts: UserConnectOptions<'_>, ) -> Result<Self, TrellisClientError>

Connect using a previously issued binding token.

pub async fn request_json_value( &self, subject: &str, body: &Value, ) -> Result<Value, TrellisClientError>

Call a raw subject with a JSON value payload.

pub async fn call<D>( &self, input: &D::Input, ) -> Result<D::Output, TrellisClientError>

where D: RpcDescriptor,

Call one descriptor-backed RPC.

pub async fn publish<D>( &self, event: &D::Event, ) -> Result<(), TrellisClientError>

where D: EventDescriptor,

Publish one descriptor-backed event.