Skip to main content

AppState

Struct AppState 

Source
pub struct AppState {
    pub registry: Arc<AnyRegistry>,
    pub admin_api_key: String,
    pub token_config: TokenConfig,
    pub session_store: AnySessionStore,
    pub policy_config: Arc<Sender<Arc<Option<PolicyConfig>>>>,
    pub audit_sink: Option<Arc<AuditSink>>,
    pub policy_file_path: Option<String>,
    pub warning_threshold_pct: f64,
    pub default_rate_limit_window_secs: u64,
    pub metrics: Arc<ArbiterMetrics>,
    pub max_concurrent_sessions_per_agent: Option<u64>,
    pub admin_rate_limiter: Arc<AdminRateLimiter>,
}
Expand description

Shared application state for the lifecycle API.

Fields§

§registry: Arc<AnyRegistry>§admin_api_key: String§token_config: TokenConfig§session_store: AnySessionStore§policy_config: Arc<Sender<Arc<Option<PolicyConfig>>>>§audit_sink: Option<Arc<AuditSink>>

Audit sink for querying per-session stats on close.

§policy_file_path: Option<String>

Path to the policy TOML file (for hot-reload).

§warning_threshold_pct: f64

Percentage threshold for session budget/time warnings.

§default_rate_limit_window_secs: u64

Default rate-limit window duration in seconds for new sessions.

§metrics: Arc<ArbiterMetrics>

Shared metrics for gauge updates (active_sessions, registered_agents).

§max_concurrent_sessions_per_agent: Option<u64>

Maximum concurrent active sessions per agent (None = no limit). P0: Per-agent session cap to prevent session multiplication attacks.

§admin_rate_limiter: Arc<AdminRateLimiter>

Rate limiter for admin API endpoints. Shared via Arc so the Clone-based axum state sharing works correctly.

Implementations§

Source§

impl AppState

Source

pub fn new(admin_api_key: String) -> Self

Create a new application state with the given admin API key.

Source

pub fn with_token_config( admin_api_key: String, token_config: TokenConfig, ) -> Self

Create a new application state with custom token config.

Source

pub fn with_admin_rate_limit(self, max_requests_per_minute: u64) -> Self

Create a rate limiter with a custom max requests per minute.

Source

pub fn admin_audit_log( &self, operation: &str, agent_id: Option<Uuid>, detail: &str, )

Log an admin API operation with structured fields for audit trail.

All admin operations are now logged at info level with structured tracing fields for observability and forensic analysis.

Trait Implementations§

Source§

impl Clone for AppState

Source§

fn clone(&self) -> AppState

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,