Struct hitbox_actix::runtime::ActixAdapter

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

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.