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>;
}