Struct pemmican::Pemmican

pub struct Pemmican<S, E> {
    pub shared: Arc<Shared<S>>,
    pub plugins: Vec<Arc<Box<Plugin<S, E>>>>,
    // some fields omitted
}

A Pemmican server instance.

Fields

shared: Arc<Shared<S>>

plugins: Vec<Arc<Box<Plugin<S, E>>>>

Methods

impl<S, E> Pemmican<S, E> where
    S: 'static,
    E: Send + Sync + StdError + 'static, 

fn new(
    config: Config,
    plugins: Vec<Arc<Box<Plugin<S, E>>>>,
    initial_state: S
) -> Pemmican<S, E>

Create a new pemmican server instance

fn run<F>(self, addr: &str, shutdown_signal: F) -> Result<(), Error> where
    F: Future<Item = (), Error = ()>, 

Run the server. It will run until the shutdown_signal future completes. You can use futures::future::empty() to run forever.

Trait Implementations

impl<S, E> Service for Pemmican<S, E> where
    S: 'static,
    E: Send + Sync + StdError + 'static, 

type Request = Request

Requests handled by the service.

type Response = Response

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Box<Future<Item = Self::Response, Error = Self::Error>>

The future response value.

fn call(&self, req: Request) -> Self::Future

Process the request and return the response asynchronously.