List of all items

Structs

• compati::CondVarMutex
• compati::Condvar
• compati::Mutex
• compati::RwLock
• io::buffer_pool::BytesPool
• io::buffer_pool::PoolStatsSnapshot
• io::buffer_pool::PooledBuffer
• io::incremental_decoder::AccumulatingBuffer
• io::ioutils::BufferedCapacityCursor
• io::ioutils::BufferedReader
• io::ioutils::BufferedWriter
• io::ioutils::ByteBufferPointer
• io::ioutils::SharedBuffer
• io::ioutils::SharedBufferReadStream
• io::ioutils::SharedBufferReader
• io::ioutils::SharedBufferWriter
• io::ioutils::SharedByteBufferStream
• io::ioutils::SharedWriteReader
• io::mem::encoding::UTF8Encoding
• io::mem::memory::Arena
• io::mem::memory::ArenaPool
• io::mem::memory::FnGenerator
• io::mem::memory::MemoryLimiter
• io::mem::memory::TypeArena
• io::mem::primitives::Bytes
• io::mem::primitives::Range
• io::mem::stringpointer::StringPointer
• io::readers::BatchReader
• io::readers::BatchStreamReader
• io::readers::DataBytesIterator
• io::readers::EOFStreamReader
• io::readers::EofReader
• io::readers::FullBodyReader
• io::readers::LimitedBatchStreamReader
• io::readers::LimitedEOFStreamReader
• io::ubytes::Bytes
• io::ubytes::BytesPointer
• retries::ExponentialBackoffDecider
• retries::RetryState
• retries::SameBackoffDecider
• synca::AbortIfPanic
• synca::ActivitySignal
• synca::DurationStore
• synca::DurationWaker
• synca::Entry
• synca::EntryList
• synca::IdleMan
• synca::LockSignal
• synca::OnSignal
• synca::RunOnDrop
• synca::Sleepers
• synca::SleepyMan
• synca::ThreadSafeEntry
• synca::WaitGroup
• synca::WaitGroupGuard
• synca::mpp::Broadcaster
• synca::mpp::Receiver
• synca::mpp::RecvIter
• synca::mpp::RecvIterator
• synca::mpp::Sender
• synca::mpp::TrackedBroadcaster
• url::Authority
• url::InvalidUri
• url::InvalidUriParts
• url::PathAndQuery
• url::Query
• url::QueryError
• url::Scheme
• url::Uri
• url::UriBuilder
• valtron::AlwaysRetry
• valtron::AnyReadiness
• valtron::AsStream
• valtron::BackgroundJobRegistry
• valtron::BackoffTask
• valtron::BoolSignal
• valtron::BroadcastBuilder
• valtron::BroadcastContinuation
• valtron::CanCloneExecutionIterator
• valtron::CanCloneIterator
• valtron::CanCloneSendIterator
• valtron::CancellableFutureTask
• valtron::Collect
• valtron::CollectAll
• valtron::CollectAllStreams
• valtron::CollectAllTaskStream
• valtron::CollectNext
• valtron::CollectNextFromAllStream
• valtron::CollectNextFromStreams
• valtron::CollectorStreamIterator
• valtron::ConcurrentQueueStreamIterator
• valtron::ConsumingIter
• valtron::DoNext
• valtron::DrivenRecvIterator
• valtron::DrivenStreamIterator
• valtron::DrivenTaskIterator
• valtron::DualSequeunceChildAndParentLinkedTask
• valtron::ExecutorState
• valtron::FilterDone
• valtron::FilterMapReceiver
• valtron::FilterMapRecvFuture
• valtron::FinishChildBeforeParentTask
• valtron::FnMutReady
• valtron::FnReady
• valtron::FutureIterator
• valtron::FutureTask
• valtron::InlineAction
• valtron::LiftBuilder
• valtron::LocalExecutionEngine
• valtron::LocalThreadExecutor
• valtron::MapAllDone
• valtron::MapAllDoneStream
• valtron::MapAllPendingAndDone
• valtron::MapAllPendingAndDoneStream
• valtron::MapCircuit
• valtron::MapDelayed
• valtron::MapDone
• valtron::MapIter
• valtron::MapIterDone
• valtron::MapIterPending
• valtron::MapPending
• valtron::MapPendingAndDone
• valtron::MappedSendFuture
• valtron::MappedSender
• valtron::NoAction
• valtron::NoResolving
• valtron::NotifyQueue
• valtron::NotifyQueueStreamIterator
• valtron::NotifyRecvIter
• valtron::NotifyRecvIterator
• valtron::OnNext
• valtron::OnceCache
• valtron::OneShotStream
• valtron::Pipe
• valtron::PipeReceiver
• valtron::PipeSender
• valtron::PollLimitTask
• valtron::PoolGuard
• valtron::QueueReadiness
• valtron::QueueVacancyReadiness
• valtron::ReadyConsumingIter
• valtron::ReadyValues
• valtron::RecvFuture
• valtron::ReferencedExecutorState
• valtron::SAll
• valtron::SAny
• valtron::SBroadcastContinuation
• valtron::SCollectorStreamIterator
• valtron::SCount
• valtron::SCountAll
• valtron::SEnumerate
• valtron::SFilterState
• valtron::SFind
• valtron::SFindMap
• valtron::SFlatMapNext
• valtron::SFlatMapPending
• valtron::SFlattenNext
• valtron::SFlattenPending
• valtron::SFold
• valtron::SInspectState
• valtron::SMapState
• valtron::SSkipState
• valtron::SSkipWhileState
• valtron::SSplitCollectorContinuation
• valtron::SSplitCollectorMapContinuation
• valtron::SSplitCollectorMapObserver
• valtron::SSplitUntilContinuation
• valtron::SSplitUntilObserver
• valtron::STakeState
• valtron::STakeWhileState
• valtron::STransformUntil
• valtron::ScheduleBuilder
• valtron::SendError
• valtron::SendFuture
• valtron::SequenceBuilder
• valtron::SleepingTask
• valtron::SpawnInfo
• valtron::SplitCollectorContinuation
• valtron::SplitCollectorMapContinuation
• valtron::SplitCollectorMapObserver
• valtron::SplitUntilContinuation
• valtron::SplitUntilContinuationMap
• valtron::SplitUntilObserver
• valtron::SplitUntilObserverMap
• valtron::StreamAsFutureStream
• valtron::StreamCollectFuture
• valtron::StreamConfig
• valtron::StreamConsumingIter
• valtron::StreamIter
• valtron::StreamNextStream
• valtron::StreamPendingFuture
• valtron::StreamReadyFuture
• valtron::StreamRecvIterator
• valtron::StreamTask
• valtron::TAll
• valtron::TAny
• valtron::TCount
• valtron::TCountAll
• valtron::TEnumerate
• valtron::TFilterReady
• valtron::TFilterState
• valtron::TFind
• valtron::TFindMap
• valtron::TFlatMapPending
• valtron::TFlatMapReady
• valtron::TFlattenPending
• valtron::TFlattenReady
• valtron::TFold
• valtron::TInspectState
• valtron::TMapCircuit
• valtron::TMapIter
• valtron::TMapPending
• valtron::TMapReady
• valtron::TMapState
• valtron::TSkipState
• valtron::TSkipWhileState
• valtron::TStreamCollect
• valtron::TTakeState
• valtron::TTakeWhileState
• valtron::TTransformUntil
• valtron::TTryMapReady
• valtron::TaskAsIterator
• valtron::TaskAsStreamIterator
• valtron::TaskIter
• valtron::TaskSpawnConfig
• valtron::ThreadId
• valtron::ThreadedIterFuture
• valtron::TimeoutTask
• valtron::TransformIterator
• valtron::TransformSendIterator
• valtron::TransformUntilIterator
• valtron::TransformUntilSendIterator
• valtron::TryMapDone
• valtron::UntilTake
• valtron::UntilUnblocked
• valtron::WakeToken
• valtron::WrapTask
• valtron::WrappedCloneableFnMut
• valtron::delayed_iterators::DelayedAsIterator
• valtron::delayed_iterators::SleepIterator
• valtron::multi_iterator::MultiAsIterator
• valtron::non_sendables::CollectAllStreams
• valtron::non_sendables::CollectAllTaskStream
• valtron::non_sendables::CollectNextFromAllStream
• valtron::non_sendables::DrivenRecvIterator
• valtron::non_sendables::DrivenStreamIterator
• valtron::non_sendables::DrivenTaskIterator
• valtron::non_sendables::InlineAction
• valtron::non_sendables::MapAllDoneStream
• valtron::non_sendables::MapAllPendingAndDoneStream
• valtron::non_sendables::OneShotStream
• valtron::single::NoThreadController
• valtron::single::PoolGuard
• valtron::single::SingleExecutorSingleton
• valtron::trace::TracingTestConfig

