Struct TriggersServiceClient 

pub struct TriggersServiceClient<T> { /* private fields */ }

Client for this service.

Generic over T: ClientTransport. For gRPC (HTTP/2), use Http2Connection — it has honest poll_ready and composes with tower::balance for multi-connection load balancing. For Connect over HTTP/1.1 (or unknown protocol), use HttpClient.

Working with the response

Unary calls return UnaryResponse<OwnedView<FooView>>. view() borrows the response message, so field access is zero-copy:

let resp = client.create_trigger(request).await?;
let name: &str = resp.view().name;  // borrow into the response buffer

If you need the owned struct (e.g. to store or pass by value), use into_owned():

let owned = client.create_trigger(request).await?.into_owned();

into_view() keeps the zero-copy decoded body (an OwnedView) without copying; field access on it goes through .reborrow(). Streaming responses yield one StreamMessage per received message from .message().await — read fields zero-copy through the generated accessor methods (msg.name()) or .view(), or convert with .to_owned_message().

Implementations

impl<T> TriggersServiceClient<T>

where T: ClientTransport, <T::ResponseBody as Body>::Error: Display,

pub fn new(transport: T, config: ClientConfig) -> Self

Create a new client with the given transport and configuration.

pub fn config(&self) -> &ClientConfig

Get the client configuration.

pub fn config_mut(&mut self) -> &mut ClientConfig

Get a mutable reference to the client configuration.

pub async fn create_trigger( &self, request: CreateTriggerRequest, ) -> Result<UnaryResponse<OwnedView<CreateTriggerResponseView<'static>>>, ConnectError>

Call the CreateTrigger RPC. Sends a request to /triggers.v1.TriggersService/CreateTrigger.

pub async fn create_trigger_with_options( &self, request: CreateTriggerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CreateTriggerResponseView<'static>>>, ConnectError>

Call the CreateTrigger RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn get_trigger( &self, request: GetTriggerRequest, ) -> Result<UnaryResponse<OwnedView<GetTriggerResponseView<'static>>>, ConnectError>

Call the GetTrigger RPC. Sends a request to /triggers.v1.TriggersService/GetTrigger.

pub async fn get_trigger_with_options( &self, request: GetTriggerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<GetTriggerResponseView<'static>>>, ConnectError>

Call the GetTrigger RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn list_triggers( &self, request: ListTriggersRequest, ) -> Result<UnaryResponse<OwnedView<ListTriggersResponseView<'static>>>, ConnectError>

Call the ListTriggers RPC. Sends a request to /triggers.v1.TriggersService/ListTriggers.

pub async fn list_triggers_with_options( &self, request: ListTriggersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ListTriggersResponseView<'static>>>, ConnectError>

Call the ListTriggers RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn list_trigger_events( &self, request: ListTriggerEventsRequest, ) -> Result<UnaryResponse<OwnedView<ListTriggerEventsResponseView<'static>>>, ConnectError>

Call the ListTriggerEvents RPC. Sends a request to /triggers.v1.TriggersService/ListTriggerEvents.

pub async fn list_trigger_events_with_options( &self, request: ListTriggerEventsRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ListTriggerEventsResponseView<'static>>>, ConnectError>

Call the ListTriggerEvents RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn cancel_trigger( &self, request: CancelTriggerRequest, ) -> Result<UnaryResponse<OwnedView<CancelTriggerResponseView<'static>>>, ConnectError>

Call the CancelTrigger RPC. Sends a request to /triggers.v1.TriggersService/CancelTrigger.

pub async fn cancel_trigger_with_options( &self, request: CancelTriggerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CancelTriggerResponseView<'static>>>, ConnectError>

Call the CancelTrigger RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn modify_trigger( &self, request: ModifyTriggerRequest, ) -> Result<UnaryResponse<OwnedView<ModifyTriggerResponseView<'static>>>, ConnectError>

Call the ModifyTrigger RPC. Sends a request to /triggers.v1.TriggersService/ModifyTrigger.

pub async fn modify_trigger_with_options( &self, request: ModifyTriggerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ModifyTriggerResponseView<'static>>>, ConnectError>

Call the ModifyTrigger RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn pause_trigger( &self, request: PauseTriggerRequest, ) -> Result<UnaryResponse<OwnedView<PauseTriggerResponseView<'static>>>, ConnectError>

Call the PauseTrigger RPC. Sends a request to /triggers.v1.TriggersService/PauseTrigger.

pub async fn pause_trigger_with_options( &self, request: PauseTriggerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<PauseTriggerResponseView<'static>>>, ConnectError>

Call the PauseTrigger RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn resume_trigger( &self, request: ResumeTriggerRequest, ) -> Result<UnaryResponse<OwnedView<ResumeTriggerResponseView<'static>>>, ConnectError>

Call the ResumeTrigger RPC. Sends a request to /triggers.v1.TriggersService/ResumeTrigger.

pub async fn resume_trigger_with_options( &self, request: ResumeTriggerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ResumeTriggerResponseView<'static>>>, ConnectError>

Call the ResumeTrigger RPC with explicit per-call options. Options override ClientConfig defaults.

Trait Implementations

impl<T: Clone> Clone for TriggersServiceClient<T>

fn clone(&self) -> TriggersServiceClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.