Struct ProductOSController 

pub struct ProductOSController { /* private fields */ }

Main controller for managing a distributed command and control system.

ProductOSController is the primary interface for coordinating multiple Product OS server instances. It handles node discovery, service management, secure communication, and workload distribution.

Examples

use product_os_command_control::ProductOSController;
use product_os_configuration::Configuration;
use product_os_security::certificates::Certificates;

let config = Configuration::new();
let certs = Certificates::new_self_signed(
    vec![("CN".to_string(), "localhost".to_string())],
    None, None, None, None, None,
);

let controller = ProductOSController::new(config, certs, None);

Implementations

impl ProductOSController

pub fn new( configuration: Configuration, certificates: Certificates, key_value_store: Option<Arc<ProductOSKeyValueStore>>, ) -> Self

Creates a new ProductOSController instance.

Initializes the command and control system with the provided configuration, certificates, and optional data stores.

Arguments

• configuration - System configuration including network and service settings
• certificates - TLS/SSL certificates for secure communication
• key_value_store - Optional key-value store for node registry persistence
• relational_store - Optional relational database store (requires relational_store feature)

Examples

use product_os_command_control::ProductOSController;
use product_os_configuration::Configuration;
use product_os_security::certificates::Certificates;

let config = Configuration::new();
let certs = Certificates::new_self_signed(
    vec![("CN".to_string(), "localhost".to_string())],
    None, None, None, None, None,
);

let controller = ProductOSController::new(config, certs, None);

pub fn get_registry(&self) -> &Registry

Returns a reference to the internal node registry.

The registry contains information about all known nodes in the cluster, including their capabilities, services, and features.

Examples

let registry = controller.get_registry();
let my_node = registry.get_me();
println!("My node ID: {}", my_node.get_identifier());

pub async fn discover_nodes(&mut self)

pub fn get_max_servers(&self) -> u8

pub fn upsert_node_local(&mut self, identifier: String, node: Node)

pub fn get_certificates(&self) -> Vec<&[u8]>

pub fn get_private_key(&self) -> &[u8]

pub fn get_certificates_and_private_key(&self) -> Certificates

pub fn validate_certificate(&self, certificate: &[u8]) -> bool

pub fn validate_verify_tag<T>( &self, query: Option<&BTreeMap<String, String>>, payload: Option<T>, headers: Option<&BTreeMap<String, String>>, verify_identifier: &str, verify_tag: &str, ) -> bool

where T: AsByteVector,

pub fn authenticate_command_control<T>( &self, query: Option<&BTreeMap<String, String>>, payload: Option<T>, headers: Option<&BTreeMap<String, String>>, verify_identifier: Option<&str>, verify_tag: Option<&str>, ) -> Result<bool, CommandControlAuthenticateError>

where T: AsByteVector,

pub fn search_and_prepare_command( &self, query: BTreeMap<&str, &str>, module: String, instruction: String, data: Option<Value>, ) -> Result<Command, ProductOSRequestError>

pub fn find_and_prepare_command( &self, key: &str, manager: &str, instruction: String, data: Option<Value>, ) -> Result<Command, ProductOSRequestError>

pub fn find_any_and_prepare_command( &self, capability: &str, manager: &str, instruction: &str, data: Option<Value>, ) -> Result<Command, ProductOSRequestError>

pub async fn find_kind_and_prepare_command( &self, kind: &str, manager: &str, instruction: &str, data: Option<Value>, ) -> Result<Command, ProductOSRequestError>

pub fn search_and_prepare_ask( &self, query: BTreeMap<&str, &str>, path: &str, data: Option<Value>, headers: BTreeMap<String, String>, params: BTreeMap<String, String>, method: Method, ) -> Result<Ask, ProductOSRequestError>

pub async fn find_feature_and_ask( &self, feature: &str, path: &str, data: &Option<Value>, headers: &BTreeMap<String, String>, params: &BTreeMap<String, String>, method: &Method, ) -> Result<ProductOSResponse<BodyBytes>, ProductOSRequestError>

pub fn find_feature_and_prepare_ask( &self, feature: &str, path: &str, data: Option<Value>, headers: BTreeMap<String, String>, params: BTreeMap<String, String>, method: Method, ) -> Result<Ask, ProductOSRequestError>

pub fn get_configuration(&self) -> Configuration

pub fn get_key(&self, identifier: &str) -> Option<Vec<u8>>

pub fn create_key_session(&mut self) -> (String, [u8; 32])

pub fn generate_key( &mut self, session_identifier: &str, remote_public_key: &[u8], association: String, remote_session_identifier: Option<String>, )

pub fn get_key_value_store(&mut self) -> Arc<ProductOSKeyValueStore>

pub async fn add_feature( &mut self, feature: Arc<dyn Feature>, base_path: String, router: &mut ProductOSRouter, )

pub async fn add_feature_mut( &mut self, feature: Arc<Mutex<dyn Feature>>, base_path: String, router: &mut ProductOSRouter, )

pub async fn remove_feature(&mut self, identifier: &str)

pub async fn add_service(&mut self, service: Arc<dyn Service>)

pub async fn add_service_mut(&mut self, service: Arc<Mutex<dyn Service>>)

pub async fn set_service_active(&mut self, identifier: String, status: bool)

pub async fn remove_service(&mut self, identifier: &str)

pub async fn remove_inactive_services(&mut self, query: BTreeMap<&str, &str>)

pub async fn start_services(&mut self) -> Result<(), ()>

pub async fn start_service(&mut self, identifier: &str) -> Result<(), ()>

pub async fn stop_service(&mut self, identifier: &str) -> Result<(), ()>