Trait FlowService 

pub trait FlowService:
    Send
    + Sync
    + 'static {
    // Required methods
    fn start_flow<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StartFlowRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<StartFlowResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn publish_to_channel<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PublishToChannelRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stop_flow<'life0, 'async_trait>(
        &'life0 self,
        request: Request<StopFlowRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_attributes<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetAttributesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetAttributesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn set_attributes<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SetAttributesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn load_blobs<'life0, 'async_trait>(
        &'life0 self,
        request: Request<LoadBlobsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<LoadBlobsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn wait_for_flow<'life0, 'async_trait>(
        &'life0 self,
        request: Request<WaitForFlowRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<FlowResult>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn search_flows<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SearchFlowsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<SearchFlowsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn sync_attribute_indexes<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SyncAttributeIndexRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<SyncAttributeIndexResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_flow_summary<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetFlowSummaryRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetFlowSummaryResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_history_events<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetHistoryEventsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetHistoryEventsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn wait_for_history_event<'life0, 'async_trait>(
        &'life0 self,
        request: Request<WaitForHistoryEventRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<WaitForHistoryEventResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_flow_state<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetFlowStateRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetFlowStateResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn reset_flow<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ResetFlowRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ResetFlowResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn invoke_rpc<'life0, 'async_trait>(
        &'life0 self,
        request: Request<InvokeRpcRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<InvokeRpcResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn skip_timer<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SkipTimerRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_flow_config<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateFlowConfigRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn wait_for_step_completion<'life0, 'async_trait>(
        &'life0 self,
        request: Request<WaitForStepCompletionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<WaitForStepCompletionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn wait_for_attribute<'life0, 'async_trait>(
        &'life0 self,
        request: Request<WaitForAttributeRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn trigger_continue_as_new<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TriggerContinueAsNewRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn health_check<'life0, 'async_trait>(
        &'life0 self,
        request: Request<()>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<HealthInfo>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Generated trait containing gRPC methods that should be implemented for use with FlowServiceServer.

Required Methods

fn start_flow<'life0, 'async_trait>( &'life0 self, request: Request<StartFlowRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<StartFlowResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn publish_to_channel<'life0, 'async_trait>( &'life0 self, request: Request<PublishToChannelRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop_flow<'life0, 'async_trait>( &'life0 self, request: Request<StopFlowRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_attributes<'life0, 'async_trait>( &'life0 self, request: Request<GetAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAttributesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn set_attributes<'life0, 'async_trait>( &'life0 self, request: Request<SetAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn load_blobs<'life0, 'async_trait>( &'life0 self, request: Request<LoadBlobsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<LoadBlobsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn wait_for_flow<'life0, 'async_trait>( &'life0 self, request: Request<WaitForFlowRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlowResult>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn search_flows<'life0, 'async_trait>( &'life0 self, request: Request<SearchFlowsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SearchFlowsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn sync_attribute_indexes<'life0, 'async_trait>( &'life0 self, request: Request<SyncAttributeIndexRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SyncAttributeIndexResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_flow_summary<'life0, 'async_trait>( &'life0 self, request: Request<GetFlowSummaryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetFlowSummaryResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_history_events<'life0, 'async_trait>( &'life0 self, request: Request<GetHistoryEventsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetHistoryEventsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn wait_for_history_event<'life0, 'async_trait>( &'life0 self, request: Request<WaitForHistoryEventRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<WaitForHistoryEventResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_flow_state<'life0, 'async_trait>( &'life0 self, request: Request<GetFlowStateRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetFlowStateResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn reset_flow<'life0, 'async_trait>( &'life0 self, request: Request<ResetFlowRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResetFlowResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn invoke_rpc<'life0, 'async_trait>( &'life0 self, request: Request<InvokeRpcRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<InvokeRpcResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn skip_timer<'life0, 'async_trait>( &'life0 self, request: Request<SkipTimerRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn update_flow_config<'life0, 'async_trait>( &'life0 self, request: Request<UpdateFlowConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn wait_for_step_completion<'life0, 'async_trait>( &'life0 self, request: Request<WaitForStepCompletionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<WaitForStepCompletionResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn wait_for_attribute<'life0, 'async_trait>( &'life0 self, request: Request<WaitForAttributeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn trigger_continue_as_new<'life0, 'async_trait>( &'life0 self, request: Request<TriggerContinueAsNewRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn health_check<'life0, 'async_trait>( &'life0 self, request: Request<()>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthInfo>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors