Struct splinter::service::ServiceProcessor

pub struct ServiceProcessor { /* fields omitted */ }

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

impl ServiceProcessor

pub fn new(
    connection: Box<dyn Connection>,
    circuit: String,
    incoming_capacity: usize,
    outgoing_capacity: usize,
    channel_capacity: usize
) -> Result<Self, ServiceProcessorError>

pub fn add_service(
    &mut self,
    service: Box<dyn Service>
) -> Result<(), 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.

pub fn start(
    self
) -> Result<ServiceProcessorShutdownHandle, ServiceProcessorError>

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.