Enum State 

pub enum State<Res, Req, U, ReqP, E>
where
    Res: CacheableResponse,
    Req: CacheableRequest,
    U: Upstream<Req, Response = Res>,
    ReqP: Predicate<Subject = Req>,
    E: Extractor<Subject = Req>,
{
    Initial(Option<Initial<Req, ReqP, E, U>>),
    CheckRequestCachePolicy {
        cache_policy_future: BoxFuture<'static, RequestCachePolicy<Req>>,
        state: Option<CheckRequestCachePolicy<U>>,
    },
    PollCache {
        poll_cache: PollCacheFuture<Res::Cached>,
        state: Option<PollCache<Req, U>>,
    },
    ConvertResponse {
        response_future: ConvertResponseFuture<Res>,
        state: Option<ConvertResponse>,
    },
    HandleStale {
        response_future: ConvertResponseFuture<Res>,
        state: Option<HandleStale<Req, U>>,
    },
    AwaitResponse {
        await_response_future: BoxFuture<'static, Result<Res, ConcurrencyError>>,
        state: Option<AwaitResponse<Req, U>>,
    },
    PollUpstream {
        upstream_future: Instrumented<U::Future>,
        state: Option<PollUpstream>,
    },
    CheckResponseCachePolicy {
        cache_policy: BoxFuture<'static, ResponseCachePolicy<Res>>,
        state: Option<CheckResponseCachePolicy>,
    },
    UpdateCache {
        update_cache_future: BoxFuture<'static, (Result<(), BackendError>, Res, BoxContext)>,
        state: Option<UpdateCache>,
    },
    Response(Option<Response<Res>>),
}

Variants

Initial(Option<Initial<Req, ReqP, E, U>>)

Initial state - all data needed for the first transition

CheckRequestCachePolicy

Checking if request should be cached

Fields

cache_policy_future: BoxFuture<'static, RequestCachePolicy<Req>>

state: Option<CheckRequestCachePolicy<U>>

PollCache

Polling the cache backend - context is captured in the future

Fields

poll_cache: PollCacheFuture<Res::Cached>

state: Option<PollCache<Req, U>>

ConvertResponse

Converting cached value to response (cache hit, no refill needed)

Fields

response_future: ConvertResponseFuture<Res>

state: Option<ConvertResponse>

HandleStale

Handling stale cache hit - convert to response then apply stale policy

Fields

response_future: ConvertResponseFuture<Res>

state: Option<HandleStale<Req, U>>

AwaitResponse

Awaiting response from another concurrent request

Fields

await_response_future: BoxFuture<'static, Result<Res, ConcurrencyError>>

state: Option<AwaitResponse<Req, U>>

PollUpstream

Polling upstream service

Fields

upstream_future: Instrumented<U::Future>

state: Option<PollUpstream>

CheckResponseCachePolicy

Checking if response should be cached

Fields

cache_policy: BoxFuture<'static, ResponseCachePolicy<Res>>

state: Option<CheckResponseCachePolicy>

UpdateCache

Updating cache with response - context is captured in the future

Fields

update_cache_future: BoxFuture<'static, (Result<(), BackendError>, Res, BoxContext)>

state: Option<UpdateCache>

Response(Option<Response<Res>>)

Final state with response

Trait Implementations

impl<Res, Req, U, ReqP, E> Debug for State<Res, Req, U, ReqP, E>

where Res: CacheableResponse, Req: CacheableRequest, U: Upstream<Req, Response = Res>, ReqP: Predicate<Subject = Req>, E: Extractor<Subject = Req>,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'pin, Res, Req, U, ReqP, E> Unpin for State<Res, Req, U, ReqP, E>

where Res: CacheableResponse, Req: CacheableRequest, U: Upstream<Req, Response = Res>, ReqP: Predicate<Subject = Req>, E: Extractor<Subject = Req>, PinnedFieldsOf<__State<'pin, Res, Req, U, ReqP, E>>: Unpin,