Struct FlowServiceClient

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

Expand description

Hosted by Dex server; SDKs call these RPCs.

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.

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 FlowServiceClient Copy item path

Implementations§

impl FlowServiceClient<Channel>

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

impl<T> FlowServiceClient<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_flow( &mut self, request: impl IntoRequest<StartFlowRequest>, ) -> Result<Response<StartFlowResponse>, Status>

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

pub async fn get_channel_messages( &mut self, request: impl IntoRequest<GetChannelMessagesRequest>, ) -> Result<Response<GetChannelMessagesResponse>, Status>

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

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

pub async fn read_stream( &mut self, request: impl IntoRequest<ReadStreamRequest>, ) -> Result<Response<ReadStreamResponse>, Status>

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

pub async fn get_attributes( &mut self, request: impl IntoRequest<GetAttributesRequest>, ) -> Result<Response<GetAttributesResponse>, Status>

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

pub async fn load_blobs( &mut self, request: impl IntoRequest<LoadBlobsRequest>, ) -> Result<Response<LoadBlobsResponse>, Status>

pub async fn wait_for_flow( &mut self, request: impl IntoRequest<WaitForFlowRequest>, ) -> Result<Response<FlowResult>, Status>

pub async fn search_flows( &mut self, request: impl IntoRequest<SearchFlowsRequest>, ) -> Result<Response<SearchFlowsResponse>, Status>

pub async fn sync_attribute_indexes( &mut self, request: impl IntoRequest<SyncAttributeIndexRequest>, ) -> Result<Response<SyncAttributeIndexResponse>, Status>

pub async fn get_flow_summary( &mut self, request: impl IntoRequest<GetFlowSummaryRequest>, ) -> Result<Response<GetFlowSummaryResponse>, Status>

pub async fn get_history_events( &mut self, request: impl IntoRequest<GetHistoryEventsRequest>, ) -> Result<Response<GetHistoryEventsResponse>, Status>

pub async fn wait_for_history_event( &mut self, request: impl IntoRequest<WaitForHistoryEventRequest>, ) -> Result<Response<WaitForHistoryEventResponse>, Status>

pub async fn get_flow_state( &mut self, request: impl IntoRequest<GetFlowStateRequest>, ) -> Result<Response<GetFlowStateResponse>, Status>

pub async fn reset_flow( &mut self, request: impl IntoRequest<ResetFlowRequest>, ) -> Result<Response<ResetFlowResponse>, Status>

pub async fn invoke_rpc( &mut self, request: impl IntoRequest<InvokeRpcRequest>, ) -> Result<Response<InvokeRpcResponse>, Status>

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

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

pub async fn wait_for_step_completion( &mut self, request: impl IntoRequest<WaitForStepCompletionRequest>, ) -> Result<Response<WaitForStepCompletionResponse>, Status>

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

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

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

Trait Implementations§

impl<T: Clone> Clone for FlowServiceClient<T>

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

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

impl<T: Debug> Debug for FlowServiceClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for FlowServiceClient<T>

impl<T> RefUnwindSafe for FlowServiceClient<T>where Grpc<T>: RefUnwindSafe,

impl<T> Send for FlowServiceClient<T>where Grpc<T>: Send,

impl<T> Sync for FlowServiceClient<T>where Grpc<T>: Sync,

impl<T> Unpin for FlowServiceClient<T>where Grpc<T>: Unpin,

impl<T> UnsafeUnpin for FlowServiceClient<T>where Grpc<T>: UnsafeUnpin,

impl<T> UnwindSafe for FlowServiceClient<T>where Grpc<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> 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> 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 = !

fn try_from(value: U) -> Result<T, !>

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

Struct FlowServiceClient

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

impl<T> FlowServiceClient<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 FlowServiceClient<T>
where Grpc<T>: RefUnwindSafe,

impl<T> Send for FlowServiceClient<T>
where Grpc<T>: Send,

impl<T> Sync for FlowServiceClient<T>
where Grpc<T>: Sync,

impl<T> Unpin for FlowServiceClient<T>
where Grpc<T>: Unpin,

impl<T> UnsafeUnpin for FlowServiceClient<T>
where Grpc<T>: UnsafeUnpin,

impl<T> UnwindSafe for FlowServiceClient<T>
where Grpc<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> 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>,