Struct splinter::orchestrator::ServiceOrchestratorBuilder [−][src]
pub struct ServiceOrchestratorBuilder { /* fields omitted */ }Expand description
Builds new RunnableServiceOrchestrator instances.
Implementations
Sets the connection for receiving service messages by the resulting ServiceOrchestrator.
This field is required to construct the final ServiceOrchestrator.
Sets the incoming message capacity.
This limits the amount of messages that may be buffered by the service orchestrator before blocking new messages.
Sets the outgoing message capacity.
This limits the amount of messages that may be buffered by the service orchestrator when being sent to external connections.
Sets the internal channel capacity.
This limits the number of messages that may be buffered when passed between the internal threads.
Adds a service factory which will be used to create service instances.
This function may be called more than once to add additional service factories.
Construct the RunnableServiceOrchestrator.
Errors
Returns an InvalidStateError, if any required fields are missing.
Trait Implementations
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ServiceOrchestratorBuilderimpl Send for ServiceOrchestratorBuilderimpl !Sync for ServiceOrchestratorBuilderimpl Unpin for ServiceOrchestratorBuilderimpl !UnwindSafe for ServiceOrchestratorBuilderBlanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span, returning an
Instrumented wrapper. Read more
Instruments this type with the provided Span, returning an
Instrumented wrapper. Read more
Convert self to an expression for Diesel’s query builder. Read more
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>, Convert &self to an expression for Diesel’s query builder. Read more
type Output = T
type Output = TShould always be Self
pub fn vzip(self) -> V