Struct RouterSharedState

Source

pub struct RouterSharedState {
    pub validation_plan: ValidationPlan,
    pub parse_cache: Cache<u64, ParseCacheEntry>,
    pub router_config: Arc<HiveRouterConfig>,
    pub headers_plan: HeaderRulesPlan,
    pub override_labels_evaluator: OverrideLabelsEvaluator,
    pub cors_runtime: Option<Cors>,
    pub jwt_claims_cache: Cache<String, Arc<TokenData<JwtClaims>>>,
    pub jwt_auth_runtime: Option<JwtAuthRuntime>,
    pub hive_usage_agent: Option<UsageAgent>,
    pub introspection_policy: BooleanOrProgram,
    pub telemetry_context: Arc<TelemetryContext>,
}

Fields§

§validation_plan: ValidationPlan§parse_cache: Cache<u64, ParseCacheEntry>§router_config: Arc<HiveRouterConfig>§headers_plan: HeaderRulesPlan§override_labels_evaluator: OverrideLabelsEvaluator§cors_runtime: Option<Cors>§jwt_claims_cache: Cache<String, Arc<TokenData<JwtClaims>>>

Cache for validated JWT claims to avoid re-parsing on every request. The cache key is the raw JWT token string. Stores the parsed claims payload for 5s, but no longer than exp date.

§jwt_auth_runtime: Option<JwtAuthRuntime>§hive_usage_agent: Option<UsageAgent>§introspection_policy: BooleanOrProgram§telemetry_context: Arc<TelemetryContext>

RouterSharedState

Struct RouterSharedState Copy item path

Fields§

Implementations§

impl RouterSharedState

pub fn new( router_config: Arc<HiveRouterConfig>, jwt_auth_runtime: Option<JwtAuthRuntime>, hive_usage_agent: Option<UsageAgent>, validation_plan: ValidationPlan, telemetry_context: Arc<TelemetryContext>, ) -> Result<Self, SharedStateError>

Auto Trait Implementations§

impl Freeze for RouterSharedState

impl !RefUnwindSafe for RouterSharedState

impl Send for RouterSharedState

impl Sync for RouterSharedState

impl Unpin for RouterSharedState

impl !UnwindSafe for RouterSharedState

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<Source, Target> OctetsInto<Target> for Sourcewhere Target: OctetsFrom<Source>,

type Error = <Target as OctetsFrom<Source>>::Error

fn try_octets_into( self, ) -> Result<Target, <Source as OctetsInto<Target>>::Error>

fn octets_into(self) -> Targetwhere Self::Error: Into<Infallible>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct RouterSharedState

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<Source, Target> OctetsInto<Target> for Source
where Target: OctetsFrom<Source>,

fn octets_into(self) -> Target
where Self::Error: Into<Infallible>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,