pub mod mxaccess
pub use mxaccess::GalaxyTagMetadata
pub use mxaccess::MxDataType
pub use mxaccess::MxReferenceHandle
pub use mxaccess::MxStatus
pub use mxaccess::MxStatusCategory
pub use mxaccess::MxStatusSource
pub use mxaccess::MxValue
pub use mxaccess::MxValueKind
pub use mxaccess::NmxOperationStatusFormat
pub use mxaccess::NmxOperationStatusMessage
pub use mxaccess::Resolver
pub use mxaccess::ResolverError
pub use mxaccess::WriteValue
pub mod mxaccess::asb_session
pub struct mxaccess::asb_session::AsbSession
impl mxaccess::asb_session::AsbSession
pub async fn mxaccess::asb_session::AsbSession::add_monitored_items(&self, subscription_id: i64, items: &[mxaccess_asb::operations::MinimalMonitoredItem], require_id: bool) -> core::result::Result<mxaccess_asb::operations::AddMonitoredItemsResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::connect(endpoint: core::net::socket_addr::SocketAddr, passphrase: &str, crypto_parameters: &mxaccess_asb_nettcp::auth::CryptoParameters, via_uri: impl core::convert::Into<alloc::string::String>, connection_id: [u8; 16]) -> core::result::Result<Self, mxaccess::Error>
pub fn mxaccess::asb_session::AsbSession::connect_response(&self) -> &mxaccess_asb::operations::ConnectResponse
pub async fn mxaccess::asb_session::AsbSession::create_subscription(&self, max_queue_size: i64, sample_interval: u64) -> core::result::Result<mxaccess_asb::operations::CreateSubscriptionResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::delete_monitored_items(&self, subscription_id: i64, items: &[mxaccess_asb::operations::MinimalMonitoredItem]) -> core::result::Result<mxaccess_asb::operations::DeleteMonitoredItemsResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::delete_subscription(&self, subscription_id: i64) -> core::result::Result<mxaccess_asb::operations::DeleteSubscriptionResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::disconnect(&self) -> core::result::Result<(), mxaccess::Error>
pub fn mxaccess::asb_session::AsbSession::from_transport(transport: mxaccess::transport_asb::AsbTransport<tokio::net::tcp::stream::TcpStream>, connect_response: mxaccess_asb::operations::ConnectResponse) -> Self
pub async fn mxaccess::asb_session::AsbSession::keep_alive(&self) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::publish(&self, subscription_id: i64) -> core::result::Result<mxaccess_asb::operations::PublishResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::publish_write_complete(&self) -> core::result::Result<mxaccess_asb::operations::PublishWriteCompleteResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::read(&self, items: &[mxaccess_asb::contracts::ItemIdentity]) -> core::result::Result<mxaccess_asb::operations::ReadResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::register_items(&self, items: &[mxaccess_asb::contracts::ItemIdentity], require_id: bool, register_only: bool) -> core::result::Result<mxaccess_asb::operations::RegisterItemsResponse, mxaccess::Error>
pub fn mxaccess::asb_session::AsbSession::subscribe(&self, subscription_id: i64) -> mxaccess::asb_session::AsbSubscription
pub async fn mxaccess::asb_session::AsbSession::subscribe_buffered(&self, _reference: &str, _options: mxaccess::BufferedOptions) -> core::result::Result<mxaccess::asb_session::AsbSubscription, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::unregister_items(&self, items: &[mxaccess_asb::contracts::ItemIdentity]) -> core::result::Result<mxaccess_asb::operations::UnregisterItemsResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::write(&self, items: &[mxaccess_asb::contracts::ItemIdentity], values: &[mxaccess_asb::operations::MinimalWriteValue], write_handle: u32) -> core::result::Result<mxaccess_asb::operations::WriteResponse, mxaccess::Error>
impl core::clone::Clone for mxaccess::asb_session::AsbSession
pub fn mxaccess::asb_session::AsbSession::clone(&self) -> mxaccess::asb_session::AsbSession
impl core::fmt::Debug for mxaccess::asb_session::AsbSession
pub fn mxaccess::asb_session::AsbSession::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::asb_session::AsbSession
impl core::marker::Send for mxaccess::asb_session::AsbSession
impl core::marker::Sync for mxaccess::asb_session::AsbSession
impl core::marker::Unpin for mxaccess::asb_session::AsbSession
impl core::marker::UnsafeUnpin for mxaccess::asb_session::AsbSession
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::asb_session::AsbSession
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::asb_session::AsbSession
pub struct mxaccess::asb_session::AsbSubscription
impl core::fmt::Debug for mxaccess::asb_session::AsbSubscription
pub fn mxaccess::asb_session::AsbSubscription::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::ops::drop::Drop for mxaccess::asb_session::AsbSubscription
pub fn mxaccess::asb_session::AsbSubscription::drop(&mut self)
impl futures_core::stream::Stream for mxaccess::asb_session::AsbSubscription
pub type mxaccess::asb_session::AsbSubscription::Item = core::result::Result<mxaccess_asb::contracts::MonitoredItemValue, mxaccess::Error>
pub fn mxaccess::asb_session::AsbSubscription::poll_next(self: core::pin::Pin<&mut Self>, cx: &mut core::task::wake::Context<'_>) -> core::task::poll::Poll<core::option::Option<Self::Item>>
impl core::marker::Freeze for mxaccess::asb_session::AsbSubscription
impl core::marker::Send for mxaccess::asb_session::AsbSubscription
impl core::marker::Sync for mxaccess::asb_session::AsbSubscription
impl core::marker::Unpin for mxaccess::asb_session::AsbSubscription
impl core::marker::UnsafeUnpin for mxaccess::asb_session::AsbSubscription
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::asb_session::AsbSubscription
impl core::panic::unwind_safe::UnwindSafe for mxaccess::asb_session::AsbSubscription
pub mod mxaccess::session
#[non_exhaustive] pub enum mxaccess::session::OperationKind
pub mxaccess::session::OperationKind::Activate
pub mxaccess::session::OperationKind::Other
pub mxaccess::session::OperationKind::Read
pub mxaccess::session::OperationKind::Subscribe
pub mxaccess::session::OperationKind::Suspend
pub mxaccess::session::OperationKind::Unsubscribe
pub mxaccess::session::OperationKind::Write
pub mxaccess::session::OperationKind::WriteSecured
impl core::clone::Clone for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::clone(&self) -> mxaccess::session::OperationKind
impl core::cmp::Eq for mxaccess::session::OperationKind
impl core::cmp::PartialEq for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::eq(&self, other: &mxaccess::session::OperationKind) -> bool
impl core::fmt::Debug for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::Copy for mxaccess::session::OperationKind
impl core::marker::StructuralPartialEq for mxaccess::session::OperationKind
impl core::marker::Freeze for mxaccess::session::OperationKind
impl core::marker::Send for mxaccess::session::OperationKind
impl core::marker::Sync for mxaccess::session::OperationKind
impl core::marker::Unpin for mxaccess::session::OperationKind
impl core::marker::UnsafeUnpin for mxaccess::session::OperationKind
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::OperationKind
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::OperationKind
#[non_exhaustive] pub struct mxaccess::session::OperationContext
pub mxaccess::session::OperationContext::correlation_id: [u8; 16]
pub mxaccess::session::OperationContext::op_kind: mxaccess::session::OperationKind
pub mxaccess::session::OperationContext::reference: core::option::Option<alloc::sync::Arc<str>>
pub mxaccess::session::OperationContext::retry_count: u32
impl mxaccess::session::OperationContext
pub fn mxaccess::session::OperationContext::new(correlation_id: [u8; 16], op_kind: mxaccess::session::OperationKind, reference: core::option::Option<alloc::sync::Arc<str>>, retry_count: u32) -> Self
impl core::clone::Clone for mxaccess::session::OperationContext
pub fn mxaccess::session::OperationContext::clone(&self) -> mxaccess::session::OperationContext
impl core::fmt::Debug for mxaccess::session::OperationContext
pub fn mxaccess::session::OperationContext::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::session::OperationContext
impl core::marker::Send for mxaccess::session::OperationContext
impl core::marker::Sync for mxaccess::session::OperationContext
impl core::marker::Unpin for mxaccess::session::OperationContext
impl core::marker::UnsafeUnpin for mxaccess::session::OperationContext
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::OperationContext
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::OperationContext
#[non_exhaustive] pub struct mxaccess::session::OperationStatus
pub mxaccess::session::OperationStatus::context: core::option::Option<mxaccess::session::OperationContext>
pub mxaccess::session::OperationStatus::is_during_recovery: bool
pub mxaccess::session::OperationStatus::raw: mxaccess_codec::operation_status::NmxOperationStatusMessage
pub mxaccess::session::OperationStatus::status: mxaccess_codec::status::MxStatus
impl mxaccess::session::OperationStatus
pub fn mxaccess::session::OperationStatus::new(raw: mxaccess_codec::operation_status::NmxOperationStatusMessage, status: mxaccess_codec::status::MxStatus, context: core::option::Option<mxaccess::session::OperationContext>, is_during_recovery: bool) -> Self
impl core::clone::Clone for mxaccess::session::OperationStatus
pub fn mxaccess::session::OperationStatus::clone(&self) -> mxaccess::session::OperationStatus
impl core::fmt::Debug for mxaccess::session::OperationStatus
pub fn mxaccess::session::OperationStatus::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::session::OperationStatus
impl core::marker::Send for mxaccess::session::OperationStatus
impl core::marker::Sync for mxaccess::session::OperationStatus
impl core::marker::Unpin for mxaccess::session::OperationStatus
impl core::marker::UnsafeUnpin for mxaccess::session::OperationStatus
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::OperationStatus
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::OperationStatus
pub struct mxaccess::session::SessionInner
impl core::fmt::Debug for mxaccess::session::SessionInner
pub fn mxaccess::session::SessionInner::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl !core::marker::Freeze for mxaccess::session::SessionInner
impl core::marker::Send for mxaccess::session::SessionInner
impl core::marker::Sync for mxaccess::session::SessionInner
impl core::marker::Unpin for mxaccess::session::SessionInner
impl core::marker::UnsafeUnpin for mxaccess::session::SessionInner
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::SessionInner
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::session::SessionInner
pub struct mxaccess::session::Subscription
impl mxaccess::session::Subscription
pub fn mxaccess::session::Subscription::correlation_id(&self) -> [u8; 16]
pub fn mxaccess::session::Subscription::metadata(&self) -> &mxaccess_galaxy::metadata::GalaxyTagMetadata
pub fn mxaccess::session::Subscription::reference(&self) -> &str
impl core::fmt::Debug for mxaccess::session::Subscription
pub fn mxaccess::session::Subscription::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl futures_core::stream::Stream for mxaccess::session::Subscription
pub type mxaccess::session::Subscription::Item = core::result::Result<mxaccess::DataChange, mxaccess::Error>
pub fn mxaccess::session::Subscription::poll_next(self: core::pin::Pin<&mut Self>, cx: &mut core::task::wake::Context<'_>) -> core::task::poll::Poll<core::option::Option<Self::Item>>
impl core::marker::Freeze for mxaccess::session::Subscription
impl core::marker::Send for mxaccess::session::Subscription
impl core::marker::Sync for mxaccess::session::Subscription
impl core::marker::Unpin for mxaccess::session::Subscription
impl core::marker::UnsafeUnpin for mxaccess::session::Subscription
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::Subscription
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::session::Subscription
#[non_exhaustive] pub struct mxaccess::session::WriteHandle
pub mxaccess::session::WriteHandle::correlation_id: [u8; 16]
impl core::clone::Clone for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::clone(&self) -> mxaccess::session::WriteHandle
impl core::cmp::Eq for mxaccess::session::WriteHandle
impl core::cmp::PartialEq for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::eq(&self, other: &mxaccess::session::WriteHandle) -> bool
impl core::fmt::Debug for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::Copy for mxaccess::session::WriteHandle
impl core::marker::StructuralPartialEq for mxaccess::session::WriteHandle
impl core::marker::Freeze for mxaccess::session::WriteHandle
impl core::marker::Send for mxaccess::session::WriteHandle
impl core::marker::Sync for mxaccess::session::WriteHandle
impl core::marker::Unpin for mxaccess::session::WriteHandle
impl core::marker::UnsafeUnpin for mxaccess::session::WriteHandle
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::WriteHandle
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::WriteHandle
pub fn mxaccess::session::filetime_to_system_time(filetime_ticks: i64) -> std::time::SystemTime
pub fn mxaccess::session::system_time_to_filetime(time: std::time::SystemTime) -> core::result::Result<i64, mxaccess::Error>
pub type mxaccess::session::RebuildFactory = alloc::sync::Arc<(dyn core::ops::function::Fn() -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = core::result::Result<mxaccess_nmx::client::NmxClient, mxaccess_nmx::client::NmxClientError>> + core::marker::Send)>> + core::marker::Send + core::marker::Sync)>
pub mod mxaccess::transport_asb
pub struct mxaccess::transport_asb::AsbTransport<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + 'static>
impl mxaccess::transport_asb::AsbTransport<tokio::net::tcp::stream::TcpStream>
pub async fn mxaccess::transport_asb::AsbTransport<tokio::net::tcp::stream::TcpStream>::connect(endpoint: core::net::socket_addr::SocketAddr, passphrase: &str, crypto_parameters: &mxaccess_asb_nettcp::auth::CryptoParameters, via_uri: impl core::convert::Into<alloc::string::String>, connection_id: [u8; 16]) -> core::result::Result<(Self, mxaccess_asb::operations::ConnectResponse), mxaccess::Error>
impl<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + 'static> mxaccess::transport_asb::AsbTransport<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::client_mut(&mut self) -> &mut mxaccess_asb::client::AsbClient<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::into_client(self) -> mxaccess_asb::client::AsbClient<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::new(client: mxaccess_asb::client::AsbClient<T>) -> Self
impl<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + core::marker::Sync + 'static> mxaccess::Transport for mxaccess::transport_asb::AsbTransport<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::capabilities(&self) -> mxaccess::TransportCapabilities
pub fn mxaccess::transport_asb::AsbTransport<T>::kind(&self) -> mxaccess::TransportKind
impl<T> core::marker::Freeze for mxaccess::transport_asb::AsbTransport<T> where T: core::marker::Freeze
impl<T> core::marker::Send for mxaccess::transport_asb::AsbTransport<T>
impl<T> core::marker::Sync for mxaccess::transport_asb::AsbTransport<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for mxaccess::transport_asb::AsbTransport<T>
impl<T> core::marker::UnsafeUnpin for mxaccess::transport_asb::AsbTransport<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for mxaccess::transport_asb::AsbTransport<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for mxaccess::transport_asb::AsbTransport<T> where T: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub enum mxaccess::AuthError
pub mxaccess::AuthError::Ntlm
pub mxaccess::AuthError::Ntlm::reason: alloc::string::String
impl core::convert::From<mxaccess::AuthError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::AuthError) -> Self
impl core::error::Error for mxaccess::AuthError
impl core::fmt::Debug for mxaccess::AuthError
pub fn mxaccess::AuthError::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for mxaccess::AuthError
pub fn mxaccess::AuthError::fmt(&self, __formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::AuthError
impl core::marker::Send for mxaccess::AuthError
impl core::marker::Sync for mxaccess::AuthError
impl core::marker::Unpin for mxaccess::AuthError
impl core::marker::UnsafeUnpin for mxaccess::AuthError
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::AuthError
impl core::panic::unwind_safe::UnwindSafe for mxaccess::AuthError
#[non_exhaustive] pub enum mxaccess::ConfigError
pub mxaccess::ConfigError::Galaxy
pub mxaccess::ConfigError::Galaxy::reason: alloc::string::String
pub mxaccess::ConfigError::InvalidArgument
pub mxaccess::ConfigError::InvalidArgument::detail: alloc::string::String
pub mxaccess::ConfigError::RecoveryNotConfigured
impl core::convert::From<mxaccess::ConfigError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::ConfigError) -> Self
impl core::error::Error for mxaccess::ConfigError
impl core::fmt::Debug for mxaccess::ConfigError
pub fn mxaccess::ConfigError::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for mxaccess::ConfigError
pub fn mxaccess::ConfigError::fmt(&self, __formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::ConfigError
impl core::marker::Send for mxaccess::ConfigError
impl core::marker::Sync for mxaccess::ConfigError
impl core::marker::Unpin for mxaccess::ConfigError
impl core::marker::UnsafeUnpin for mxaccess::ConfigError
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::ConfigError
impl core::panic::unwind_safe::UnwindSafe for mxaccess::ConfigError
#[non_exhaustive] pub enum mxaccess::ConnectionError
pub mxaccess::ConnectionError::CallbackProxyMissing
pub mxaccess::ConnectionError::EngineNotRegistered
pub mxaccess::ConnectionError::ServerUnavailable
pub mxaccess::ConnectionError::TransportFailure
pub mxaccess::ConnectionError::TransportFailure::detail: alloc::string::String
impl core::convert::From<mxaccess::ConnectionError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::ConnectionError) -> Self
impl core::error::Error for mxaccess::ConnectionError
impl core::fmt::Debug for mxaccess::ConnectionError
pub fn mxaccess::ConnectionError::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for mxaccess::ConnectionError
pub fn mxaccess::ConnectionError::fmt(&self, __formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::ConnectionError
impl core::marker::Send for mxaccess::ConnectionError
impl core::marker::Sync for mxaccess::ConnectionError
impl core::marker::Unpin for mxaccess::ConnectionError
impl core::marker::UnsafeUnpin for mxaccess::ConnectionError
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::ConnectionError
impl core::panic::unwind_safe::UnwindSafe for mxaccess::ConnectionError
#[non_exhaustive] pub enum mxaccess::Error
pub mxaccess::Error::Auth(mxaccess::AuthError)
pub mxaccess::Error::Cancelled
pub mxaccess::Error::Configuration(mxaccess::ConfigError)
pub mxaccess::Error::Connection(mxaccess::ConnectionError)
pub mxaccess::Error::Io(std::io::error::Error)
pub mxaccess::Error::Protocol(mxaccess::ProtocolError)
pub mxaccess::Error::Security(mxaccess::SecurityError)
pub mxaccess::Error::Status
pub mxaccess::Error::Status::category: mxaccess_codec::status::MxStatusCategory
pub mxaccess::Error::Status::detail: i16
pub mxaccess::Error::Status::detected_by: mxaccess_codec::status::MxStatusSource
pub mxaccess::Error::Status::success: i16
pub mxaccess::Error::Timeout(core::time::Duration)
pub mxaccess::Error::TypeMismatch
pub mxaccess::Error::TypeMismatch::actual: mxaccess_codec::value::MxValueKind
pub mxaccess::Error::TypeMismatch::expected: mxaccess_codec::value::MxValueKind
pub mxaccess::Error::TypeMismatch::reference: alloc::sync::Arc<str>
pub mxaccess::Error::Unsupported
pub mxaccess::Error::Unsupported::operation: alloc::borrow::Cow<'static, str>
pub mxaccess::Error::Unsupported::transport: mxaccess::TransportKind
impl core::convert::From<mxaccess::AuthError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::AuthError) -> Self
impl core::convert::From<mxaccess::ConfigError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::ConfigError) -> Self
impl core::convert::From<mxaccess::ConnectionError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::ConnectionError) -> Self
impl core::convert::From<mxaccess::ProtocolError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::ProtocolError) -> Self
impl core::convert::From<mxaccess::SecurityError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::SecurityError) -> Self
impl core::convert::From<std::io::error::Error> for mxaccess::Error
pub fn mxaccess::Error::from(source: std::io::error::Error) -> Self
impl core::error::Error for mxaccess::Error
pub fn mxaccess::Error::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for mxaccess::Error
pub fn mxaccess::Error::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for mxaccess::Error
pub fn mxaccess::Error::fmt(&self, __formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::Error
impl core::marker::Send for mxaccess::Error
impl core::marker::Sync for mxaccess::Error
impl core::marker::Unpin for mxaccess::Error
impl core::marker::UnsafeUnpin for mxaccess::Error
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::Error
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::Error
#[non_exhaustive] pub enum mxaccess::OperationKind
pub mxaccess::OperationKind::Activate
pub mxaccess::OperationKind::Other
pub mxaccess::OperationKind::Read
pub mxaccess::OperationKind::Subscribe
pub mxaccess::OperationKind::Suspend
pub mxaccess::OperationKind::Unsubscribe
pub mxaccess::OperationKind::Write
pub mxaccess::OperationKind::WriteSecured
impl core::clone::Clone for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::clone(&self) -> mxaccess::session::OperationKind
impl core::cmp::Eq for mxaccess::session::OperationKind
impl core::cmp::PartialEq for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::eq(&self, other: &mxaccess::session::OperationKind) -> bool
impl core::fmt::Debug for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::session::OperationKind
pub fn mxaccess::session::OperationKind::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::Copy for mxaccess::session::OperationKind
impl core::marker::StructuralPartialEq for mxaccess::session::OperationKind
impl core::marker::Freeze for mxaccess::session::OperationKind
impl core::marker::Send for mxaccess::session::OperationKind
impl core::marker::Sync for mxaccess::session::OperationKind
impl core::marker::Unpin for mxaccess::session::OperationKind
impl core::marker::UnsafeUnpin for mxaccess::session::OperationKind
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::OperationKind
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::OperationKind
#[non_exhaustive] pub enum mxaccess::ProtocolError
pub mxaccess::ProtocolError::Decode
pub mxaccess::ProtocolError::Decode::buffer_len: usize
pub mxaccess::ProtocolError::Decode::offset: usize
pub mxaccess::ProtocolError::Decode::reason: &'static str
pub mxaccess::ProtocolError::InnerLengthMismatch
pub mxaccess::ProtocolError::InnerLengthMismatch::actual: usize
pub mxaccess::ProtocolError::InnerLengthMismatch::declared: i32
pub mxaccess::ProtocolError::UnexpectedOpcode(u8)
impl core::convert::From<mxaccess::ProtocolError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::ProtocolError) -> Self
impl core::error::Error for mxaccess::ProtocolError
impl core::fmt::Debug for mxaccess::ProtocolError
pub fn mxaccess::ProtocolError::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for mxaccess::ProtocolError
pub fn mxaccess::ProtocolError::fmt(&self, __formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::ProtocolError
impl core::marker::Send for mxaccess::ProtocolError
impl core::marker::Sync for mxaccess::ProtocolError
impl core::marker::Unpin for mxaccess::ProtocolError
impl core::marker::UnsafeUnpin for mxaccess::ProtocolError
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::ProtocolError
impl core::panic::unwind_safe::UnwindSafe for mxaccess::ProtocolError
#[non_exhaustive] pub enum mxaccess::RecoveryEvent
pub mxaccess::RecoveryEvent::Failed
pub mxaccess::RecoveryEvent::Failed::attempt: u32
pub mxaccess::RecoveryEvent::Failed::error: mxaccess::Error
pub mxaccess::RecoveryEvent::Failed::will_retry: bool
pub mxaccess::RecoveryEvent::Recovered
pub mxaccess::RecoveryEvent::Recovered::attempt: u32
pub mxaccess::RecoveryEvent::Started
pub mxaccess::RecoveryEvent::Started::attempt: u32
impl core::fmt::Debug for mxaccess::RecoveryEvent
pub fn mxaccess::RecoveryEvent::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::RecoveryEvent
impl core::marker::Send for mxaccess::RecoveryEvent
impl core::marker::Sync for mxaccess::RecoveryEvent
impl core::marker::Unpin for mxaccess::RecoveryEvent
impl core::marker::UnsafeUnpin for mxaccess::RecoveryEvent
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::RecoveryEvent
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::RecoveryEvent
#[non_exhaustive] pub enum mxaccess::SecurityError
pub mxaccess::SecurityError::CallbackObjRefRejected
pub mxaccess::SecurityError::VerifierRequired
impl core::convert::From<mxaccess::SecurityError> for mxaccess::Error
pub fn mxaccess::Error::from(source: mxaccess::SecurityError) -> Self
impl core::error::Error for mxaccess::SecurityError
impl core::fmt::Debug for mxaccess::SecurityError
pub fn mxaccess::SecurityError::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for mxaccess::SecurityError
pub fn mxaccess::SecurityError::fmt(&self, __formatter: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::SecurityError
impl core::marker::Send for mxaccess::SecurityError
impl core::marker::Sync for mxaccess::SecurityError
impl core::marker::Unpin for mxaccess::SecurityError
impl core::marker::UnsafeUnpin for mxaccess::SecurityError
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::SecurityError
impl core::panic::unwind_safe::UnwindSafe for mxaccess::SecurityError
#[non_exhaustive] pub enum mxaccess::TransportKind
pub mxaccess::TransportKind::Asb
pub mxaccess::TransportKind::Nmx
impl core::clone::Clone for mxaccess::TransportKind
pub fn mxaccess::TransportKind::clone(&self) -> mxaccess::TransportKind
impl core::cmp::Eq for mxaccess::TransportKind
impl core::cmp::PartialEq for mxaccess::TransportKind
pub fn mxaccess::TransportKind::eq(&self, other: &mxaccess::TransportKind) -> bool
impl core::fmt::Debug for mxaccess::TransportKind
pub fn mxaccess::TransportKind::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::TransportKind
pub fn mxaccess::TransportKind::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::Copy for mxaccess::TransportKind
impl core::marker::StructuralPartialEq for mxaccess::TransportKind
impl core::marker::Freeze for mxaccess::TransportKind
impl core::marker::Send for mxaccess::TransportKind
impl core::marker::Sync for mxaccess::TransportKind
impl core::marker::Unpin for mxaccess::TransportKind
impl core::marker::UnsafeUnpin for mxaccess::TransportKind
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::TransportKind
impl core::panic::unwind_safe::UnwindSafe for mxaccess::TransportKind
pub struct mxaccess::AsbSession
impl mxaccess::asb_session::AsbSession
pub async fn mxaccess::asb_session::AsbSession::add_monitored_items(&self, subscription_id: i64, items: &[mxaccess_asb::operations::MinimalMonitoredItem], require_id: bool) -> core::result::Result<mxaccess_asb::operations::AddMonitoredItemsResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::connect(endpoint: core::net::socket_addr::SocketAddr, passphrase: &str, crypto_parameters: &mxaccess_asb_nettcp::auth::CryptoParameters, via_uri: impl core::convert::Into<alloc::string::String>, connection_id: [u8; 16]) -> core::result::Result<Self, mxaccess::Error>
pub fn mxaccess::asb_session::AsbSession::connect_response(&self) -> &mxaccess_asb::operations::ConnectResponse
pub async fn mxaccess::asb_session::AsbSession::create_subscription(&self, max_queue_size: i64, sample_interval: u64) -> core::result::Result<mxaccess_asb::operations::CreateSubscriptionResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::delete_monitored_items(&self, subscription_id: i64, items: &[mxaccess_asb::operations::MinimalMonitoredItem]) -> core::result::Result<mxaccess_asb::operations::DeleteMonitoredItemsResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::delete_subscription(&self, subscription_id: i64) -> core::result::Result<mxaccess_asb::operations::DeleteSubscriptionResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::disconnect(&self) -> core::result::Result<(), mxaccess::Error>
pub fn mxaccess::asb_session::AsbSession::from_transport(transport: mxaccess::transport_asb::AsbTransport<tokio::net::tcp::stream::TcpStream>, connect_response: mxaccess_asb::operations::ConnectResponse) -> Self
pub async fn mxaccess::asb_session::AsbSession::keep_alive(&self) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::publish(&self, subscription_id: i64) -> core::result::Result<mxaccess_asb::operations::PublishResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::publish_write_complete(&self) -> core::result::Result<mxaccess_asb::operations::PublishWriteCompleteResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::read(&self, items: &[mxaccess_asb::contracts::ItemIdentity]) -> core::result::Result<mxaccess_asb::operations::ReadResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::register_items(&self, items: &[mxaccess_asb::contracts::ItemIdentity], require_id: bool, register_only: bool) -> core::result::Result<mxaccess_asb::operations::RegisterItemsResponse, mxaccess::Error>
pub fn mxaccess::asb_session::AsbSession::subscribe(&self, subscription_id: i64) -> mxaccess::asb_session::AsbSubscription
pub async fn mxaccess::asb_session::AsbSession::subscribe_buffered(&self, _reference: &str, _options: mxaccess::BufferedOptions) -> core::result::Result<mxaccess::asb_session::AsbSubscription, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::unregister_items(&self, items: &[mxaccess_asb::contracts::ItemIdentity]) -> core::result::Result<mxaccess_asb::operations::UnregisterItemsResponse, mxaccess::Error>
pub async fn mxaccess::asb_session::AsbSession::write(&self, items: &[mxaccess_asb::contracts::ItemIdentity], values: &[mxaccess_asb::operations::MinimalWriteValue], write_handle: u32) -> core::result::Result<mxaccess_asb::operations::WriteResponse, mxaccess::Error>
impl core::clone::Clone for mxaccess::asb_session::AsbSession
pub fn mxaccess::asb_session::AsbSession::clone(&self) -> mxaccess::asb_session::AsbSession
impl core::fmt::Debug for mxaccess::asb_session::AsbSession
pub fn mxaccess::asb_session::AsbSession::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::asb_session::AsbSession
impl core::marker::Send for mxaccess::asb_session::AsbSession
impl core::marker::Sync for mxaccess::asb_session::AsbSession
impl core::marker::Unpin for mxaccess::asb_session::AsbSession
impl core::marker::UnsafeUnpin for mxaccess::asb_session::AsbSession
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::asb_session::AsbSession
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::asb_session::AsbSession
pub struct mxaccess::AsbTransport<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + 'static>
impl mxaccess::transport_asb::AsbTransport<tokio::net::tcp::stream::TcpStream>
pub async fn mxaccess::transport_asb::AsbTransport<tokio::net::tcp::stream::TcpStream>::connect(endpoint: core::net::socket_addr::SocketAddr, passphrase: &str, crypto_parameters: &mxaccess_asb_nettcp::auth::CryptoParameters, via_uri: impl core::convert::Into<alloc::string::String>, connection_id: [u8; 16]) -> core::result::Result<(Self, mxaccess_asb::operations::ConnectResponse), mxaccess::Error>
impl<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + 'static> mxaccess::transport_asb::AsbTransport<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::client_mut(&mut self) -> &mut mxaccess_asb::client::AsbClient<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::into_client(self) -> mxaccess_asb::client::AsbClient<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::new(client: mxaccess_asb::client::AsbClient<T>) -> Self
impl<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + core::marker::Sync + 'static> mxaccess::Transport for mxaccess::transport_asb::AsbTransport<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::capabilities(&self) -> mxaccess::TransportCapabilities
pub fn mxaccess::transport_asb::AsbTransport<T>::kind(&self) -> mxaccess::TransportKind
impl<T> core::marker::Freeze for mxaccess::transport_asb::AsbTransport<T> where T: core::marker::Freeze
impl<T> core::marker::Send for mxaccess::transport_asb::AsbTransport<T>
impl<T> core::marker::Sync for mxaccess::transport_asb::AsbTransport<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for mxaccess::transport_asb::AsbTransport<T>
impl<T> core::marker::UnsafeUnpin for mxaccess::transport_asb::AsbTransport<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for mxaccess::transport_asb::AsbTransport<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for mxaccess::transport_asb::AsbTransport<T> where T: core::panic::unwind_safe::UnwindSafe
pub struct mxaccess::BufferedOptions
pub mxaccess::BufferedOptions::update_interval_ms: u32
impl mxaccess::BufferedOptions
pub const fn mxaccess::BufferedOptions::rounded_update_interval_ms(self) -> u32
impl core::clone::Clone for mxaccess::BufferedOptions
pub fn mxaccess::BufferedOptions::clone(&self) -> mxaccess::BufferedOptions
impl core::fmt::Debug for mxaccess::BufferedOptions
pub fn mxaccess::BufferedOptions::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for mxaccess::BufferedOptions
impl core::marker::Freeze for mxaccess::BufferedOptions
impl core::marker::Send for mxaccess::BufferedOptions
impl core::marker::Sync for mxaccess::BufferedOptions
impl core::marker::Unpin for mxaccess::BufferedOptions
impl core::marker::UnsafeUnpin for mxaccess::BufferedOptions
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::BufferedOptions
impl core::panic::unwind_safe::UnwindSafe for mxaccess::BufferedOptions
pub struct mxaccess::BufferedSubscription
impl core::clone::Clone for mxaccess::BufferedSubscription
pub fn mxaccess::BufferedSubscription::clone(&self) -> mxaccess::BufferedSubscription
impl core::fmt::Debug for mxaccess::BufferedSubscription
pub fn mxaccess::BufferedSubscription::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::BufferedSubscription
impl core::marker::Send for mxaccess::BufferedSubscription
impl core::marker::Sync for mxaccess::BufferedSubscription
impl core::marker::Unpin for mxaccess::BufferedSubscription
impl core::marker::UnsafeUnpin for mxaccess::BufferedSubscription
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::BufferedSubscription
impl core::panic::unwind_safe::UnwindSafe for mxaccess::BufferedSubscription
pub struct mxaccess::ConnectionOptions
impl core::clone::Clone for mxaccess::ConnectionOptions
pub fn mxaccess::ConnectionOptions::clone(&self) -> mxaccess::ConnectionOptions
impl core::fmt::Debug for mxaccess::ConnectionOptions
pub fn mxaccess::ConnectionOptions::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::ConnectionOptions
impl core::marker::Send for mxaccess::ConnectionOptions
impl core::marker::Sync for mxaccess::ConnectionOptions
impl core::marker::Unpin for mxaccess::ConnectionOptions
impl core::marker::UnsafeUnpin for mxaccess::ConnectionOptions
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::ConnectionOptions
impl core::panic::unwind_safe::UnwindSafe for mxaccess::ConnectionOptions
pub struct mxaccess::DataChange
pub mxaccess::DataChange::quality: u16
pub mxaccess::DataChange::reference: alloc::sync::Arc<str>
pub mxaccess::DataChange::status: mxaccess_codec::status::MxStatus
pub mxaccess::DataChange::timestamp: std::time::SystemTime
pub mxaccess::DataChange::value: mxaccess_codec::value::MxValue
impl core::clone::Clone for mxaccess::DataChange
pub fn mxaccess::DataChange::clone(&self) -> mxaccess::DataChange
impl core::fmt::Debug for mxaccess::DataChange
pub fn mxaccess::DataChange::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::DataChange
impl core::marker::Send for mxaccess::DataChange
impl core::marker::Sync for mxaccess::DataChange
impl core::marker::Unpin for mxaccess::DataChange
impl core::marker::UnsafeUnpin for mxaccess::DataChange
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::DataChange
impl core::panic::unwind_safe::UnwindSafe for mxaccess::DataChange
#[non_exhaustive] pub struct mxaccess::OperationContext
pub mxaccess::OperationContext::correlation_id: [u8; 16]
pub mxaccess::OperationContext::op_kind: mxaccess::session::OperationKind
pub mxaccess::OperationContext::reference: core::option::Option<alloc::sync::Arc<str>>
pub mxaccess::OperationContext::retry_count: u32
impl mxaccess::session::OperationContext
pub fn mxaccess::session::OperationContext::new(correlation_id: [u8; 16], op_kind: mxaccess::session::OperationKind, reference: core::option::Option<alloc::sync::Arc<str>>, retry_count: u32) -> Self
impl core::clone::Clone for mxaccess::session::OperationContext
pub fn mxaccess::session::OperationContext::clone(&self) -> mxaccess::session::OperationContext
impl core::fmt::Debug for mxaccess::session::OperationContext
pub fn mxaccess::session::OperationContext::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::session::OperationContext
impl core::marker::Send for mxaccess::session::OperationContext
impl core::marker::Sync for mxaccess::session::OperationContext
impl core::marker::Unpin for mxaccess::session::OperationContext
impl core::marker::UnsafeUnpin for mxaccess::session::OperationContext
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::OperationContext
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::OperationContext
#[non_exhaustive] pub struct mxaccess::OperationStatus
pub mxaccess::OperationStatus::context: core::option::Option<mxaccess::session::OperationContext>
pub mxaccess::OperationStatus::is_during_recovery: bool
pub mxaccess::OperationStatus::raw: mxaccess_codec::operation_status::NmxOperationStatusMessage
pub mxaccess::OperationStatus::status: mxaccess_codec::status::MxStatus
impl mxaccess::session::OperationStatus
pub fn mxaccess::session::OperationStatus::new(raw: mxaccess_codec::operation_status::NmxOperationStatusMessage, status: mxaccess_codec::status::MxStatus, context: core::option::Option<mxaccess::session::OperationContext>, is_during_recovery: bool) -> Self
impl core::clone::Clone for mxaccess::session::OperationStatus
pub fn mxaccess::session::OperationStatus::clone(&self) -> mxaccess::session::OperationStatus
impl core::fmt::Debug for mxaccess::session::OperationStatus
pub fn mxaccess::session::OperationStatus::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::session::OperationStatus
impl core::marker::Send for mxaccess::session::OperationStatus
impl core::marker::Sync for mxaccess::session::OperationStatus
impl core::marker::Unpin for mxaccess::session::OperationStatus
impl core::marker::UnsafeUnpin for mxaccess::session::OperationStatus
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::OperationStatus
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::OperationStatus
pub struct mxaccess::RecoveryPolicy
pub mxaccess::RecoveryPolicy::delay: core::time::Duration
pub mxaccess::RecoveryPolicy::max_attempts: u32
impl mxaccess::RecoveryPolicy
pub const mxaccess::RecoveryPolicy::SINGLE_ATTEMPT: mxaccess::RecoveryPolicy
pub fn mxaccess::RecoveryPolicy::validate(&self) -> core::result::Result<(), mxaccess::ConfigError>
impl core::clone::Clone for mxaccess::RecoveryPolicy
pub fn mxaccess::RecoveryPolicy::clone(&self) -> mxaccess::RecoveryPolicy
impl core::cmp::Eq for mxaccess::RecoveryPolicy
impl core::cmp::PartialEq for mxaccess::RecoveryPolicy
pub fn mxaccess::RecoveryPolicy::eq(&self, other: &mxaccess::RecoveryPolicy) -> bool
impl core::default::Default for mxaccess::RecoveryPolicy
pub fn mxaccess::RecoveryPolicy::default() -> Self
impl core::fmt::Debug for mxaccess::RecoveryPolicy
pub fn mxaccess::RecoveryPolicy::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::RecoveryPolicy
pub fn mxaccess::RecoveryPolicy::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::Copy for mxaccess::RecoveryPolicy
impl core::marker::StructuralPartialEq for mxaccess::RecoveryPolicy
impl core::marker::Freeze for mxaccess::RecoveryPolicy
impl core::marker::Send for mxaccess::RecoveryPolicy
impl core::marker::Sync for mxaccess::RecoveryPolicy
impl core::marker::Unpin for mxaccess::RecoveryPolicy
impl core::marker::UnsafeUnpin for mxaccess::RecoveryPolicy
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::RecoveryPolicy
impl core::panic::unwind_safe::UnwindSafe for mxaccess::RecoveryPolicy
pub struct mxaccess::SecurityContext
pub mxaccess::SecurityContext::current_user_id: i32
pub mxaccess::SecurityContext::verifier_user_id: i32
impl core::clone::Clone for mxaccess::SecurityContext
pub fn mxaccess::SecurityContext::clone(&self) -> mxaccess::SecurityContext
impl core::fmt::Debug for mxaccess::SecurityContext
pub fn mxaccess::SecurityContext::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::SecurityContext
impl core::marker::Send for mxaccess::SecurityContext
impl core::marker::Sync for mxaccess::SecurityContext
impl core::marker::Unpin for mxaccess::SecurityContext
impl core::marker::UnsafeUnpin for mxaccess::SecurityContext
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::SecurityContext
impl core::panic::unwind_safe::UnwindSafe for mxaccess::SecurityContext
pub struct mxaccess::Session
impl mxaccess::Session
pub async fn mxaccess::Session::callback_exporter_addr(&self) -> core::option::Option<core::net::socket_addr::SocketAddr>
pub fn mxaccess::Session::callbacks(&self) -> tokio::sync::broadcast::Receiver<alloc::sync::Arc<mxaccess_codec::subscription_message::NmxSubscriptionMessage>>
pub async fn mxaccess::Session::connect_nmx(addr: core::net::socket_addr::SocketAddr, options: mxaccess::SessionOptions, ntlm: mxaccess_rpc::ntlm::NtlmClientContext, service_ipid: mxaccess_rpc::guid::Guid, resolver: alloc::sync::Arc<dyn mxaccess_galaxy::resolver::Resolver>, recovery: mxaccess::RecoveryPolicy) -> core::result::Result<Self, mxaccess::Error>
pub async fn mxaccess::Session::has_recovery_factory(&self) -> bool
pub fn mxaccess::Session::operation_status_events(&self) -> tokio::sync::broadcast::Receiver<alloc::sync::Arc<mxaccess::session::OperationStatus>>
pub fn mxaccess::Session::operation_status_stream(&self) -> impl futures_core::stream::Stream<Item = core::result::Result<alloc::sync::Arc<mxaccess::session::OperationStatus>, mxaccess::Error>> + core::marker::Send + use<>
pub async fn mxaccess::Session::read(&self, reference: &str, timeout: core::time::Duration) -> core::result::Result<mxaccess::DataChange, mxaccess::Error>
pub async fn mxaccess::Session::recover_connection(&self, policy: mxaccess::RecoveryPolicy) -> core::result::Result<(), mxaccess::Error>
pub fn mxaccess::Session::recovery_events(&self) -> tokio::sync::broadcast::Receiver<alloc::sync::Arc<mxaccess::RecoveryEvent>>
pub async fn mxaccess::Session::resolve_tag(&self, reference: &str) -> core::result::Result<mxaccess_galaxy::metadata::GalaxyTagMetadata, mxaccess::Error>
pub async fn mxaccess::Session::resolve_write_kind(&self, reference: &str) -> core::result::Result<mxaccess_codec::value::MxValueKind, mxaccess::Error>
pub async fn mxaccess::Session::set_recovery_factory(&self, factory: mxaccess::session::RebuildFactory)
pub async fn mxaccess::Session::shutdown_nmx(self) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::subscribe(&self, reference: &str) -> core::result::Result<mxaccess::session::Subscription, mxaccess::Error>
pub async fn mxaccess::Session::unsubscribe(&self, subscription: mxaccess::session::Subscription) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_value(&self, reference: &str, value: mxaccess_codec::write_message::WriteValue) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_value_at(&self, reference: &str, value: mxaccess_codec::write_message::WriteValue, timestamp_filetime: i64) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_value_at_with_handle(&self, reference: &str, value: mxaccess_codec::write_message::WriteValue, timestamp_filetime: i64) -> core::result::Result<mxaccess::session::WriteHandle, mxaccess::Error>
pub async fn mxaccess::Session::write_value_secured_at(&self, reference: &str, value: mxaccess_codec::write_message::WriteValue, timestamp_filetime: i64, security: mxaccess::SecurityContext) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_value_secured_at_with_handle(&self, reference: &str, value: mxaccess_codec::write_message::WriteValue, timestamp_filetime: i64, security: mxaccess::SecurityContext) -> core::result::Result<mxaccess::session::WriteHandle, mxaccess::Error>
pub async fn mxaccess::Session::write_value_with_handle(&self, reference: &str, value: mxaccess_codec::write_message::WriteValue) -> core::result::Result<mxaccess::session::WriteHandle, mxaccess::Error>
impl mxaccess::Session
pub async fn mxaccess::Session::connect(_options: mxaccess::ConnectionOptions) -> core::result::Result<Self, mxaccess::Error>
pub async fn mxaccess::Session::shutdown(self, timeout: core::time::Duration) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::subscribe_buffered(&self, reference: &str, options: mxaccess::BufferedOptions) -> core::result::Result<mxaccess::session::Subscription, mxaccess::Error>
pub async fn mxaccess::Session::subscribe_many(&self, _references: &[&str]) -> core::result::Result<mxaccess::session::Subscription, mxaccess::Error>
pub async fn mxaccess::Session::write(&self, reference: &str, value: mxaccess_codec::value::MxValue) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_secured(&self, _reference: &str, _value: mxaccess_codec::value::MxValue, _security: mxaccess::SecurityContext) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_secured_at(&self, reference: &str, value: mxaccess_codec::value::MxValue, timestamp: std::time::SystemTime, security: mxaccess::SecurityContext) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_secured_at_with_handle(&self, reference: &str, value: mxaccess_codec::value::MxValue, timestamp: std::time::SystemTime, security: mxaccess::SecurityContext) -> core::result::Result<mxaccess::session::WriteHandle, mxaccess::Error>
pub async fn mxaccess::Session::write_with_completion(&self, _reference: &str, _value: mxaccess_codec::value::MxValue, _client_token: u32) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_with_handle(&self, reference: &str, value: mxaccess_codec::value::MxValue) -> core::result::Result<mxaccess::session::WriteHandle, mxaccess::Error>
pub async fn mxaccess::Session::write_with_timestamp(&self, reference: &str, value: mxaccess_codec::value::MxValue, timestamp: std::time::SystemTime) -> core::result::Result<(), mxaccess::Error>
pub async fn mxaccess::Session::write_with_timestamp_and_handle(&self, reference: &str, value: mxaccess_codec::value::MxValue, timestamp: std::time::SystemTime) -> core::result::Result<mxaccess::session::WriteHandle, mxaccess::Error>
impl core::clone::Clone for mxaccess::Session
pub fn mxaccess::Session::clone(&self) -> mxaccess::Session
impl core::fmt::Debug for mxaccess::Session
pub fn mxaccess::Session::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for mxaccess::Session
impl core::marker::Send for mxaccess::Session
impl core::marker::Sync for mxaccess::Session
impl core::marker::Unpin for mxaccess::Session
impl core::marker::UnsafeUnpin for mxaccess::Session
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::Session
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::Session
pub struct mxaccess::SessionOptions
pub mxaccess::SessionOptions::engine_name: alloc::string::String
pub mxaccess::SessionOptions::galaxy_id: u8
pub mxaccess::SessionOptions::heartbeat_max_missed_ticks: i32
pub mxaccess::SessionOptions::heartbeat_ticks_per_beat: core::option::Option<i32>
pub mxaccess::SessionOptions::local_engine_id: i32
pub mxaccess::SessionOptions::partner_version: i32
pub mxaccess::SessionOptions::source_platform_id: i32
impl mxaccess::SessionOptions
pub fn mxaccess::SessionOptions::default_engine_name() -> alloc::string::String
pub fn mxaccess::SessionOptions::default_local_engine_id() -> i32
impl core::clone::Clone for mxaccess::SessionOptions
pub fn mxaccess::SessionOptions::clone(&self) -> mxaccess::SessionOptions
impl core::cmp::Eq for mxaccess::SessionOptions
impl core::cmp::PartialEq for mxaccess::SessionOptions
pub fn mxaccess::SessionOptions::eq(&self, other: &mxaccess::SessionOptions) -> bool
impl core::default::Default for mxaccess::SessionOptions
pub fn mxaccess::SessionOptions::default() -> Self
impl core::fmt::Debug for mxaccess::SessionOptions
pub fn mxaccess::SessionOptions::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::SessionOptions
pub fn mxaccess::SessionOptions::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::StructuralPartialEq for mxaccess::SessionOptions
impl core::marker::Freeze for mxaccess::SessionOptions
impl core::marker::Send for mxaccess::SessionOptions
impl core::marker::Sync for mxaccess::SessionOptions
impl core::marker::Unpin for mxaccess::SessionOptions
impl core::marker::UnsafeUnpin for mxaccess::SessionOptions
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::SessionOptions
impl core::panic::unwind_safe::UnwindSafe for mxaccess::SessionOptions
pub struct mxaccess::Subscription
impl mxaccess::session::Subscription
pub fn mxaccess::session::Subscription::correlation_id(&self) -> [u8; 16]
pub fn mxaccess::session::Subscription::metadata(&self) -> &mxaccess_galaxy::metadata::GalaxyTagMetadata
pub fn mxaccess::session::Subscription::reference(&self) -> &str
impl core::fmt::Debug for mxaccess::session::Subscription
pub fn mxaccess::session::Subscription::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl futures_core::stream::Stream for mxaccess::session::Subscription
pub type mxaccess::session::Subscription::Item = core::result::Result<mxaccess::DataChange, mxaccess::Error>
pub fn mxaccess::session::Subscription::poll_next(self: core::pin::Pin<&mut Self>, cx: &mut core::task::wake::Context<'_>) -> core::task::poll::Poll<core::option::Option<Self::Item>>
impl core::marker::Freeze for mxaccess::session::Subscription
impl core::marker::Send for mxaccess::session::Subscription
impl core::marker::Sync for mxaccess::session::Subscription
impl core::marker::Unpin for mxaccess::session::Subscription
impl core::marker::UnsafeUnpin for mxaccess::session::Subscription
impl !core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::Subscription
impl !core::panic::unwind_safe::UnwindSafe for mxaccess::session::Subscription
pub struct mxaccess::TransportCapabilities
pub mxaccess::TransportCapabilities::activate_suspend: bool
pub mxaccess::TransportCapabilities::buffered_subscribe: bool
pub mxaccess::TransportCapabilities::operation_complete_frame: bool
impl core::clone::Clone for mxaccess::TransportCapabilities
pub fn mxaccess::TransportCapabilities::clone(&self) -> mxaccess::TransportCapabilities
impl core::fmt::Debug for mxaccess::TransportCapabilities
pub fn mxaccess::TransportCapabilities::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for mxaccess::TransportCapabilities
impl core::marker::Freeze for mxaccess::TransportCapabilities
impl core::marker::Send for mxaccess::TransportCapabilities
impl core::marker::Sync for mxaccess::TransportCapabilities
impl core::marker::Unpin for mxaccess::TransportCapabilities
impl core::marker::UnsafeUnpin for mxaccess::TransportCapabilities
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::TransportCapabilities
impl core::panic::unwind_safe::UnwindSafe for mxaccess::TransportCapabilities
#[non_exhaustive] pub struct mxaccess::WriteHandle
pub mxaccess::WriteHandle::correlation_id: [u8; 16]
impl core::clone::Clone for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::clone(&self) -> mxaccess::session::WriteHandle
impl core::cmp::Eq for mxaccess::session::WriteHandle
impl core::cmp::PartialEq for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::eq(&self, other: &mxaccess::session::WriteHandle) -> bool
impl core::fmt::Debug for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for mxaccess::session::WriteHandle
pub fn mxaccess::session::WriteHandle::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
impl core::marker::Copy for mxaccess::session::WriteHandle
impl core::marker::StructuralPartialEq for mxaccess::session::WriteHandle
impl core::marker::Freeze for mxaccess::session::WriteHandle
impl core::marker::Send for mxaccess::session::WriteHandle
impl core::marker::Sync for mxaccess::session::WriteHandle
impl core::marker::Unpin for mxaccess::session::WriteHandle
impl core::marker::UnsafeUnpin for mxaccess::session::WriteHandle
impl core::panic::unwind_safe::RefUnwindSafe for mxaccess::session::WriteHandle
impl core::panic::unwind_safe::UnwindSafe for mxaccess::session::WriteHandle
pub trait mxaccess::Transport: core::marker::Send + core::marker::Sync + 'static
pub fn mxaccess::Transport::capabilities(&self) -> mxaccess::TransportCapabilities
pub fn mxaccess::Transport::kind(&self) -> mxaccess::TransportKind
impl<T: tokio::io::async_read::AsyncRead + tokio::io::async_write::AsyncWrite + core::marker::Unpin + core::marker::Send + core::marker::Sync + 'static> mxaccess::Transport for mxaccess::transport_asb::AsbTransport<T>
pub fn mxaccess::transport_asb::AsbTransport<T>::capabilities(&self) -> mxaccess::TransportCapabilities
pub fn mxaccess::transport_asb::AsbTransport<T>::kind(&self) -> mxaccess::TransportKind
pub type mxaccess::RebuildFactory = alloc::sync::Arc<(dyn core::ops::function::Fn() -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = core::result::Result<mxaccess_nmx::client::NmxClient, mxaccess_nmx::client::NmxClientError>> + core::marker::Send)>> + core::marker::Send + core::marker::Sync)>