Enums

• extensions::serde_ext::JsonError
• extensions::serde_ext::TomlError
• extensions::serde_ext::ValueError
• extensions::strings_ext::TryIntoStrError
• extensions::strings_ext::TryIntoStringError
• io::incremental_decoder::DecodeError
• io::incremental_decoder::DecodeStep
• io::ioutils::Data
• io::ioutils::OwnedReader
• io::ioutils::PeekError
• io::ioutils::PeekState
• io::mem::memory::MemoryErrors
• io::readers::Data
• synca::LockState
• synca::NotifyDirective
• synca::SleepyState
• synca::mpp::ReceiverError
• synca::mpp::SenderError
• traits::try_clone::TryCloneError
• url::Host
• valtron::BackoffStrategy
• valtron::BranchPath
• valtron::BroadcastPolicy
• valtron::CancelOutcome
• valtron::CollectionState
• valtron::ExecutorError
• valtron::FuturePollState
• valtron::InlineActionBehaviour
• valtron::LocalFallback
• valtron::NotificationItem
• valtron::PriorityOrder
• valtron::ProgressIndicator
• valtron::ReadyValue
• valtron::ScheduleOutcome
• valtron::ShortCircuit
• valtron::Sleepable
• valtron::SpawnType
• valtron::State
• valtron::Stream
• valtron::StreamPollState
• valtron::StreamSpread
• valtron::TaskShortCircuit
• valtron::TaskSpread
• valtron::TaskStatus
• valtron::ThreadActivity
• valtron::ThreadedValue
• valtron::TryRecvError
• valtron::TrySendError
• valtron::delayed_iterators::Delayed
• valtron::multi_iterator::Multi

