pub struct EnhancedIPCManager {
pub compressor: MessageCompressor,
pub connection_pool: ConnectionPool,
pub secure_channel: SecureMessageChannel,
pub performance_dashboard: PerformanceDashboard,
}Expand description
Enhanced IPC manager that combines all advanced features
Fields§
§compressor: MessageCompressor§connection_pool: ConnectionPool§secure_channel: SecureMessageChannel§performance_dashboard: PerformanceDashboardImplementations§
Source§impl EnhancedIPCManager
impl EnhancedIPCManager
Sourcepub async fn send_enhanced_message<T: Serialize>(
&self,
channel: &str,
message: &T,
use_compression: bool,
use_encryption: bool,
) -> Result<(), String>
pub async fn send_enhanced_message<T: Serialize>( &self, channel: &str, message: &T, use_compression: bool, use_encryption: bool, ) -> Result<(), String>
Send a message using enhanced features
Sourceasync fn send_encrypted_message(
&self,
channel: &str,
_encrypted: &EncryptedMessage,
) -> Result<(), String>
async fn send_encrypted_message( &self, channel: &str, _encrypted: &EncryptedMessage, ) -> Result<(), String>
Send encrypted message
Sourceasync fn send_compressed_message(
&self,
channel: &str,
_data: &[u8],
) -> Result<(), String>
async fn send_compressed_message( &self, channel: &str, _data: &[u8], ) -> Result<(), String>
Send compressed message
Sourceasync fn send_raw_message(
&self,
channel: &str,
_data: &[u8],
) -> Result<(), String>
async fn send_raw_message( &self, channel: &str, _data: &[u8], ) -> Result<(), String>
Send raw message
Sourcepub async fn get_statistics(&self) -> EnhancedIPCStats
pub async fn get_statistics(&self) -> EnhancedIPCStats
Get enhanced IPC statistics
Source§impl EnhancedIPCManager
Utility functions for enhanced IPC
impl EnhancedIPCManager
Utility functions for enhanced IPC
Sourcepub fn high_performance_config() -> Self
pub fn high_performance_config() -> Self
Create a high-performance configuration
Sourcepub fn high_security_config() -> Self
pub fn high_security_config() -> Self
Create a security-focused configuration
Source§impl EnhancedIPCManager
Integration with existing Mountain IPC system
impl EnhancedIPCManager
Integration with existing Mountain IPC system
Sourcepub async fn integrate_with_tauri_ipc(
&self,
_ipc_server: &TauriIPCServer,
) -> Result<(), String>
pub async fn integrate_with_tauri_ipc( &self, _ipc_server: &TauriIPCServer, ) -> Result<(), String>
Integrate with Tauri IPCServer
Sourcepub async fn create_enhanced_handler(
&self,
) -> impl Fn(TauriIPCMessage) -> Result<(), String>
pub async fn create_enhanced_handler( &self, ) -> impl Fn(TauriIPCMessage) -> Result<(), String>
Create enhanced message handler
Auto Trait Implementations§
impl Freeze for EnhancedIPCManager
impl !RefUnwindSafe for EnhancedIPCManager
impl Send for EnhancedIPCManager
impl Sync for EnhancedIPCManager
impl Unpin for EnhancedIPCManager
impl !UnwindSafe for EnhancedIPCManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Convert
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can
then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Convert
Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be
further downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].