Struct splinter::service::ServiceProcessor [−][src]
pub struct ServiceProcessor { /* fields omitted */ }
Expand description
The ServiceProcessor handles the networking for services. This includes talking to the splinter node, connecting for authorization, registering the services, and routing direct messages to the correct service.
Implementations
pub fn new(
connection: Box<dyn Connection>,
circuit: String,
incoming_capacity: usize,
outgoing_capacity: usize,
channel_capacity: usize
) -> Result<Self, ServiceProcessorError>
add_service takes a Service and sets up the thread that the service will run in. The service will be started, including registration and then messages are routed to the the services using a channel.
Once the service processor is started it will handle incoming messages from the splinter node and route it to a running service.
Returns a ShutdownHandle impelmentation so the service can be properly shutdown.
Auto Trait Implementations
impl !RefUnwindSafe for ServiceProcessor
impl Send for ServiceProcessor
impl !Sync for ServiceProcessor
impl Unpin for ServiceProcessor
impl !UnwindSafe for ServiceProcessor
Blanket Implementations
Mutably borrows from an owned value. 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
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more