Module kitsune_p2p_types::tx2::tx2_utils

Utilities to help with developing / testing tx2.

Structs

• Active
  Active tracking helper for related items. This facilitates e.g. an endpoint with sub connections. The endpoint can close, closing all connections. Or, individual connections can close, without closing the endpoint.
• LogicChan
  A logic channel. Capture a handle to the logic_chan. Fill the LogicChan with async logic. Report events to the handle in the async logic. Treat the LogicChan as a stream, collecting the events.
• LogicChanHandle
  Handle to a logic_chan instance. A clone of a LogicChanHandle is Eq to its origin. A clone of a LogicChanHandle will Hash the same as its origin.
• NotifyAll
  Many tasks can await on this notify struct. They will all be notified once notify is called.
• PoolBuf
  A buffer that will return to a pool after use.
• ResourceBucket
  Control efficient access to shared resource pool.
• Share
  Synchronized droppable share-lock around internal state date.
• ShareOpen
  A version of Share which can never be closed, and thus every share is infallible (no Err possible).
• TReceiver
  The receiver side of a t_chan.
• TSender
  The sender side of a t_chan - this is cheaply clone-able.
• TxUrl
  New-type for sync ref-counted Urls to make passing around tx2 more efficient.

Functions

• bound_async_mem_channel
  Construct a bound async read/write memory channel
• fill_with_latency_info
  Fill a buffer with data that is readable as latency information. Note, the minimum message size to get the timing data across is 16 bytes.
• parse_latency_info
  Return the duration since the time encoded in a latency info buffer. Returns a unit error if we could not parse the buffer into time data.
• t_chan
  tokio::sync::mpsc::Sender is cheaply clonable, futures::channel::mpsc::Sender can be closed from the sender side. We want both these things. Produce a TChan - a wrapper around a tokio::sync::mpsc::channel. Provides futures::stream::Stream impl on TReceive. Allows channel close from sender side.