polyester-sdk 0.1.0-alpha.27

// @generated by connectrpc-codegen. DO NOT EDIT.

///Shorthand for `OwnedView<CreateTriggerRequestView<'static>>`.
pub type OwnedCreateTriggerRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::CreateTriggerRequestView<'static>,
>;
///Shorthand for `OwnedView<CreateTriggerResponseView<'static>>`.
pub type OwnedCreateTriggerResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::CreateTriggerResponseView<'static>,
>;
///Shorthand for `OwnedView<GetTriggerRequestView<'static>>`.
pub type OwnedGetTriggerRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::GetTriggerRequestView<'static>,
>;
///Shorthand for `OwnedView<GetTriggerResponseView<'static>>`.
pub type OwnedGetTriggerResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::GetTriggerResponseView<'static>,
>;
///Shorthand for `OwnedView<ListTriggersRequestView<'static>>`.
pub type OwnedListTriggersRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ListTriggersRequestView<'static>,
>;
///Shorthand for `OwnedView<ListTriggersResponseView<'static>>`.
pub type OwnedListTriggersResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ListTriggersResponseView<'static>,
>;
///Shorthand for `OwnedView<ListTriggerEventsRequestView<'static>>`.
pub type OwnedListTriggerEventsRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ListTriggerEventsRequestView<'static>,
>;
///Shorthand for `OwnedView<ListTriggerEventsResponseView<'static>>`.
pub type OwnedListTriggerEventsResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ListTriggerEventsResponseView<'static>,
>;
///Shorthand for `OwnedView<CancelTriggerRequestView<'static>>`.
pub type OwnedCancelTriggerRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::CancelTriggerRequestView<'static>,
>;
///Shorthand for `OwnedView<CancelTriggerResponseView<'static>>`.
pub type OwnedCancelTriggerResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::CancelTriggerResponseView<'static>,
>;
///Shorthand for `OwnedView<ModifyTriggerRequestView<'static>>`.
pub type OwnedModifyTriggerRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ModifyTriggerRequestView<'static>,
>;
///Shorthand for `OwnedView<ModifyTriggerResponseView<'static>>`.
pub type OwnedModifyTriggerResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ModifyTriggerResponseView<'static>,
>;
///Shorthand for `OwnedView<PauseTriggerRequestView<'static>>`.
pub type OwnedPauseTriggerRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::PauseTriggerRequestView<'static>,
>;
///Shorthand for `OwnedView<PauseTriggerResponseView<'static>>`.
pub type OwnedPauseTriggerResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::PauseTriggerResponseView<'static>,
>;
///Shorthand for `OwnedView<ResumeTriggerRequestView<'static>>`.
pub type OwnedResumeTriggerRequestView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ResumeTriggerRequestView<'static>,
>;
///Shorthand for `OwnedView<ResumeTriggerResponseView<'static>>`.
pub type OwnedResumeTriggerResponseView = ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ResumeTriggerResponseView<'static>,
>;
impl ::connectrpc::Encodable<crate::proto::triggers::v1::CreateTriggerResponse>
for crate::proto::triggers::v1::__buffa::view::CreateTriggerResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::CreateTriggerResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::CreateTriggerResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::GetTriggerResponse>
for crate::proto::triggers::v1::__buffa::view::GetTriggerResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::GetTriggerResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::GetTriggerResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ListTriggersResponse>
for crate::proto::triggers::v1::__buffa::view::ListTriggersResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ListTriggersResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ListTriggersResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ListTriggerEventsResponse>
for crate::proto::triggers::v1::__buffa::view::ListTriggerEventsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ListTriggerEventsResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ListTriggerEventsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::CancelTriggerResponse>
for crate::proto::triggers::v1::__buffa::view::CancelTriggerResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::CancelTriggerResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::CancelTriggerResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ModifyTriggerResponse>
for crate::proto::triggers::v1::__buffa::view::ModifyTriggerResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ModifyTriggerResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ModifyTriggerResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::PauseTriggerResponse>
for crate::proto::triggers::v1::__buffa::view::PauseTriggerResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::PauseTriggerResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::PauseTriggerResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ResumeTriggerResponse>
for crate::proto::triggers::v1::__buffa::view::ResumeTriggerResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::triggers::v1::ResumeTriggerResponse>
for ::buffa::view::OwnedView<
    crate::proto::triggers::v1::__buffa::view::ResumeTriggerResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
