Struct product_os_command_control::ProductOSController

pub struct ProductOSController { /* private fields */ }

Implementations

impl ProductOSController

pub fn new( configuration: Configuration, certificates: Certificates, key_value_store: Option<Arc<ProductOSKeyValueStore>> ) -> 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<&BTreeMap<String, String>>, payload: Option<T>, headers: Option<&BTreeMap<String, String>>, verify_identifier: String, verify_tag: String ) -> 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<String>, verify_tag: Option<String> ) -> Result<bool, CommandControlAuthenticateError>

where T: AsByteVector,

pub fn search_and_prepare_command( &self, query: BTreeMap<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: BTreeMap<String, String>, path: String, 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: String, path: String, 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: String, path: String, 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: 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_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: String)

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: String)

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

pub async fn start_services(&mut self)