Struct AdminApiService 

pub struct AdminApiService { /* private fields */ }

AdminApiService — canonical business-logic layer for node administration.

Both the REST/BFF (admin_api.rs) and the gRPC NodeAdminService trait call into the *_direct() methods defined here. REST handlers should be thin wrappers that parse the request and format the JSON response.

Implementations

impl AdminApiService

pub fn new( node_id: impl Into<String>, name: impl Into<String>, location_tag: impl Into<String>, version: impl Into<String>, service_collector: ServiceCollector, ) -> AdminResult<Self>

Create a new control gRPC service instance.

pub fn with_metrics_provider<F, Fut>(self, provider: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = AdminResult<SystemMetrics>> + Send + 'static,

Override the metrics provider used by GetNodeInfo.

pub fn with_shutdown_handler<F, Fut>(self, handler: F) -> Self

where F: Fn(bool, Option<i32>, Option<String>) -> Fut + Send + Sync + 'static, Fut: Future<Output = AdminResult<()>> + Send + 'static,

Attach a shutdown handler invoked when Shutdown is accepted.

pub fn with_override_store(self, store: Arc<ConfigOverrideStore>) -> Self

Attach a SQLite-backed config override store for L2 dynamic overrides.

pub fn with_reload_handler<F, Fut>(self, handler: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = AdminResult<bool>> + Send + 'static,

Attach a reload handler invoked when reload is requested.

pub fn with_running_config(self, config: ActrixConfig) -> Self

Attach the runtime config snapshot (AdminUi head mode).

pub fn with_toml_content(self, content: String) -> Self

Attach the raw TOML content for L1 detection.

pub fn with_config_path(self, path: PathBuf) -> Self

Attach the config file path.

pub fn override_store(&self) -> Option<&Arc<ConfigOverrideStore>>

Get the override store reference.

pub async fn service_statuses(&self) -> Vec<ServiceStatus>

Collect current service statuses for this node.

Returns all service statuses from the service registry.

pub async fn resolve_node_name(&self) -> String

Resolve the effective node name (L2 override → L1 config → running).

pub async fn health_info(&self) -> HealthInfo

Health check info.

pub async fn list_overrides_direct(&self) -> Result<Vec<ConfigOverride>, Status>

List L2 dynamic config overrides.

pub async fn set_override_direct( &self, key: &str, value: &str, by: &str, ) -> Result<(), Status>

Set a dynamic config override.

pub async fn delete_override_direct(&self, key: &str) -> Result<bool, Status>

Delete a dynamic config override.

pub async fn get_platform_detail_direct(&self) -> Result<PlatformDetail, Status>

Get platform detail with resolved config fields.

pub async fn get_service_detail_direct( &self, name: &str, ) -> Result<ServiceDetail, Status>

Get service detail with resolved config fields.

pub fn get_registry_direct(&self) -> &'static [ConfigFieldDef]

Get config registry (all field definitions).

pub async fn get_config_file_direct(&self) -> Result<ConfigFileContent, Status>

Read config file from disk.

pub async fn save_config_file_direct(&self, content: &str) -> Result<(), Status>

Write config file to disk (with TOML validation).

pub async fn reload_direct(&self) -> Result<bool, Status>

Trigger reload (SIGHUP).

pub async fn get_signer_keys_direct(&self) -> Result<KsKeysResult, Status>

Query Signer keys from the SQLite database.

pub async fn cleanup_signer_keys_direct( &self, ) -> Result<KsCleanupResult, Status>

Cleanup expired Signer keys.

pub async fn get_ais_keys_direct(&self) -> Result<Vec<KeyInfo>, Status>

Query AIS keys from the SQLite database.

pub async fn node_info_direct(&self) -> Result<GetNodeInfoResponse, Status>

Get node info including metrics and service statuses.

pub async fn list_realms_direct(&self) -> Result<ListRealmsResponse, Status>

List all realms.

pub async fn create_realm_with_secret_direct( &self, req: CreateRealmRequest, ) -> Result<(CreateRealmResponse, Option<String>), Status>

Create a realm and return the plaintext realm secret once.

pub async fn create_realm_direct( &self, req: CreateRealmRequest, ) -> Result<CreateRealmResponse, Status>

Create a realm (gRPC path, does not expose plaintext secret in response).

pub async fn get_realm_direct( &self, realm_id: u32, ) -> Result<GetRealmResponse, Status>

Get a single realm by ID.

pub async fn update_realm_direct( &self, req: UpdateRealmRequest, ) -> Result<UpdateRealmResponse, Status>

Update an existing realm.

pub async fn delete_realm_direct( &self, realm_id: u32, ) -> Result<DeleteRealmResponse, Status>

Delete a realm by ID.

pub async fn delete_realm_hard_direct( &self, realm_id: u32, ) -> Result<DeleteRealmResponse, Status>

Hard-delete a realm for local Admin UI standalone mode.

pub async fn rotate_realm_secret_direct( &self, realm_id: u32, ) -> Result<RealmSecretRotationResult, Status>

Rotate realm secret and return plaintext once.

pub async fn get_config_direct( &self, config_type: ConfigType, config_key: String, ) -> Result<GetConfigResponse, Status>

Get a config value.

pub async fn update_config_direct( &self, config_type: ConfigType, config_key: String, config_value: String, ) -> Result<UpdateConfigResponse, Status>

Update a config value.

pub async fn shutdown_direct( &self, graceful: bool, timeout_secs: Option<i32>, reason: Option<String>, ) -> Result<ShutdownResponse, Status>

Request node shutdown.

Trait Implementations

impl Clone for AdminApiService

fn clone(&self) -> AdminApiService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl NodeAdminService for AdminApiService

fn update_config<'life0, 'async_trait>( &'life0 self, request: Request<UpdateConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateConfigResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

———— Configuration management ————

fn get_config<'life0, 'async_trait>( &'life0 self, request: Request<GetConfigRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetConfigResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn create_realm<'life0, 'async_trait>( &'life0 self, request: Request<CreateRealmRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateRealmResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

———— Realm management ————

fn get_realm<'life0, 'async_trait>( &'life0 self, request: Request<GetRealmRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRealmResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn update_realm<'life0, 'async_trait>( &'life0 self, request: Request<UpdateRealmRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateRealmResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete_realm<'life0, 'async_trait>( &'life0 self, request: Request<DeleteRealmRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteRealmResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_realms<'life0, 'async_trait>( &'life0 self, request: Request<ListRealmsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListRealmsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_node_info<'life0, 'async_trait>( &'life0 self, request: Request<GetNodeInfoRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNodeInfoResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

———— Node control ————

fn shutdown<'life0, 'async_trait>( &'life0 self, request: Request<ShutdownRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ShutdownResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_config_overrides<'life0, 'async_trait>( &'life0 self, _request: Request<ListConfigOverridesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListConfigOverridesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

———— Config override management (remote admin) ————

fn set_config_override<'life0, 'async_trait>( &'life0 self, request: Request<SetConfigOverrideRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetConfigOverrideResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete_config_override<'life0, 'async_trait>( &'life0 self, request: Request<DeleteConfigOverrideRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteConfigOverrideResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,