Struct product_os_command_control::ProductOSController

pub struct ProductOSController { /* private fields */ }

Implementations

impl ProductOSController

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

pub fn get_registry(&self) -> &Registry

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: Vec<u8>) -> bool

pub fn validate_verify_tag<T>( &self, query: Option<&HashMap<String, String>>, payload: Option<T>, headers: Option<&HashMap<String, String>>, verify_identifier: String, verify_tag: String ) -> boolwhere T: AsByteVector,

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

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

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

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

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

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

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

pub fn find_feature_and_ask_sync( &mut self, feature: String, path: String, data: Option<Value>, headers: HashMap<String, String>, params: HashMap<String, String>, method: Method ) -> Result<ProductOSResponse, ProductOSRequestSyncError>

pub fn get_configuration(&self) -> Configuration

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

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

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

pub fn get_relational_store(&mut self) -> Arc<ProductOSRelationalStore>

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 remove_feature(&mut self, identifier: String)

pub async fn add_service(&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: String)

pub async fn remove_inactive_services(&mut self, query: HashMap<String, String>)

pub async fn start_services(&mut self)