pub struct WorkflowClient<T: Send + Sync> { /* private fields */ }Expand description
Transport-neutral client for the public gestaltd App surface.
Implementations§
Source§impl<T: Send + Sync> WorkflowClient<T>
impl<T: Send + Sync> WorkflowClient<T>
Source§impl<T: UnaryTransport> WorkflowClient<T>
impl<T: UnaryTransport> WorkflowClient<T>
pub async fn apply_definition( &self, request: ApplyWorkflowProviderDefinitionRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub async fn get_definition( &self, request: GetWorkflowProviderDefinitionRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub async fn list_definitions( &self, request: ListWorkflowProviderDefinitionsRequest, ) -> Result<ListWorkflowProviderDefinitionsResponse, GestaltError>
pub async fn set_definition_paused( &self, request: SetWorkflowProviderDefinitionPausedRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub async fn set_activation_paused( &self, request: SetWorkflowProviderActivationPausedRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub async fn delete_definition( &self, request: DeleteWorkflowProviderDefinitionRequest, ) -> Result<(), GestaltError>
pub async fn start_run( &self, request: StartWorkflowProviderRunRequest, ) -> Result<WorkflowRun, GestaltError>
pub async fn list_runs( &self, request: ListWorkflowProviderRunsRequest, ) -> Result<ListWorkflowProviderRunsResponse, GestaltError>
pub async fn get_run( &self, request: GetWorkflowProviderRunRequest, ) -> Result<WorkflowRun, GestaltError>
pub async fn get_run_events( &self, request: GetWorkflowProviderRunEventsRequest, ) -> Result<GetWorkflowProviderRunEventsResponse, GestaltError>
pub async fn get_run_output( &self, request: GetWorkflowProviderRunOutputRequest, ) -> Result<GetWorkflowProviderRunOutputResponse, GestaltError>
pub async fn cancel_run( &self, request: CancelWorkflowProviderRunRequest, ) -> Result<WorkflowRun, GestaltError>
pub async fn signal_run( &self, request: SignalWorkflowProviderRunRequest, ) -> Result<SignalWorkflowRunResponse, GestaltError>
pub async fn signal_or_start_run( &self, request: SignalOrStartWorkflowProviderRunRequest, ) -> Result<SignalWorkflowRunResponse, GestaltError>
Source§impl<T: SyncUnaryTransport> WorkflowClient<T>
impl<T: SyncUnaryTransport> WorkflowClient<T>
pub fn apply_definition_sync( &self, request: ApplyWorkflowProviderDefinitionRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub fn get_definition_sync( &self, request: GetWorkflowProviderDefinitionRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub fn list_definitions_sync( &self, request: ListWorkflowProviderDefinitionsRequest, ) -> Result<ListWorkflowProviderDefinitionsResponse, GestaltError>
pub fn set_definition_paused_sync( &self, request: SetWorkflowProviderDefinitionPausedRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub fn set_activation_paused_sync( &self, request: SetWorkflowProviderActivationPausedRequest, ) -> Result<WorkflowDefinition, GestaltError>
pub fn delete_definition_sync( &self, request: DeleteWorkflowProviderDefinitionRequest, ) -> Result<(), GestaltError>
pub fn start_run_sync( &self, request: StartWorkflowProviderRunRequest, ) -> Result<WorkflowRun, GestaltError>
pub fn list_runs_sync( &self, request: ListWorkflowProviderRunsRequest, ) -> Result<ListWorkflowProviderRunsResponse, GestaltError>
pub fn get_run_sync( &self, request: GetWorkflowProviderRunRequest, ) -> Result<WorkflowRun, GestaltError>
pub fn get_run_events_sync( &self, request: GetWorkflowProviderRunEventsRequest, ) -> Result<GetWorkflowProviderRunEventsResponse, GestaltError>
pub fn get_run_output_sync( &self, request: GetWorkflowProviderRunOutputRequest, ) -> Result<GetWorkflowProviderRunOutputResponse, GestaltError>
pub fn cancel_run_sync( &self, request: CancelWorkflowProviderRunRequest, ) -> Result<WorkflowRun, GestaltError>
pub fn signal_run_sync( &self, request: SignalWorkflowProviderRunRequest, ) -> Result<SignalWorkflowRunResponse, GestaltError>
pub fn signal_or_start_run_sync( &self, request: SignalOrStartWorkflowProviderRunRequest, ) -> Result<SignalWorkflowRunResponse, GestaltError>
Auto Trait Implementations§
impl<T> Freeze for WorkflowClient<T>where
T: Freeze,
impl<T> RefUnwindSafe for WorkflowClient<T>where
T: RefUnwindSafe,
impl<T> Send for WorkflowClient<T>
impl<T> Sync for WorkflowClient<T>
impl<T> Unpin for WorkflowClient<T>where
T: Unpin,
impl<T> UnsafeUnpin for WorkflowClient<T>where
T: UnsafeUnpin,
impl<T> UnwindSafe for WorkflowClient<T>where
T: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request