Skip to main content

Module prelude

Module prelude 

Source

Re-exports§

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;

Modules§

batching
concur_control
future
Asynchronous values.
http
instrument
Attach a span to a std::future::Future.
retryable
sink
Asynchronous sinks.
stream
Asynchronous streams.

Macros§

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.

Structs§

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.

Enums§

Cow
A clone-on-write smart pointer.
Error

Traits§

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.

Functions§

invariance_violation

Type Aliases§

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

Attribute Macros§

async_trait
instrument
Instruments a function to create and enter a tracing span every time the function is called.

Derive Macros§

Debug
Derive macro generating an impl of the trait Debug.
Deserialize
Hash
Derive macro generating an impl of the trait Hash.
Serialize