Struct AdminState 

pub struct AdminState {

    pub http_server_addr: Option<SocketAddr>,
    pub ws_server_addr: Option<SocketAddr>,
    pub grpc_server_addr: Option<SocketAddr>,
    pub graphql_server_addr: Option<SocketAddr>,
    pub api_enabled: bool,
    pub admin_port: u16,
    pub start_time: DateTime<Utc>,
    pub metrics: Arc<RwLock<RequestMetrics>>,
    pub system_metrics: Arc<RwLock<SystemMetrics>>,
    pub config: Arc<RwLock<ConfigurationState>>,
    pub logs: Arc<RwLock<Vec<RequestLog>>>,
    pub time_series: Arc<RwLock<TimeSeriesData>>,
    pub restart_status: Arc<RwLock<RestartStatus>>,
    pub smoke_test_results: Arc<RwLock<Vec<SmokeTestResult>>>,
    pub import_history: Arc<RwLock<Vec<ImportHistoryEntry>>>,
    pub workspace_persistence: Arc<WorkspacePersistence>,
    pub plugin_registry: Arc<RwLock<PluginRegistry>>,
}

Shared state for the admin UI

Fields

http_server_addr: Option<SocketAddr>

HTTP server address

ws_server_addr: Option<SocketAddr>

WebSocket server address

grpc_server_addr: Option<SocketAddr>

gRPC server address

graphql_server_addr: Option<SocketAddr>

GraphQL server address

api_enabled: bool

Whether API endpoints are enabled

admin_port: u16

Admin server port

start_time: DateTime<Utc>

Start time

metrics: Arc<RwLock<RequestMetrics>>

Request metrics (protected by RwLock)

system_metrics: Arc<RwLock<SystemMetrics>>

System metrics (protected by RwLock)

config: Arc<RwLock<ConfigurationState>>

Configuration (protected by RwLock)

logs: Arc<RwLock<Vec<RequestLog>>>

Request logs (protected by RwLock)

time_series: Arc<RwLock<TimeSeriesData>>

Time series data (protected by RwLock)

restart_status: Arc<RwLock<RestartStatus>>

Restart status (protected by RwLock)

smoke_test_results: Arc<RwLock<Vec<SmokeTestResult>>>

Smoke test results (protected by RwLock)

import_history: Arc<RwLock<Vec<ImportHistoryEntry>>>

Import history (protected by RwLock)

workspace_persistence: Arc<WorkspacePersistence>

Workspace persistence

plugin_registry: Arc<RwLock<PluginRegistry>>

Plugin registry (protected by RwLock)

Implementations

impl AdminState

pub async fn start_system_monitoring(&self)

Start system monitoring background task

pub fn new( http_server_addr: Option<SocketAddr>, ws_server_addr: Option<SocketAddr>, grpc_server_addr: Option<SocketAddr>, graphql_server_addr: Option<SocketAddr>, api_enabled: bool, admin_port: u16, ) -> Self

Create new admin state

pub async fn record_request( &self, method: &str, path: &str, status_code: u16, response_time_ms: u64, error: Option<String>, )

Record a request

pub async fn get_metrics(&self) -> RequestMetrics

Get current metrics

pub async fn update_system_metrics( &self, memory_mb: u64, cpu_percent: f64, threads: u32, )

Update system metrics

pub async fn get_system_metrics(&self) -> SystemMetrics

Get system metrics

pub async fn get_time_series_data(&self) -> TimeSeriesData

Get time series data

pub async fn get_restart_status(&self) -> RestartStatus

Get restart status

pub async fn initiate_restart(&self, reason: String) -> Result<()>

Initiate server restart

pub async fn complete_restart(&self, success: bool)

Complete restart (success or failure)

pub async fn get_smoke_test_results(&self) -> Vec<SmokeTestResult>

Get smoke test results

pub async fn update_smoke_test_result(&self, result: SmokeTestResult)

Update smoke test result

pub async fn clear_smoke_test_results(&self)

Clear all smoke test results

pub async fn get_config(&self) -> ConfigurationState

Get current configuration

pub async fn update_latency_config( &self, base_ms: u64, jitter_ms: u64, tag_overrides: HashMap<String, u64>, )

Update latency configuration

pub async fn update_fault_config( &self, enabled: bool, failure_rate: f64, status_codes: Vec<u16>, )

Update fault configuration

pub async fn update_proxy_config( &self, enabled: bool, upstream_url: Option<String>, timeout_seconds: u64, )

Update proxy configuration

pub async fn update_validation_config( &self, mode: String, aggregate_errors: bool, validate_responses: bool, overrides: HashMap<String, String>, )

Update validation settings

pub async fn get_logs_filtered(&self, filter: &LogFilter) -> Vec<RequestLog>

Get filtered logs

pub async fn clear_logs(&self)

Clear all logs

Trait Implementations

impl Clone for AdminState

fn clone(&self) -> AdminState

Returns a duplicate of the value.

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

Performs copy-assignment from source.