List of all items
Structs
- block_layout::BlockLayout
- block_layout::Coded
- block_layout::Digit
- block_layout::Field
- block_layout::Plane
- block_layout::PlaneCursor
- block_layout::SubBlocks
- float_layout::FloatLayout
- pipe::batch::Batch
- pipe::body::Carry
- pipe::body::RequestStream
- pipe::body::ResponseStream
- pipe::bucket_table::BucketTable
- pipe::chaos::ChaosBuilder
- pipe::chaos::ChaosConfig
- pipe::chaos::LatencyFault
- pipe::clock::TimeClock
- pipe::credit_gate::CreditCapacityError
- pipe::credit_gate::CreditGate
- pipe::credit_gate::CreditInput
- pipe::credit_gate::CreditLease
- pipe::delay::Delay
- pipe::delay::DelayConfig
- pipe::delay::DelayFactory
- pipe::demand::AlwaysArmed
- pipe::demand::AtomicGate
- pipe::demand::AtomicGateController
- pipe::demand::Demand
- pipe::diff::Diff
- pipe::drain_sink::DrainFanOut
- pipe::drain_sink::RingSink
- pipe::drain_source::DrainFanIn
- pipe::drain_source::RingSource
- pipe::fan_in::CapacityExceeded
- pipe::fan_in::Exhausted
- pipe::fan_in::FanIn
- pipe::fan_in::FanInVec
- pipe::fan_in::Quorum
- pipe::fanout::AllOrNothing
- pipe::fanout::BestEffort
- pipe::fanout::FanOut
- pipe::fanout::IgnoreErrors
- pipe::fanout_registry::KeyedFanOut
- pipe::fanout_registry::SubscriptionId
- pipe::filter::FilterConfig
- pipe::filter::FilterFactory
- pipe::filter_registry::FilterRegistry
- pipe::filter_registry::FilterRegistryConfig
- pipe::header_list::HeaderList
- pipe::interval_pipe::IntervalPipe
- pipe::interval_pipe::IntervalPipeBuilder
- pipe::interval_pipe::IntervalSourceFactory
- pipe::isolate::Isolate
- pipe::isolate::IsolateConfig
- pipe::isolate::IsolateConfigBuilder
- pipe::isolate::IsolateFactory
- pipe::keyed_live_filter::KeyedLiveFilter
- pipe::lifecycle::ProducerLifecycle
- pipe::lifecycle::ShutdownReport
- pipe::live_filter::FilterControl
- pipe::live_filter::IdSet
- pipe::live_filter::LiveFilter
- pipe::mutate::MutateOp
- pipe::path_pattern::PathPattern
- pipe::primitives::AndThen
- pipe::quiesce::QuiesceResponse
- pipe::rate_limit::CapsConfig
- pipe::rate_limit::CapsConfigBuilder
- pipe::rate_limit::RateLimit
- pipe::rate_limit::RateLimitCaps
- pipe::rate_limit::RateLimitConfig
- pipe::rate_limit::RateLimitConfigBuilder
- pipe::rate_limit::RateLimitFactory
- pipe::rate_limit::TokenBucketConfig
- pipe::request::Request
- pipe::request::RequestBuilder
- pipe::request::RequestContext
- pipe::request::Response
- pipe::resilience::circuit_breaker::AtomicCircuitBreaker
- pipe::resilience::circuit_breaker::CircuitBreaker
- pipe::resilience::deadline::Deadline
- pipe::resilience::fallback::Fallback
- pipe::resilience::retry::RetryController
- pipe::resilience::retry_exec::Retry
- pipe::retry::BudgetConfig
- pipe::retry::BudgetConfigBuilder
- pipe::retry::HttpReplay
- pipe::retry::HttpResponseReplay
- pipe::retry::Retry
- pipe::retry::RetryBudget
- pipe::retry::RetryConfig
- pipe::retry::RetryConfigBuilder
- pipe::retry::RetryFactory
- pipe::retry_rules::RetryRules
- pipe::routing::HostFilter
- pipe::routing::MethodFilter
- pipe::routing::Mount
- pipe::routing::Router
- pipe::routing::RoutingPipe
- pipe::signal_source::SignalSource
- pipe::sink::SinkFront
- pipe::sink_front::SinkCounters
- pipe::sink_front::SinkFront
- pipe::stream_bridge::AsSink
- pipe::stream_bridge::AsStream
- pipe::swap_registry::SwapRegistry
- pipe::swap_registry::SwappablePipe
- pipe::swap_surface::Turn
- pipe::telemetry_surface::HistogramSummary
- pipe::telemetry_surface::Labels
- pipe::telemetry_surface::MetricsSnapshot
- pipe::telemetry_surface::NoopTelemetry
- pipe::transform::Transform
- pipe::transform::TransformConfig
- pipe::transform::TransformFactory
- pipe::upgrade::HijackedSocket
- pipe::upgrade::LocalHijackedSocket
- pipe::upgrade::LocalUpgradeHandler
- pipe::upgrade::UpgradeHandler
- pipe::validate::Validate
- pipe::validate::ValidateConfig
- pipe::validate::ValidateFactory
- pipe::validate::ValidateOp
- pipe::when::When
- stream::Accept
- stream::Connect
- stream::TcpBindOptions
- sync::AcquireError
- sync::Barrier
- sync::Mutex
- sync::MutexGuard
- sync::MutexLockFuture
- sync::Notified
- sync::Notify
- sync::OnceCell
- sync::RwLock
- sync::RwLockReadGuard
- sync::RwLockWriteGuard
- sync::Semaphore
- sync::SemaphoreGuard
- sync::SemaphoreGuardArc
- sync::SemaphorePermit
- sync::TryLockError
- sync::blocking::Condvar
- sync::broadcast::Receiver
- sync::broadcast::SendError
- sync::broadcast::Sender
- sync::mpsc::Receiver
- sync::mpsc::SendError
- sync::mpsc::Sender
- sync::mpsc::UnboundedReceiver
- sync::mpsc::UnboundedSender
- sync::oneshot::Canceled
- sync::oneshot::Receiver
- sync::oneshot::Sender
- sync::shutdown::ResourceRegistry
- sync::shutdown::ShutdownBarrier
- sync::shutdown::ShutdownReport
- sync::task::AbortHandle
- sync::task::JoinError
- sync::task::JoinSet
- sync::task::YieldNow
- sync::watch::Receiver
- sync::watch::RecvError
- sync::watch::Ref
- sync::watch::SendError
- sync::watch::Sender
- transport::replay::Replay
Enums
- codec::Codec
- float_layout::SignEncoding
- float_layout::Specials
- pipe::EnqueueOutcome
- pipe::FailMode
- pipe::ProximaError
- pipe::bounded::EnqueueOutcome
- pipe::bounded::FailMode
- pipe::capabilities::CheckOutcome
- pipe::capabilities::ExceededAction
- pipe::credit_gate::CreditAcquireError
- pipe::credit_gate::CreditGateError
- pipe::delay::Dist
- pipe::drain_source::DrainState
- pipe::endpoint::BindAddr
- pipe::endpoint::PeerInfo
- pipe::fan_in::Select
- pipe::filter::Predicate
- pipe::filter::RejectMode
- pipe::header_name::HeaderName
- pipe::interval_pipe::IntervalBuildError
- pipe::live_filter::FilterUpdate
- pipe::method::Method
- pipe::mutate::Mutation
- pipe::rate_limit::KeyConfig
- pipe::rate_limit::KeyExtractor
- pipe::resilience::backoff::Backoff
- pipe::resilience::backoff::Jitter
- pipe::resilience::circuit_breaker::CircuitState
- pipe::resilience::retry::RetryAction
- pipe::retry::DeliveryOutcome
- pipe::retry::RetryPredicate
- pipe::sans_io::Outcome
- pipe::sink_front::Admission
- pipe::sink_front::DropReason
- pipe::sink_front::SinkLifecycle
- pipe::stream_bridge::AsSinkError
- pipe::transform::RequestOp
- pipe::transform::RequestOpConfig
- pipe::transform::ResponseOp
- pipe::transform::ResponseOpConfig
- pipe::validate::SchemaRef
- sync::TryAcquireError
- sync::broadcast::error::RecvError
- sync::mpsc::TrySendError
- transport::replay::ReplayEvent
Traits
- pipe::alloc_tier::DynPipe
- pipe::alloc_tier::SendDynPipe
- pipe::batch_source::BatchSource
- pipe::capabilities::ApplyOps
- pipe::capabilities::BytePayload
- pipe::capabilities::Checkable
- pipe::capabilities::Clock
- pipe::capabilities::Idempotent
- pipe::capabilities::KeyOf
- pipe::capabilities::Replayable
- pipe::capabilities::Retryable
- pipe::capture_surface::CaptureContext
- pipe::demand::DemandGate
- pipe::drain_sink::DrainSink
- pipe::drain_source::DrainSource
- pipe::ext::PipeExt
- pipe::fan_in::FanInCompletion
- pipe::fan_in::FanInStrategy
- pipe::fanout::FanPolicy
- pipe::handler::Handler
- pipe::handler::ThreadLocalHandler
- pipe::header_list::IntoHeaderBytes
- pipe::labeled::Labeled
- pipe::pipe_factory::PipeFactory
- pipe::plugin::PluginRegistry
- pipe::primitives::Pipe
- pipe::primitives::SendPipe
- pipe::primitives::UnpinPipe
- pipe::primitives::UnpinSendPipe
- pipe::sans_io::ByteStreamParser
- pipe::source::SourceFactory
- pipe::source::SourcePipe
- pipe::stream_bridge::DrainSinkExt
- pipe::stream_bridge::PollSourceExt
- pipe::swap_surface::StreamFramer
- pipe::swap_surface::SwapSurface
- pipe::telemetry_surface::Telemetry
- pipe::upgrade::HijackStream
- pipe::upgrade::LocalHijackStream
- stream::AcceptorFactory
- stream::DatagramFactory
- stream::DatagramSocket
- stream::DatagramSocketBatchExt
- stream::StreamConnection
- stream::StreamListener
- stream::StreamListenerExt
- stream::StreamUpstream
- stream::StreamUpstreamExt
- stream::TcpAcceptor
- stream::UnixUpstreamFactory
Functions
- driver::block_on
- pipe::alloc_tier::into_handle
- pipe::alloc_tier::into_local_handle
- pipe::chaos::chaos
- pipe::diff::diff_handle
- pipe::handler::into_handle
- pipe::handler::into_thread_local_handle
- pipe::keyed_live_filter::keyed_live_filter_ids
- pipe::live_filter::live_filter
- pipe::live_filter::live_filter_ids
- pipe::sans_io::drive_to_completion
- pipe::source::into_source_handle
- pipe::upgrade::local_slots::discard
- pipe::upgrade::local_slots::install
- pipe::upgrade::local_slots::next_ticket
- pipe::upgrade::local_slots::take
- sync::broadcast::channel
- sync::mpsc::channel
- sync::mpsc::unbounded_channel
- sync::oneshot::channel
- sync::shutdown::drain_current_core
- sync::shutdown::register_per_core_resource
- sync::task::yield_now
- sync::watch::channel
- transport::replay::tap_complete
- transport::replay::tap_complete_with_size
Type Aliases
- pipe::ProximaResult
- pipe::alloc_tier::BoxFuture
- pipe::alloc_tier::LocalPipeHandle
- pipe::alloc_tier::PipeHandle
- pipe::alloc_tier::SendBoxFuture
- pipe::body::ChunkStream
- pipe::body::TrailersSlot
- pipe::bounded::BoundedQueue
- pipe::handler::PipeHandle
- pipe::handler::ThreadLocalPipeHandle
- pipe::interval_pipe::RequestFactory
- pipe::pipe_factory::DynPipeFactory
- pipe::pipe_factory::PipeFactoryRegistry
- pipe::retry_rules::StatusSet
- pipe::sink_front::HeapSinkFront
- pipe::sink_front::StaticSinkFront
- pipe::source::SourceFactoryRegistry
- pipe::source::SourceHandle
- pipe::telemetry_surface::TelemetryHandle
- pipe::upgrade::AcceptHandle
- pipe::upgrade::LocalUpgradeFuture
- pipe::upgrade::UpgradeFuture
- stream::ConnectFuture
- sync::blocking::Mutex
- sync::blocking::MutexGuard
- sync::shutdown::DropHook
- transport::replay::BytesReplay
- transport::stream::GenericStream