Traits

• extensions::result_ext::BoxedResult
• extensions::result_ext::SendableBoxedResult
• extensions::serde_ext::AsType
• extensions::serde_ext::DynamicValueExt
• extensions::serde_ext::JsonValueExt
• extensions::serde_ext::PointerValueExt
• extensions::serde_ext::TomlValueExt
• extensions::strings_ext::IntoStr
• extensions::strings_ext::IntoString
• extensions::strings_ext::TryIntoStr
• extensions::strings_ext::TryIntoString
• extensions::vec_ext::VecExt
• io::incremental_decoder::IncrementalDecoder
• io::ioutils::BufferCapacity
• io::ioutils::IsUnixTransport
• io::ioutils::PeekableReadStream
• io::ioutils::ReadTimeoutOperations
• io::ioutils::SplitReadStream
• io::mem::encoding::Decoder
• io::mem::encoding::Encoder
• io::mem::encoding::Encoding
• io::mem::memory::PoolGenerator
• io::mem::memory::Resettable
• io::mem::primitives::Align
• io::readers::HintReadterator
• io::readers::IntoDataBytes
• io::stream_ext::ReadBytesExt
• retries::CReconnectionDecider
• retries::RetryDecider
• synca::Timeable
• synca::Timing
• synca::Waiter
• synca::Waker
• traits::try_clone::TryClone
• type_uuid::TypeUuid
• type_uuid::TypeUuidDynamic
• valtron::CanNotify
• valtron::CanNotifyOfSelf
• valtron::CloneProcessController
• valtron::CloneableExecutionIterator
• valtron::CloneableFn
• valtron::CloneableIterator
• valtron::CloneableSendIterator
• valtron::Drain
• valtron::EventReadiness
• valtron::ExecutionAction
• valtron::ExecutionEngine
• valtron::ExecutionIterator
• valtron::IntoBoxedExecutionAction
• valtron::IntoBoxedExecutionIterator
• valtron::IntoBoxedSendExecutionAction
• valtron::IntoBoxedSendExecutionIterator
• valtron::IntoBoxedSendTaskReadyResolver
• valtron::IntoBoxedTaskReadyResolver
• valtron::IntoRawExecutionIterator
• valtron::Notifiable
• valtron::ProcessController
• valtron::RetryDecider
• valtron::SeedableRng
• valtron::SendableIterator
• valtron::StreamIterator
• valtron::StreamIteratorExt
• valtron::TaskIterator
• valtron::TaskIteratorExt
• valtron::TaskReadyResolver
• valtron::delayed_iterators::DelayedIterator
• valtron::delayed_iterators::DelayedReadyResolver
• valtron::multi_iterator::AsMultiIterator
• valtron::multi_iterator::MultiIterator

