Crate kitsune_p2p_types

Types subcrate for kitsune-p2p.

Re-exports

• pub use kitsune_p2p_dht as dht;
• pub use kitsune_p2p_dht_arc as dht_arc;

Modules

• agent_info
  Data structures to be stored in the agent/peer database.
• async_lazy
  utility for lazy init-ing things
• bin_types
  Binary types, hashes, signatures, etc used by kitsune.
• bootstrap
  Types for the bootstrap server
• codec
  Encoding / Decoding utilities.
• combinators
  Combinator functions, for more easeful functional programming
• config
  Kitsune Config Tuning Params
• consistency
  Types used for consistency checking during tests or dht health checks. These types describe a protocol that can be implemented to gather statistics on data consistency. This is a first prototype so expect this to change.
• dependencies
  Re-exported dependencies.
• metrics
  Utilities for helping with metric tracking.
• reverse_semaphore
  ReverseSemaphore allow waiting for all permits to be released.
• task_agg
  Task Aggregation helper utility
• tls
  TLS utils for kitsune
• tx2
  Next-gen performance kitsune transport abstractions

Macros

• write_codec_enum
  DSL-style macro for generating a serialization protocol message enum.

Structs

• KitsuneBackoff
  Kitsune Backoff
• KitsuneError
  Error related to remote communication.
• KitsuneTimeout
  Kitsune Timeout
• Tx2Cert
  Wrapper around CertDigest that provides some additional debugging helpers.

Enums

• AutoStreamSelect
  Item Type for auto_stream_select function.
• KitsuneErrorKind
  Error related to remote communication.

Traits

• CertDigestExt
  Extension trait for working with CertDigests.

Functions

• auto_stream_select
  Merge two sub-streams so they can be polled in parallel, but still know when each individually ends, unlike futures::stream::select()
• box_fut
  Helper function for the common case of returning this boxed future type.
• ok_fut
  Helper function for the common case of returning this boxed future type.
• proc_count_now_us
  Monotonically nondecreasing process tick count, backed by tokio::time::Instant as an i64 to facilitate reference times that may be less than the first call to this function. The returned value is on the scale of microseconds.
• proc_count_us_elapsed
  Get the elapsed process count duration from a captured ProcCount to now. If the duration would be negative, this fn returns a zero Duration.
• unit_ok_fut
  Helper function for the common case of returning this nested Unit type.

Type Definitions

• CertDigest
  32 byte binary TLS certificate digest.
• KAgent
  KitsuneAgent in an Arc
• KBasis
  KitsuneBasis in an Arc
• KOpData
  KitsuneOpData in an Arc
• KOpHash
  KitsuneOpHash in an Arc
• KSpace
  KitsuneSpace in an Arc
• KitsuneResult
  Result type for remote communication.
• ProcCountMicros
  Typedef for result of proc_count_now(). This value is on the scale of microseconds.