Struct WorkflowGrpcService 

pub struct WorkflowGrpcService { /* private fields */ }

Cloneable tonic implementation for workflow management.

Implementations

impl WorkflowGrpcService

pub const fn new(state: ServerState) -> Self

Build a tonic workflow service from shared server state.

Trait Implementations

impl Clone for WorkflowGrpcService

fn clone(&self) -> WorkflowGrpcService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl WorkflowService for WorkflowGrpcService

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

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

Retire a workloop: the declared way to stop a loop, which is not failure. Routed to the shard owner like every other write, because it appends a terminal batch.

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

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

Mint (or gate) an already-authorized namespace set on THIS node — the owner side of namespace-mint routing. See WorkflowGrpcService::mint_namespace_here for the authorization and policy-parity contract this delegates to.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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