Struct QueryCache

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

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 = Pin<Box<dyn Future<Output = 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.