Struct WorkflowProviderClient

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

Expand description

Implementations§

Attempt to create a new client by connecting to a given endpoint.

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

Enable decompressing responses.

Limits the maximum size of a decoded message.

Default: 4MB

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Converts to this type from a reference to the input type.

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

Attaches the current Context to this type, returning a WithContext wrapper. Read more

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct WorkflowProviderClient Copy item path

Implementations§

impl WorkflowProviderClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> WorkflowProviderClient<T>where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

pub fn max_decoding_message_size(self, limit: usize) -> Self

pub fn max_encoding_message_size(self, limit: usize) -> Self

pub async fn start_run( &mut self, request: impl IntoRequest<StartWorkflowProviderRunRequest>, ) -> Result<Response<BoundWorkflowRun>, Status>

pub async fn get_run( &mut self, request: impl IntoRequest<GetWorkflowProviderRunRequest>, ) -> Result<Response<BoundWorkflowRun>, Status>

pub async fn list_runs( &mut self, request: impl IntoRequest<ListWorkflowProviderRunsRequest>, ) -> Result<Response<ListWorkflowProviderRunsResponse>, Status>

pub async fn cancel_run( &mut self, request: impl IntoRequest<CancelWorkflowProviderRunRequest>, ) -> Result<Response<BoundWorkflowRun>, Status>

pub async fn signal_run( &mut self, request: impl IntoRequest<SignalWorkflowProviderRunRequest>, ) -> Result<Response<SignalWorkflowRunResponse>, Status>

pub async fn signal_or_start_run( &mut self, request: impl IntoRequest<SignalOrStartWorkflowProviderRunRequest>, ) -> Result<Response<SignalWorkflowRunResponse>, Status>

pub async fn upsert_schedule( &mut self, request: impl IntoRequest<UpsertWorkflowProviderScheduleRequest>, ) -> Result<Response<BoundWorkflowSchedule>, Status>

pub async fn get_schedule( &mut self, request: impl IntoRequest<GetWorkflowProviderScheduleRequest>, ) -> Result<Response<BoundWorkflowSchedule>, Status>

pub async fn list_schedules( &mut self, request: impl IntoRequest<ListWorkflowProviderSchedulesRequest>, ) -> Result<Response<ListWorkflowProviderSchedulesResponse>, Status>

pub async fn delete_schedule( &mut self, request: impl IntoRequest<DeleteWorkflowProviderScheduleRequest>, ) -> Result<Response<()>, Status>

pub async fn pause_schedule( &mut self, request: impl IntoRequest<PauseWorkflowProviderScheduleRequest>, ) -> Result<Response<BoundWorkflowSchedule>, Status>

pub async fn resume_schedule( &mut self, request: impl IntoRequest<ResumeWorkflowProviderScheduleRequest>, ) -> Result<Response<BoundWorkflowSchedule>, Status>

pub async fn upsert_event_trigger( &mut self, request: impl IntoRequest<UpsertWorkflowProviderEventTriggerRequest>, ) -> Result<Response<BoundWorkflowEventTrigger>, Status>

pub async fn get_event_trigger( &mut self, request: impl IntoRequest<GetWorkflowProviderEventTriggerRequest>, ) -> Result<Response<BoundWorkflowEventTrigger>, Status>

pub async fn list_event_triggers( &mut self, request: impl IntoRequest<ListWorkflowProviderEventTriggersRequest>, ) -> Result<Response<ListWorkflowProviderEventTriggersResponse>, Status>

pub async fn delete_event_trigger( &mut self, request: impl IntoRequest<DeleteWorkflowProviderEventTriggerRequest>, ) -> Result<Response<()>, Status>

pub async fn pause_event_trigger( &mut self, request: impl IntoRequest<PauseWorkflowProviderEventTriggerRequest>, ) -> Result<Response<BoundWorkflowEventTrigger>, Status>

pub async fn resume_event_trigger( &mut self, request: impl IntoRequest<ResumeWorkflowProviderEventTriggerRequest>, ) -> Result<Response<BoundWorkflowEventTrigger>, Status>

pub async fn put_execution_reference( &mut self, request: impl IntoRequest<PutWorkflowExecutionReferenceRequest>, ) -> Result<Response<WorkflowExecutionReference>, Status>

pub async fn get_execution_reference( &mut self, request: impl IntoRequest<GetWorkflowExecutionReferenceRequest>, ) -> Result<Response<WorkflowExecutionReference>, Status>

pub async fn list_execution_references( &mut self, request: impl IntoRequest<ListWorkflowExecutionReferencesRequest>, ) -> Result<Response<ListWorkflowExecutionReferencesResponse>, Status>

pub async fn publish_event( &mut self, request: impl IntoRequest<PublishWorkflowProviderEventRequest>, ) -> Result<Response<()>, Status>

Trait Implementations§

impl<T: Clone> Clone for WorkflowProviderClient<T>

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

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

impl<T: Debug> Debug for WorkflowProviderClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for WorkflowProviderClient<T>

impl<T> RefUnwindSafe for WorkflowProviderClient<T>where T: RefUnwindSafe,

impl<T> Send for WorkflowProviderClient<T>where T: Send,

impl<T> Sync for WorkflowProviderClient<T>where T: Sync,

impl<T> Unpin for WorkflowProviderClient<T>where T: Unpin,

impl<T> UnsafeUnpin for WorkflowProviderClient<T>where T: UnsafeUnpin,

impl<T> UnwindSafe for WorkflowProviderClient<T>where T: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

Struct WorkflowProviderClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>
where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> WorkflowProviderClient<T>
where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

impl<T> RefUnwindSafe for WorkflowProviderClient<T>
where T: RefUnwindSafe,

impl<T> Send for WorkflowProviderClient<T>
where T: Send,

impl<T> Sync for WorkflowProviderClient<T>
where T: Sync,

impl<T> Unpin for WorkflowProviderClient<T>
where T: Unpin,

impl<T> UnsafeUnpin for WorkflowProviderClient<T>
where T: UnsafeUnpin,

impl<T> UnwindSafe for WorkflowProviderClient<T>
where T: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DynClone for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,