Macros

• debug
• err
• error
• external_type_uuid
• info
• is_ok
• make_collection
• on_result
• panic_if_failed
• unwrap_or_panic_log
• warn

Attribute Macros

• valtron::timeout
• valtron::valtron
• valtron::valtron_test

Functions

• io::incremental_decoder::read_frame_blocking
• io::ioutils::buffered_stream
• io::ioutils::buffered_stream_with_capacity
• io::mem::memory::calculate_size_for
• synca::mpp::bounded
• synca::mpp::unbounded
• type_uuid::parse_uuid_const
• url::percent_decode
• url::percent_encode
• valtron::any_task
• valtron::block_on_future
• valtron::cancel_signal
• valtron::collect_all
• valtron::collect_all_streams
• valtron::collect_next_from_streams
• valtron::collect_one
• valtron::collect_result
• valtron::drive_cancellable_future
• valtron::drive_future
• valtron::drive_future_stream
• valtron::drive_iterator
• valtron::drive_receiver
• valtron::drive_stream
• valtron::exec_future
• valtron::execute
• valtron::execute_as_task
• valtron::execute_collect_all
• valtron::execute_collect_next_from_all
• valtron::execute_map_all
• valtron::execute_map_all_pending_and_done
• valtron::execute_with_config
• valtron::from_cancellable_future
• valtron::from_future
• valtron::from_stream
• valtron::initialize_pool
• valtron::inlined_task
• valtron::map_all_done
• valtron::map_all_pending_and_done
• valtron::non_sendables::block_on_future
• valtron::non_sendables::cancel_signal
• valtron::non_sendables::collect_all_streams
• valtron::non_sendables::drive_cancellable_future
• valtron::non_sendables::drive_future
• valtron::non_sendables::drive_future_stream
• valtron::non_sendables::drive_iterator
• valtron::non_sendables::drive_receiver
• valtron::non_sendables::drive_stream
• valtron::non_sendables::exec_future
• valtron::non_sendables::execute
• valtron::non_sendables::execute_as_task
• valtron::non_sendables::execute_collect_all
• valtron::non_sendables::execute_collect_next_from_all
• valtron::non_sendables::execute_map_all
• valtron::non_sendables::execute_map_all_pending_and_done
• valtron::non_sendables::execute_with_config
• valtron::non_sendables::from_cancellable_future
• valtron::non_sendables::from_future
• valtron::non_sendables::from_stream
• valtron::non_sendables::initialize_pool
• valtron::non_sendables::inlined_task
• valtron::non_sendables::one_shot
• valtron::non_sendables::run_background_job
• valtron::non_sendables::run_future
• valtron::non_sendables::run_future_iter
• valtron::non_sendables::run_once
• valtron::non_sendables::run_until
• valtron::non_sendables::run_until_complete
• valtron::non_sendables::run_until_next_acceptable_state
• valtron::non_sendables::run_until_next_state
• valtron::non_sendables::run_until_next_state_within
• valtron::non_sendables::run_until_ready_state
• valtron::non_sendables::run_until_receiver_has_value
• valtron::non_sendables::run_until_stream_has_value
• valtron::non_sendables::schedule_future
• valtron::non_sendables::send
• valtron::non_sendables::sleep
• valtron::non_sendables::sleep_async
• valtron::non_sendables::sync_all
• valtron::non_sendables::sync_collect_one
• valtron::non_sendables::sync_one
• valtron::one_shot
• valtron::queue_waker
• valtron::run_background_job
• valtron::run_future
• valtron::run_future_iter
• valtron::run_once
• valtron::run_until
• valtron::run_until_complete
• valtron::run_until_next_acceptable_state
• valtron::run_until_next_state
• valtron::run_until_next_state_within
• valtron::run_until_ready_state
• valtron::run_until_receiver_has_value
• valtron::run_until_stream_has_value
• valtron::schedule_future
• valtron::send
• valtron::send_any_task
• valtron::send_typed_task
• valtron::single::initialize_pool
• valtron::single::run_background_job
• valtron::single::run_once
• valtron::single::run_until
• valtron::single::run_until_complete
• valtron::single::spawn
• valtron::single::spawn2
• valtron::sleep
• valtron::sleep_async
• valtron::spawn_broadcaster
• valtron::spawn_builder
• valtron::split_thread_count
• valtron::sync_all
• valtron::sync_collect_one
• valtron::sync_one
• valtron::trace::try_init_tracing
• valtron::trace::try_init_tracing_with
• valtron::typed_task

