Struct RootGraphService 

pub struct RootGraphService<B>
where
    B: Backend + WireFormatBackend,
{ /* private fields */ }

Service that manages the execution of a Graph workflow

Implementations

impl<B> RootGraphService<B>

where B: Backend + WireFormatBackend,

pub fn get_node_by_name_mut( &mut self, name: &str, ) -> Option<&mut BoxCloneSyncService<Task<NodeInput<B::Compact>>, (B::Compact, Value), BoxDynError>>

Get a node by name

Trait Implementations

impl<B> Clone for RootGraphService<B>

where B: Backend + WireFormatBackend + Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B> Debug for RootGraphService<B>

where B: Backend + WireFormatBackend,

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

Formats the value using the given formatter.

impl<B, Compact, Err> IntoWorkerService<B, RootGraphService<B>> for GraphFlow<B>

where B: Backend<Error = Err, Task = Task<Compact>> + WireFormatBackend<Compact = Compact> + Clone, Err: Error + Send + Sync + 'static, B::Compact: Send + Sync + 'static + Clone, RootGraphService<B>: Service<Task<Compact>>,

type Task = Task<Compact>

The task type processed by the worker.

type Backend = B

The backend type used by the worker service.

fn into_service(self, b: B) -> WorkerService<B, RootGraphService<B>>

Builds a worker service from the provided backend.

impl<B, Err, CdcErr, Id, Compact> Service<Task<Compact>> for RootGraphService<B>

where B: Backend<Error = Err> + BackendConfig<Id = Id> + WireFormatBackend<Compact = Compact> + Send + Sync + 'static + Clone + WaitForCompletion<GraphNodeResponse> + Sink<Task<B::Compact>, Error = Err> + Unpin, Id: GenerateId + Send + Sync + 'static + PartialEq + Debug + FromStr + Display, Compact: Send + Sync + 'static + Clone, Err: Error + Send + Sync + 'static, B::Codec: Codec<Vec<Compact>, Compact = Compact, Error = CdcErr> + Send + Sync + Clone + 'static, CdcErr: Into<BoxDynError>, <Id as FromStr>::Err: Error + Send + Sync + 'static,

type Response = GraphNodeResponse

Responses given by the service.

type Error = GraphFlowError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<RootGraphService<B> as Service<Task<Compact>>>::Response, <RootGraphService<B> as Service<Task<Compact>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Task<B::Compact>) -> Self::Future

Process the request and return the response asynchronously.