pub trait Request: Clone {
    type Reply: Clone + IntoReply<Self::Reply> + From<AsError>;
    type FrontCodec: Decoder<Item = Self, Error = AsError> + Encoder<Item = Self, Error = AsError> + Default + 'static;
    type BackCodec: Decoder<Item = Self::Reply, Error = AsError> + Encoder<Item = Self, Error = AsError> + Default + 'static;

Show 14 methods fn ping_request() -> Self; fn reregister(&mut self, task: Task); fn key_hash(&self, hash_tag: &[u8], hasher: fn(_: &[u8]) -> u64) -> u64; fn subs(&self) -> Option<Vec<Self>>; fn mark_total(&self, cluster: &str); fn mark_remote(&self, cluster: &str); fn is_done(&self) -> bool; fn is_error(&self) -> bool; fn add_cycle(&self); fn can_cycle(&self) -> bool; fn valid(&self) -> bool; fn set_reply<R: IntoReply<Self::Reply>>(&self, t: R); fn set_error(&self, t: &AsError); fn get_sendtime(&self) -> Option<Instant>;
}

Required Associated Types

Required Methods

Implementors