Module links_nonblocking::prelude

Re-exports

• pub use crate::core::framer::into_split_framer;
• pub use crate::core::framer::FrameReader;
• pub use crate::core::framer::FrameWriter;
• pub use crate::core::messenger::into_split_messenger;
• pub use crate::core::messenger::MessageRecver;
• pub use crate::core::messenger::MessageSender;
• pub use crate::core::protocol::persistance::FileMessageLog;
• pub use crate::core::protocol::persistance::InMemoryMessageLog;
• pub use crate::core::protocol::persistance::ProtocolStorage;
• pub use crate::core::protocol::state::ProtocolConnectionState;
• pub use crate::core::protocol::state::ProtocolSessionState;
• pub use crate::core::protocol::Protocol;
• pub use crate::core::protocol::ProtocolCore;
• pub use crate::core::AcceptStatus;
• pub use crate::core::PollAble;
• pub use crate::core::PollAccept;
• pub use crate::core::PollEventStatus;
• pub use crate::core::PollRead;
• pub use crate::core::PoolAcceptStatus;
• pub use crate::core::PoolSvcAcceptorOfCltNonBlocking;
• pub use crate::core::ReSendNonBlocking;
• pub use crate::core::RecvNonBlocking;
• pub use crate::core::RecvStatus;
• pub use crate::core::SendNonBlocking;
• pub use crate::core::SendNonBlockingNonMut;
• pub use crate::core::SendStatus;
• pub use crate::core::SvcAcceptorOfCltNonBlocking;
• pub use crate::connect::clt::Clt;
• pub use crate::connect::clt::CltRecver;
• pub use crate::connect::clt::CltRecverRef;
• pub use crate::connect::clt::CltSender;
• pub use crate::connect::clt::CltSenderRef;
• pub use crate::connect::poll::PollHandler;
• pub use crate::connect::poll::PollHandlerDynamic;
• pub use crate::connect::poll::PollHandlerStatic;
• pub use crate::connect::poll::SpawnedPollHandler;
• pub use crate::connect::poll::SpawnedPollHandlerDynamic;
• pub use crate::connect::poll::SpawnedPollHandlerStatic;
• pub use crate::connect::pool::CltRecversPool;
• pub use crate::connect::pool::CltSendersPool;
• pub use crate::connect::pool::CltsPool;
• pub use crate::connect::pool::TransmittingSvcAcceptor;
• pub use crate::connect::pool::TransmittingSvcAcceptorRef;
• pub use crate::connect::svc::Svc;
• pub use crate::connect::svc::SvcAcceptor;
• pub use crate::connect::svc::SvcRecver;
• pub use crate::connect::svc::SvcRecverRef;
• pub use crate::connect::svc::SvcSender;
• pub use crate::connect::svc::SvcSenderRef;
• pub use crate::connect::svc::SVC_MAX_CONNECTIONS_2_POOL_SIZE_FACTOR;
• pub use crate::connect::DEFAULT_HBEAT_HANDLER;
• pub use crate::connect::DEFAULT_HBEAT_HANDLER;
• pub use crate::connect::DEFAULT_POLL_HANDLER;
• pub use crate::connect::DEFAULT_POLL_HANDLER;

Macros

• asserted_short_name
  Will endure that the short name of Self is matching the name of struct, resolved via Self argument. This prevents invalid names in Debug/Display output after refactoring without performance penalty at run time. Will panic in debug build only if the name is not matching and always resolves to the literal name in release build.
• cross_os_fd
  returns raw fd or socket number depending on the target family

Structs

• AcceptorConnectionGate
  Utility to track the number of active connections.
• CanonicalEntry
  A structure that is used to capture not only information about the message but also the following attributes:
• CanonicalEntryStore
  An in-memory Vec of CanonicalEntry’s protected by a spin::Mutex.
• ChainCallback
  Implements CallbackSend and CallbackRecv by delegating all respective calls to the internal Vec of other callbacks. Will use dynamic dispatch.
• CounterCallback
  Implements CallbackSend and CallbackRecv and provides access methods to get the number/count of sent and received messages.
• DevNullCallback
  Implements CallbackSend and CallbackRecv but simply ignores all messages. Complier should optimize away this callback
• FixedSizeFramer
  Will split the first <const FRAME_SIZE: usize> bytes from the BytesMut buffer and return them as a Bytes frame.
• LoggerCallback
• PacketLengthU16Framer
• RemoveConnectionBarrierOnDrop
  Utility to track number of active connections. See AcceptorConnectionGate for usage.
• RoundRobinPool
  A round robin pool of elements
• StoreCallback
  A callback designed to direct all messages to the Storage::on_msg instance after converting each message into a Canonical type using INTO generic argument
• Timer
  Class that allows scheduling tasks to be executed at repeating interval.

Enums

• ConId
  Connection identifier
• Message
  Enum that captures a relative direction of the type T being sent or received.
• TimerTaskStatus
  Enum representing the status of a timer task

Traits

• CallbackRecv
  Trait for callbacks that wish to get all received messages.
• CallbackRecvSend
  Super trait for callbacks that wish to get all sent and received messages.
• CallbackSend
  Trait for callbacks that wish to get all sent messages.
• ConnectionId
  Trait that maintain an active connection can disclose its connection information via ConId struct
• ConnectionStatus
• Framer
  Provides a function that is meant to determine when enough bytes are available to make up a single complete message/frame.
• Messenger
  Trait defining serialize & deserialize methods for Send & Recv types
• PoolConnectionStatus
  Provides methods for testing status of connections in the Pool
• Storage
  Traits providing an on_msg method that Memory/File/Etc implementations can use to persist incoming message

Functions

• short_instance_type_name
• short_type_name