Struct ActixAdapter 

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

RuntimeAdapter for Actix runtime.

Implementations

impl<A, M, B> ActixAdapter<A, M, B>

where A: Actor + Handler<M>, M: Message + Cacheable + Send, M::Result: MessageResponse<A, M> + Send, B: Backend,

pub fn new( message: QueryCache<A, M>, backend: Addr<B>, ) -> Result<Self, CacheError>

Creates new instance of Actix runtime adapter.

Trait Implementations

impl<A, M, T, B, U> RuntimeAdapter for ActixAdapter<A, M, B>

where A: Actor + Handler<M>, A::Context: ToEnvelope<A, M>, M: Message<Result = T> + Cacheable + Send + 'static, M::Result: MessageResponse<A, M> + Send, B: Backend, <B as Actor>::Context: ToEnvelope<B, Get> + ToEnvelope<B, Set>, T: CacheableResponse<Cached = U> + 'static, U: DeserializeOwned + Serialize,

type UpstreamResult = T

Associated type describes the upstream result.

fn poll_upstream(&mut self) -> AdapterResult<Self::UpstreamResult>

Send data to upstream and return Self::UpstreamResult

fn poll_cache(&self) -> AdapterResult<CacheState<Self::UpstreamResult>>

Check cache and return current state of cached data.

fn update_cache( &self, cached_value: &CachedValue<Self::UpstreamResult>, ) -> AdapterResult<()>

Write or update Self::UpstreamResult into cache.

fn eviction_settings(&self) -> EvictionPolicy

Returns eviction settings for current cacheable data.