Struct splinter::service::ServiceProcessorBuilder
source · [−]pub struct ServiceProcessorBuilder { /* private fields */ }
Expand description
Builds new ServiceProcessors.
Implementations
sourceimpl ServiceProcessorBuilder
impl ServiceProcessorBuilder
sourcepub fn with_connection(self, connection: Box<dyn Connection>) -> Self
pub fn with_connection(self, connection: Box<dyn Connection>) -> Self
Sets the connection for receiving service messages by the resulting ServiceProcessor.
This field is required to construct the final ServiceProcessor.
sourcepub fn with_circuit(self, circuit: String) -> Self
pub fn with_circuit(self, circuit: String) -> Self
Sets the circuit associated with all of the services in this processor.
This field is required to construct the final ServiceProcessor.
sourcepub fn with_incoming_capacity(self, incoming_capacity: usize) -> Self
pub fn with_incoming_capacity(self, incoming_capacity: usize) -> Self
Sets the incoming message capacity.
This limits the amount of messages that may be buffered by the service processor before blocking new messages.
sourcepub fn with_outgoing_capacity(self, outgoing_capacity: usize) -> Self
pub fn with_outgoing_capacity(self, outgoing_capacity: usize) -> Self
Sets the outgoing message capacity.
This limits the amount of messages that may be buffered by the service processor when being sent to external connections.
sourcepub fn with_channel_capacity(self, channel_capacity: usize) -> Self
pub fn with_channel_capacity(self, channel_capacity: usize) -> Self
Sets the internal channel capacity.
This limits the number of messages that may be buffered when passed between the internal threads.
sourcepub fn with_service(self, service: Box<dyn Service>) -> Self
pub fn with_service(self, service: Box<dyn Service>) -> Self
Adds a service to be managed by the resulting ServiceProcessor.
This function may be called more than once to add additional services. It must be called at least once to construct a valid service processor.
sourcepub fn build(self) -> Result<ServiceProcessor, InvalidStateError>
pub fn build(self) -> Result<ServiceProcessor, InvalidStateError>
Construct the ServiceProcessor.
Errors
Returns an InvalidStateError, if any required fields are missing.
Trait Implementations
sourceimpl Default for ServiceProcessorBuilder
impl Default for ServiceProcessorBuilder
sourcefn default() -> ServiceProcessorBuilder
fn default() -> ServiceProcessorBuilder
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ServiceProcessorBuilder
impl Send for ServiceProcessorBuilder
impl !Sync for ServiceProcessorBuilder
impl Unpin for ServiceProcessorBuilder
impl !UnwindSafe for ServiceProcessorBuilder
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<P, N> IntoBytes<P> for N where
P: Message + FromNative<N>,
impl<P, N> IntoBytes<P> for N where
P: Message + FromNative<N>,
fn into_bytes(self) -> Result<Vec<u8, Global>, ProtoConversionError>
sourceimpl<N, P> IntoNative<N> for P where
N: FromProto<P>,
impl<N, P> IntoNative<N> for P where
N: FromProto<P>,
fn into_native(self) -> Result<N, ProtoConversionError>
sourceimpl<N, P> IntoProto<P> for N where
P: FromNative<N>,
impl<N, P> IntoProto<P> for N where
P: FromNative<N>,
fn into_proto(self) -> Result<P, ProtoConversionError>
sourceimpl<T> IntoSql for T
impl<T> IntoSql for T
sourcefn into_sql<T>(self) -> Self::Expression where
Self: AsExpression<T>,
fn into_sql<T>(self) -> Self::Expression where
Self: AsExpression<T>,
Convert self
to an expression for Diesel’s query builder. Read more
sourcefn 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
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more