Trait scylla_rs::app::worker::Worker[−][src]

pub trait Worker: Send {
    fn handle_response(self: Box<Self>, giveload: Vec<u8>) -> Result<()>;

    fn handle_error(
        self: Box<Self>, 
        error: WorkerError, 
        reporter: &Option<ReporterHandle>
    ) -> Result<()>;
}

WorkerId trait type which will be implemented by worker in order to send their channel_tx.

Required methods

fn handle_response(self: Box<Self>, giveload: Vec<u8>) -> Result<()>[src]

Reporter will invoke this method to Send the cql response to worker

fn handle_error(
    self: Box<Self>,
    error: WorkerError,
    reporter: &Option<ReporterHandle>
) -> Result<()>[src]

Reporter will invoke this method to Send the worker error to worker

Loading content...

Implementors

impl Worker for PrepareWorker[src]

impl<H, S, K, V> Worker for SelectWorker<H, S, K, V> where
    S: 'static + Select<K, V>,
    K: 'static + Send + Clone,
    V: 'static + Send + Clone,
    H: 'static + Send + HandleResponse<Self, Response = Decoder> + HandleError<Self> + Clone, [src]

impl<S, H, K, V> Worker for ValueWorker<H, S, K, V> where
    S: 'static + Select<K, V> + Clone,
    K: 'static + Send + Clone,
    V: 'static + Send + Clone,
    H: 'static + Send + HandleResponse<Self, Response = Option<V>> + HandleError<Self> + Clone, [src]

impl<S, K, V> Worker for DeleteWorker<S, K, V> where
    S: 'static + Delete<K, V>,
    K: 'static + Send + Clone,
    V: 'static + Send + Clone, [src]

impl<S, K, V> Worker for InsertWorker<S, K, V> where
    S: 'static + Insert<K, V>,
    K: 'static + Send + Clone,
    V: 'static + Send + Clone, [src]

Loading content...