Type Aliases

• extensions::result_ext::BoxedError
• extensions::result_ext::Result
• extensions::result_ext::SendableBoxedError
• extensions::serde_ext::Result
• extensions::serde_ext::ValueResult
• extensions::strings_ext::IntoStringResult
• extensions::strings_ext::TryIntoStrResult
• io::ioutils::BufferedStream
• io::mem::encoding::SharedEncoding
• io::mem::memory::GeneratorFunc
• io::mem::memory::ReferencedType
• io::mem::memory::SharedArenaPool
• type_uuid::Bytes
• valtron::AnyResult
• valtron::AsTaskIterator
• valtron::BackgroundJob
• valtron::BoxedExecutionAction
• valtron::BoxedExecutionEngine
• valtron::BoxedExecutionIterator
• valtron::BoxedIterator
• valtron::BoxedPanicHandler
• valtron::BoxedResultIterator
• valtron::BoxedSendExecutionAction
• valtron::BoxedSendExecutionIterator
• valtron::BoxedSendIterator
• valtron::BoxedSendStateIterator
• valtron::BoxedSendSyncStateIterator
• valtron::BoxedSendTaskReadyResolver
• valtron::BoxedSendableDataIterator
• valtron::BoxedSendableIterator
• valtron::BoxedSendableVecIterator
• valtron::BoxedStateIterator
• valtron::BoxedTaskIterator
• valtron::BoxedTaskReadyResolver
• valtron::CloneableBoxIterator
• valtron::CloneableSendBoxIterator
• valtron::EventReadinessPtr
• valtron::GenericResult
• valtron::GlobalTask
• valtron::NoResolver
• valtron::NoResolverAndSpawner
• valtron::NoSpawner
• valtron::PanicHandler
• valtron::SendGenericResult
• valtron::SendVecIterator
• valtron::SendableBoxIterator
• valtron::SharedTaskQueue
• valtron::StringBoxedIterator
• valtron::VecBoxedIterator
• valtron::delayed_iterators::BoxedDelayedIterator
• valtron::delayed_iterators::BoxedDelayedReadyResolver

Constants

• io::ioutils::DEFAULT_READ_SIZE
• retries::DEFAULT_MIN_DURATION
• valtron::BACK_OFF_JITER
• valtron::BACK_OFF_MAX_DURATION
• valtron::BACK_OFF_MIN_DURATION
• valtron::BACK_OFF_THREAD_FACTOR
• valtron::DEFAULT_BG_YIELD_DURATION
• valtron::DEFAULT_DELIVERY_CAPACITY
• valtron::DEFAULT_KILL_SIGNAL_CHECK_INTERVAL
• valtron::DEFAULT_MAX_TURNS
• valtron::DEFAULT_NOTIFY_QUEUE_MAX_SPINS
• valtron::DEFAULT_NOTIFY_QUEUE_WAIT_TIMEOUT
• valtron::DEFAULT_OP_READ_TIME
• valtron::DEFAULT_PARK_DURATION
• valtron::DEFAULT_READINESS_WAIT
• valtron::DEFAULT_WAIT_CYCLE
• valtron::DEFAULT_YIELD_WAIT_TIME
• valtron::MAX_ROUNDS_IDLE_COUNT
• valtron::MAX_ROUNDS_WHEN_SLEEPING_ENDS