/// Full service name for this service.
pub const TRIGGERS_SERVICE_SERVICE_NAME: &str = "triggers.v1.TriggersService";
/// Static [`Spec`](::connectrpc::Spec) for the server-side `CreateTrigger` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_CREATE_TRIGGER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/CreateTrigger",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetTrigger` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_GET_TRIGGER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/GetTrigger",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListTriggers` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_LIST_TRIGGERS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/ListTriggers",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListTriggerEvents` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_LIST_TRIGGER_EVENTS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/ListTriggerEvents",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `CancelTrigger` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_CANCEL_TRIGGER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/CancelTrigger",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ModifyTrigger` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_MODIFY_TRIGGER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/ModifyTrigger",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `PauseTrigger` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_PAUSE_TRIGGER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/PauseTrigger",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ResumeTrigger` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const TRIGGERS_SERVICE_RESUME_TRIGGER_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/triggers.v1.TriggersService/ResumeTrigger",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Server trait for TriggersService.
///
/// # Implementing handlers
///
/// Implement methods with plain `async fn`; the returned future satisfies
/// the `Send` bound automatically.
///
/// **Unary and server-streaming requests** arrive as
/// [`ServiceRequest<'_, Req>`](::connectrpc::ServiceRequest): a zero-copy
/// view of the request plus its body, valid for the duration of the call.
/// Fields are read directly (`request.name` is a `&str` into the decoded
/// buffer) and the borrow may be held across `.await` points. Anything
/// that must outlive the call — `tokio::spawn`, channels, server state,
/// or data captured by a returned response stream — takes owned data:
/// call `request.to_owned_message()` (or copy the specific fields)
/// first.
///
/// **Client-streaming and bidi requests** arrive as
/// [`InboundStream<Req>`](::connectrpc::InboundStream) — a
/// `ServiceStream` of [`StreamMessage`](::connectrpc::StreamMessage)s.
/// Each item owns its decoded buffer and is `Send + 'static`, so items
/// can be buffered or moved into spawned tasks; read fields zero-copy
/// through the generated accessor methods (`item.name()`) or `.view()`,
/// convert with `.to_owned_message()`, or yield an item back unchanged —
/// `StreamMessage<M>` implements `Encodable<M>`.
///
/// Request types resolved through `extern_path` (e.g. well-known types
/// from another crate) use the same wrappers; the crate that owns the
/// type must be generated with buffa ≥ 0.8.0 and views enabled so the
/// backing `HasMessageView` impl exists.
///
/// The `impl Encodable<Out>` return bound accepts the owned `Out`, the
/// generated `OutView<'_>` / `OwnedOutView`,
/// [`MaybeBorrowed`](::connectrpc::MaybeBorrowed), or
/// [`PreEncoded`](::connectrpc::PreEncoded) for handlers that encode a
/// non-`'static` view internally and pass the bytes across the handler
/// boundary. View bodies are not emitted for output types mapped via
/// `extern_path` (the impl would be an orphan); return owned for
/// WKT/extern outputs.
///
/// Server-streaming and bidi-streaming methods return
/// `ServiceStream<impl Encodable<Out> + Send + use<Self>>`. The
/// `use<Self>` precise-capturing clause excludes `&self`'s lifetime and
/// the request's lifetime (unary methods use `use<'a, Self>` and may
/// borrow from `&self`), so stream items must be `'static` and cannot
/// borrow from the request. To stream view-encoded data, encode each
/// item inside the stream body and yield
/// [`PreEncoded`](::connectrpc::PreEncoded) — see its `# Streaming
/// example` doc.
#[allow(clippy::type_complexity)]
pub trait TriggersService: Send + Sync + 'static {
    /// Create a standalone trigger (stop order, TWAP, ladder).
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn create_trigger<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::CreateTriggerRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::CreateTriggerResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Get a trigger by ID.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_trigger<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::GetTriggerRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::GetTriggerResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// List triggers for a sub-account with optional filters.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_triggers<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::ListTriggersRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::ListTriggersResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// List trigger events (append-only history).
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_trigger_events<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::ListTriggerEventsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::ListTriggerEventsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Cancel a trigger.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn cancel_trigger<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::CancelTriggerRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::CancelTriggerResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Modify a trigger (limited patch).
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn modify_trigger<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::ModifyTriggerRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::ModifyTriggerResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Pause a trigger (sets status=PAUSED).
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn pause_trigger<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::PauseTriggerRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::PauseTriggerResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Resume a paused trigger (sets status back to ARMED/RUNNING as appropriate).
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn resume_trigger<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::triggers::v1::ResumeTriggerRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::triggers::v1::ResumeTriggerResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
}
/// Extension trait for registering a service implementation with a Router.
///
/// This trait is automatically implemented for all types that implement the service trait.
/// Prefer [`Router::add_service`](::connectrpc::Router::add_service) for
/// top-down registration; `register` remains available for compatibility
/// and cases where the service-first call shape is more convenient.
///
/// # Example
///
/// ```rust,ignore
/// use std::sync::Arc;
///
/// let service = Arc::new(MyServiceImpl);
/// let router = service.register(Router::new());
/// ```
pub trait TriggersServiceExt: TriggersService {
    /// Register this service implementation with a Router.
    ///
    /// Takes ownership of the `Arc<Self>` and returns a new Router with
    /// this service's methods registered.
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router;
}
impl<S: TriggersService> TriggersServiceExt for S {
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router {
        router
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "CreateTrigger",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::CreateTriggerRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::CreateTriggerRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.create_trigger(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::CreateTriggerResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_CREATE_TRIGGER_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "GetTrigger",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::GetTriggerRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::GetTriggerRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_trigger(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::GetTriggerResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_GET_TRIGGER_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ListTriggers",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::ListTriggersRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::ListTriggersRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_triggers(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::ListTriggersResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_LIST_TRIGGERS_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ListTriggerEvents",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::ListTriggerEventsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::ListTriggerEventsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_trigger_events(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::ListTriggerEventsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_LIST_TRIGGER_EVENTS_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "CancelTrigger",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::CancelTriggerRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::CancelTriggerRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.cancel_trigger(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::CancelTriggerResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_CANCEL_TRIGGER_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ModifyTrigger",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::ModifyTriggerRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::ModifyTriggerRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.modify_trigger(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::ModifyTriggerResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_MODIFY_TRIGGER_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "PauseTrigger",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::PauseTriggerRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::PauseTriggerRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.pause_trigger(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::PauseTriggerResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_PAUSE_TRIGGER_SPEC)
            .route_view(
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ResumeTrigger",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::triggers::v1::__buffa::view::ResumeTriggerRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::triggers::v1::ResumeTriggerRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.resume_trigger(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::triggers::v1::ResumeTriggerResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(TRIGGERS_SERVICE_RESUME_TRIGGER_SPEC)
    }
}
/// Type-inference marker used by [`Router::add_service`](::connectrpc::Router::add_service).
#[doc(hidden)]
pub struct TriggersServiceRegisterMarker;
impl<S: TriggersService> ::connectrpc::ServiceRegister<TriggersServiceRegisterMarker>
for ::std::sync::Arc<S> {
    fn register_service(self, router: ::connectrpc::Router) -> ::connectrpc::Router {
        <S as TriggersServiceExt>::register(self, router)
    }
}
/// Monomorphic dispatcher for `TriggersService`.
///
/// Unlike `.register(Router)` which type-erases each method into an `Arc<dyn ErasedHandler>` stored in a `HashMap`, this struct dispatches via a compile-time `match` on method name: no vtable, no hash lookup.
///
/// # Example
///
/// ```rust,ignore
/// use connectrpc::ConnectRpcService;
///
/// let server = TriggersServiceServer::new(MyImpl);
/// let service = ConnectRpcService::new(server);
/// // hand `service` to axum/hyper as a fallback_service
/// ```
pub struct TriggersServiceServer<T> {
    inner: ::std::sync::Arc<T>,
}
impl<T: TriggersService> TriggersServiceServer<T> {
    /// Wrap a service implementation in a monomorphic dispatcher.
    pub fn new(service: T) -> Self {
        Self {
            inner: ::std::sync::Arc::new(service),
        }
    }
    /// Wrap an already-`Arc`'d service implementation.
    pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
        Self { inner }
    }
}
impl<T> Clone for TriggersServiceServer<T> {
    fn clone(&self) -> Self {
        Self {
            inner: ::std::sync::Arc::clone(&self.inner),
        }
    }
}
impl<T: TriggersService> ::connectrpc::Dispatcher for TriggersServiceServer<T> {
    #[inline]
    fn lookup(
        &self,
        path: &str,
    ) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
        let method = path.strip_prefix("triggers.v1.TriggersService/")?;
        match method {
            "CreateTrigger" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_CREATE_TRIGGER_SPEC),
                )
            }
            "GetTrigger" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_GET_TRIGGER_SPEC),
                )
            }
            "ListTriggers" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_LIST_TRIGGERS_SPEC),
                )
            }
            "ListTriggerEvents" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_LIST_TRIGGER_EVENTS_SPEC),
                )
            }
            "CancelTrigger" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_CANCEL_TRIGGER_SPEC),
                )
            }
            "ModifyTrigger" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_MODIFY_TRIGGER_SPEC),
                )
            }
            "PauseTrigger" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_PAUSE_TRIGGER_SPEC),
                )
            }
            "ResumeTrigger" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(TRIGGERS_SERVICE_RESUME_TRIGGER_SPEC),
                )
            }
            _ => None,
        }
    }
    fn call_unary(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::Payload,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("triggers.v1.TriggersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            "CreateTrigger" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::CreateTriggerRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::CreateTriggerRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::CreateTriggerRequest,
                    >::from_parts(&req, &body);
                    svc.create_trigger(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::CreateTriggerResponse,
                        >(format)
                })
            }
            "GetTrigger" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::GetTriggerRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::GetTriggerRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::GetTriggerRequest,
                    >::from_parts(&req, &body);
                    svc.get_trigger(ctx, req)
                        .await?
                        .encode::<crate::proto::triggers::v1::GetTriggerResponse>(format)
                })
            }
            "ListTriggers" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::ListTriggersRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::ListTriggersRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::ListTriggersRequest,
                    >::from_parts(&req, &body);
                    svc.list_triggers(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::ListTriggersResponse,
                        >(format)
                })
            }
            "ListTriggerEvents" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::ListTriggerEventsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::ListTriggerEventsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::ListTriggerEventsRequest,
                    >::from_parts(&req, &body);
                    svc.list_trigger_events(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::ListTriggerEventsResponse,
                        >(format)
                })
            }
            "CancelTrigger" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::CancelTriggerRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::CancelTriggerRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::CancelTriggerRequest,
                    >::from_parts(&req, &body);
                    svc.cancel_trigger(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::CancelTriggerResponse,
                        >(format)
                })
            }
            "ModifyTrigger" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::ModifyTriggerRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::ModifyTriggerRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::ModifyTriggerRequest,
                    >::from_parts(&req, &body);
                    svc.modify_trigger(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::ModifyTriggerResponse,
                        >(format)
                })
            }
            "PauseTrigger" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::PauseTriggerRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::PauseTriggerRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::PauseTriggerRequest,
                    >::from_parts(&req, &body);
                    svc.pause_trigger(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::PauseTriggerResponse,
                        >(format)
                })
            }
            "ResumeTrigger" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::triggers::v1::ResumeTriggerRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::triggers::v1::__buffa::view::ResumeTriggerRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::triggers::v1::ResumeTriggerRequest,
                    >::from_parts(&req, &body);
                    svc.resume_trigger(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::triggers::v1::ResumeTriggerResponse,
                        >(format)
                })
            }
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_server_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::buffa::bytes::Bytes,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("triggers.v1.TriggersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
    fn call_client_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("triggers.v1.TriggersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_bidi_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("triggers.v1.TriggersService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
}
/// 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>>`](::connectrpc::client::UnaryResponse).
/// [`view()`](::connectrpc::client::UnaryResponse::view) borrows the response
/// message, so field access is zero-copy:
///
/// ```rust,ignore
/// 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()`](::connectrpc::client::UnaryResponse::into_owned):
///
/// ```rust,ignore
/// let owned = client.create_trigger(request).await?.into_owned();
/// ```
///
/// [`into_view()`](::connectrpc::client::UnaryResponse::into_view) keeps the
/// zero-copy decoded body (an `OwnedView`) without copying; field access on it
/// goes through `.reborrow()`. Streaming responses yield one
/// [`StreamMessage`](::connectrpc::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()`.
#[derive(Clone)]
pub struct TriggersServiceClient<T> {
    transport: T,
    config: ::connectrpc::client::ClientConfig,
}
impl<T> TriggersServiceClient<T>
where
    T: ::connectrpc::client::ClientTransport,
    <T::ResponseBody as ::connectrpc::http_body::Body>::Error: ::std::fmt::Display,
{
    /// Create a new client with the given transport and configuration.
    pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
        Self { transport, config }
    }
    /// Get the client configuration.
    pub fn config(&self) -> &::connectrpc::client::ClientConfig {
        &self.config
    }
    /// Get a mutable reference to the client configuration.
    pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
        &mut self.config
    }
    /// Call the CreateTrigger RPC. Sends a request to /triggers.v1.TriggersService/CreateTrigger.
    pub async fn create_trigger(
        &self,
        request: crate::proto::triggers::v1::CreateTriggerRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::CreateTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.create_trigger_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the CreateTrigger RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn create_trigger_with_options(
        &self,
        request: crate::proto::triggers::v1::CreateTriggerRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::CreateTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "CreateTrigger",
                request,
                options,
            )
            .await
    }
    /// Call the GetTrigger RPC. Sends a request to /triggers.v1.TriggersService/GetTrigger.
    pub async fn get_trigger(
        &self,
        request: crate::proto::triggers::v1::GetTriggerRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::GetTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_trigger_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetTrigger RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_trigger_with_options(
        &self,
        request: crate::proto::triggers::v1::GetTriggerRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::GetTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "GetTrigger",
                request,
                options,
            )
            .await
    }
    /// Call the ListTriggers RPC. Sends a request to /triggers.v1.TriggersService/ListTriggers.
    pub async fn list_triggers(
        &self,
        request: crate::proto::triggers::v1::ListTriggersRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ListTriggersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_triggers_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListTriggers RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_triggers_with_options(
        &self,
        request: crate::proto::triggers::v1::ListTriggersRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ListTriggersResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ListTriggers",
                request,
                options,
            )
            .await
    }
    /// Call the ListTriggerEvents RPC. Sends a request to /triggers.v1.TriggersService/ListTriggerEvents.
    pub async fn list_trigger_events(
        &self,
        request: crate::proto::triggers::v1::ListTriggerEventsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ListTriggerEventsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_trigger_events_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListTriggerEvents RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_trigger_events_with_options(
        &self,
        request: crate::proto::triggers::v1::ListTriggerEventsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ListTriggerEventsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ListTriggerEvents",
                request,
                options,
            )
            .await
    }
    /// Call the CancelTrigger RPC. Sends a request to /triggers.v1.TriggersService/CancelTrigger.
    pub async fn cancel_trigger(
        &self,
        request: crate::proto::triggers::v1::CancelTriggerRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::CancelTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.cancel_trigger_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the CancelTrigger RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn cancel_trigger_with_options(
        &self,
        request: crate::proto::triggers::v1::CancelTriggerRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::CancelTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "CancelTrigger",
                request,
                options,
            )
            .await
    }
    /// Call the ModifyTrigger RPC. Sends a request to /triggers.v1.TriggersService/ModifyTrigger.
    pub async fn modify_trigger(
        &self,
        request: crate::proto::triggers::v1::ModifyTriggerRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ModifyTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.modify_trigger_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ModifyTrigger RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn modify_trigger_with_options(
        &self,
        request: crate::proto::triggers::v1::ModifyTriggerRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ModifyTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ModifyTrigger",
                request,
                options,
            )
            .await
    }
    /// Call the PauseTrigger RPC. Sends a request to /triggers.v1.TriggersService/PauseTrigger.
    pub async fn pause_trigger(
        &self,
        request: crate::proto::triggers::v1::PauseTriggerRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::PauseTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.pause_trigger_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the PauseTrigger RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn pause_trigger_with_options(
        &self,
        request: crate::proto::triggers::v1::PauseTriggerRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::PauseTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "PauseTrigger",
                request,
                options,
            )
            .await
    }
    /// Call the ResumeTrigger RPC. Sends a request to /triggers.v1.TriggersService/ResumeTrigger.
    pub async fn resume_trigger(
        &self,
        request: crate::proto::triggers::v1::ResumeTriggerRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ResumeTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.resume_trigger_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ResumeTrigger RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn resume_trigger_with_options(
        &self,
        request: crate::proto::triggers::v1::ResumeTriggerRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::triggers::v1::__buffa::view::ResumeTriggerResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                TRIGGERS_SERVICE_SERVICE_NAME,
                "ResumeTrigger",
                request,
                options,
            )
            .await
    }
}