Struct hitbox_actix::messages::QueryCache

pub struct QueryCache<A, M> where
    M: Message + Cacheable + Send,
    M::Result: MessageResponse<A, M> + Send,
    A: Actor,  { /* fields omitted */ }

Intermediate actix message which handled by Cache actor.

This message a product of upstream message and upstream actor address. In other words, QueryCache is a struct that includes base message with user data and address of an actor that is a recipient of this message. You can only send QueryCache messages to Cache actor.

Implementations

impl<A, M> QueryCache<A, M> where
    M: Message + Cacheable + Send,
    M::Result: MessageResponse<A, M> + Send,
    A: Actor, 

pub fn cache_key(&self) -> Result<String, CacheError>

Returns final cache key.

This method compose final cache key from Cacheable::cache_key and Upstream actor type name.

Trait Implementations

impl<'a, A, M, B> Handler<QueryCache<A, M>> for CacheActor<B> where
    B: Actor + Backend,
    <B as Actor>::Context: ToEnvelope<B, Get> + ToEnvelope<B, Set> + ToEnvelope<B, Lock> + ToEnvelope<B, Delete>,
    A: Actor + Handler<M> + Send,
    M: Message + Cacheable + Send + 'static,
    M::Result: MessageResponse<A, M> + CacheableResponse + Debug + Send,
    <<M as Message>::Result as CacheableResponse>::Cached: Serialize + DeserializeOwned,
    <A as Actor>::Context: ToEnvelope<A, M>, 

type Result = ResponseFuture<Result<<M as Message>::Result, CacheError>>

The type of value that this handler will return.

fn handle(
    &mut self,
    msg: QueryCache<A, M>,
    _: &mut Self::Context
) -> Self::Result

This method is called for every message received by this actor.

impl<'a, A, M> Message for QueryCache<A, M> where
    A: Actor,
    M: Message + Cacheable + Send,
    M::Result: MessageResponse<A, M> + Send, 

type Result = Result<<M as Message>::Result, CacheError>

The type of value that this message will resolved with if it is successful.