Skip to main contentModule prelude
Source pub use crate::base;pub use crate::base::schema;pub use crate::base::spec;pub use crate::base::value;pub use crate::builder;pub use crate::builder::exec_ctx;pub use crate::builder::plan;pub use crate::execution;pub use crate::lib_context::FlowContext;pub use crate::lib_context::LibContext;pub use crate::lib_context::get_lib_context;pub use crate::lib_context::get_runtime;pub use crate::ops::interface;pub use crate::setup;pub use crate::setup::AuthRegistry;pub use recoco_utils as utils;
- batching
- concur_control
- future
- Asynchronous values.
- http
- instrument
- Attach a span to a
std::future::Future. - retryable
- sink
- Asynchronous sinks.
- stream
- Asynchronous streams.
- api_bail
- api_error
- client_bail
- client_error
- debug
- Constructs an event at the debug level.
- error
- Constructs an event at the error level.
- info
- Constructs an event at the info level.
- info_span
- Constructs a span at the info level.
- internal_bail
- internal_error
- stream
- Asynchronous stream
- trace
- Constructs an event at the trace level.
- try_stream
- Asynchronous fallible stream
- warn
- Constructs an event at the warn level.
- ApiError
- Arc
- A thread-safe reference-counting pointer. ‘Arc’ stands for ‘Atomically
Reference Counted’.
- BTreeMap
- An ordered map based on a B-Tree.
- BTreeSet
- An ordered set based on a B-Tree.
- DateTime
- ISO 8601 combined date and time with time zone.
- HashMap
- A hash map implemented with quadratic probing and SIMD lookup.
- HashSet
- A hash set implemented as a
HashMap where the value is (). - IndexMap
- A hash table where the iteration order of the key-value pairs is independent
of the hash values of the keys.
- IndexSet
- A hash set where the iteration order of the values is independent of their
hash values.
- LazyLock
- A value which is initialized on the first access.
- Mutex
- A mutual exclusion primitive useful for protecting shared data
- OnceLock
- A synchronization primitive which can nominally be written to only once.
- RwLock
- A reader-writer lock
- Shared
- Future for the
shared method. - Span
- A handle representing a span, with the capability to enter the span if it
exists.
- Utc
- The UTC time zone. This is the most efficient time zone when you don’t need the local time.
It is also used as an offset (which is also a dummy type).
- Weak
Weak is a version of Arc that holds a non-owning reference to the
managed allocation.
- Cow
- A clone-on-write smart pointer.
- Error
- Any
- A trait to emulate dynamic typing.
- AsyncBufRead
- Read bytes asynchronously.
- AsyncRead
- Read bytes asynchronously.
- AsyncSeek
- Seek bytes asynchronously.
- AsyncWrite
- Write bytes asynchronously.
- ContextExt
- Debug
? formatting.- Deserialize
- A data structure that can be deserialized from any data format supported
by Serde.
- DeserializeOwned
- A data structure that can be deserialized without borrowing any data from
the deserializer.
- Future
- A future represents an asynchronous computation, commonly obtained by use of
async. - FutureExt
- An extension trait for
Futures that provides a variety of convenient
adapters. - Hash
- A hashable type.
- Itertools
- An
Iterator blanket implementation that provides extra adaptors and
methods. - Serialize
- A data structure that can be serialized into any data format supported
by Serde.
- Sink
- A
Sink is a value into which other values can be sent, asynchronously. - Stream
- A stream of values produced asynchronously.
- StreamExt
- An extension trait for
Streams that provides a variety of convenient
combinator functions. - TryFuture
- A convenience for futures that return
Result values that includes
a variety of adapters tailored to such futures. - TryStream
- A convenience for streams that return
Result values that includes
a variety of adapters tailored to such futures. - _
- An extension trait for
Futures that provides a variety of convenient
adapters.
- invariance_violation
- BoxFuture
- An owned dynamically typed
Future for use in cases where you can’t
statically type your result or need to add some indirection. - BoxStream
- An owned dynamically typed
Stream for use in cases where you can’t
statically type your result or need to add some indirection. - Result
- async_trait
- instrument
- Instruments a function to create and enter a
tracing span every time
the function is called.
- Debug
- Derive macro generating an impl of the trait
Debug. - Deserialize
- Hash
- Derive macro generating an impl of the trait
Hash. - Serialize