[−][src]Module arcon::prelude

Re-exports

pub use crate::streaming::channel::strategy::broadcast::Broadcast;

pub use crate::streaming::channel::strategy::forward::Forward;

pub use crate::streaming::channel::strategy::key_by::KeyBy;

pub use crate::streaming::channel::strategy::round_robin::RoundRobin;

pub use crate::streaming::channel::strategy::shuffle::Shuffle;

pub use crate::streaming::channel::strategy::ChannelStrategy;

pub use crate::streaming::channel::Channel;

pub use crate::streaming::task::filter::Filter;

pub use crate::streaming::task::flatmap::FlatMap;

pub use crate::streaming::task::map::Map;

pub use crate::streaming::window::builder::WindowBuilder;

pub use crate::streaming::window::builder::WindowFn;

pub use crate::streaming::window::builder::WindowModules;

pub use crate::streaming::window::event_time::EventTimeWindowAssigner;

pub use crate::streaming::window::processing_time::ProcessingTimeWindowAssigner;

pub use crate::streaming::source::collection::CollectionSource;

pub use crate::streaming::source::local_file::LocalFileSource;

pub use crate::streaming::source::socket::SocketKind;

pub use crate::streaming::source::socket::SocketSource;

pub use crate::streaming::sink::debug::DebugSink;

pub use crate::streaming::sink::local_file::LocalFileSink;

pub use crate::streaming::sink::socket::SocketSink;

pub use crate::data::*;

pub use crate::weld::module::Module;

pub use crate::weld::module::ModuleRun;

default_components
future	Futures
helpers
lookup	Data structures for looking up the dispatch/routing table.
messages	Generated file from `messages.proto`
messaging	Messaging types for sending and receiving messages between remote actors.
net
prelude
queue_manager
ser	Deprecated Compatibility name to ease upgrading from `slog v1`
ser_test_helpers
serialisation_ids
timer

b	Macro for building group of key-value pairs in `BorrowedKV`
crit	Log critical level record
debug	Log debug level record
error	Log error level record
info	Log info level record
kv	Macro for build `KV` implementing type
log	Log message a logging record
o	Macro for building group of key-value pairs: `OwnedKV`
record	Create `Record` at the given code location
record_static	Create `RecordStatic` at the given code location
slog_b	Alias of `b`
slog_crit	Log critical level record (alias)
slog_debug	Log debug level record (alias)
slog_error	Log error level record
slog_info	Log info level record (alias)
slog_kv	Alias of `kv`
slog_log	Log message a logging record (alias)
slog_o	Macro for building group of key-value pairs (alias)
slog_record	Create `Record` at the given code location (alias)
slog_record_static	Create `RecordStatic` at the given code location (alias)
slog_trace	Log trace level record (alias)
slog_warn	Log warning level record (alias)
trace	Log trace level record
warn	Log warning level record

ActorRefStrong
Appender	The `appender` builder type.
Async	Async drain
BorrowedKV	Borrowed `KV`
ComponentCore
ConcurrentQueue	An unbounded multi-producer multi-consumer queue.
CustomComponents
DeadletterBox
Dict	The dictionary type.
DictMerger	The `dictmerger` builder type.
Discard	`Drain` discarding everything
Duplicate	`Drain` duplicating records into two other `Drain`s
Filter	`Drain` filtering records
FnValue	Explicit lazy-closure `Value`
Fuse	`Drain` panicking on error
Future	Until the futures crate stabilises
GroupMerger	The `groupmerger` builder type.
IgnoreResult	`Drain` ignoring result
LevelFilter	`Drain` filtering records by `Record` logging level
LocalDispatcher
Logger	Logging handle used to execute logging statements
MapError	`Drain` mapping error returned by another `Drain`
OwnedKV	Owned KV
OwnedKVList	Chain of `SyncMultiSerialize`-s of a `Logger` and its ancestors
Promise	Until the futures crate stabilises
ProtoSer
ProvidedPort
ProvidedRef
PushFnValue	Lazy `Value` that writes to Serializer
PushFnValueSerializer	Handle passed to `PushFnValue` closure
Record	One logging record
RecordStatic	Information that can be static in the given record thus allowing to optimize record creation to be done mostly at compile-time.
RegisteredPath
RequiredPort
RequiredRef
ScheduledTimer
SingleKV	Single pair `Key` and `Value`
SystemPath
TransportParseError
WeldVec	A dynamically sized constant vector.

Async	Return type of future, indicating whether a value is ready or not.
AsyncSink	The result of an asynchronous attempt to send a value to a sink.
Error	Serialization Error
FilterLevel	Logging filtering level
KompactError
Level	Logging level associated with a logging `Record`
MutexDrainError	Error returned by `Mutex<D : Drain>`
PathParseError
PromiseErr
SchedulingDecision
Transport
TryDualLockError

LOG_LEVEL_NAMES	Official capitalized logging (and logging filtering) level names
LOG_LEVEL_SHORT_NAMES	Official capitalized logging (and logging filtering) short level names

ActorRaw	Handles raw message envelopes. Usually it's better to us the unwrapped functions in `Actor`, but this can be more efficient at times.
ActorRefFactory
ActorSource
BoxDeserialisable
Dispatcher	A dispatcher is a system component that knows how to route messages and create system paths.
Dispatching
Drain	Logging drain
ExecuteSend
FilterFn	Function that can be used in `Filter` drain
From	Used to do value-to-value conversions while consuming the input value. It is the reciprocal of `Into`.
Fulfillable
Future	Trait for types which are a placeholder of a value that may become available at some later point in time.
Into	A value-to-value conversion that consumes the input value. The opposite of `From`.
IntoFuture	Class of types which can be converted into a future.
KV	Key-value pair(s) for log events
MapErrFn	Function that can be used in `MapErr` drain
Port
Scheduler
SendRefUnwindSafeDrain	`Drain + Send + RefUnwindSafe` bound
SendSyncRefUnwindSafeDrain	`Drain + Send + Sync + RefUnwindSafe` bound
SendSyncRefUnwindSafeKV	This type is used to enforce `KV`s stored in `Logger`s are thread-safe.
SendSyncUnwindSafe	`Send + Sync + UnwindSafe` bound
SendSyncUnwindSafeDrain	`Drain + Send + Sync + UnwindSafe` bound
Serializer	Serializer
Sink	A `Sink` is a value into which other values can be sent, asynchronously.
Stream	A stream of values, not all of which may have been produced yet.
SystemComponents
Timer
TimerComponent
TimerRefFactory
Value	Value that can be serialized

biconnect
create_element
create_keyed_element
ok	Creates a "leaf future" from an immediate value of a finished and successful computation.
on_dual_definition
promise

Key	Key type
KompactLogger
OwnedKeyValueList	Deprecated Compatibility name to ease upgrading from `slog v1`
Poll	Return type of the `Future::poll` method, indicates whether a future's value is ready or not.
PushFnSerializer	Deprecated Old name of `PushFnValueSerializer`
PushLazy	Deprecated Compatibility name to ease upgrading from `slog v1`
Result	Serialization `Result`
Serialize	Deprecated Compatibility name to ease upgrading from `slog v1`
StartSend	Return type of the `Sink::start_send` method, indicating the outcome of a send attempt. See `AsyncSink` for more details.
ValueSerializer	Deprecated Compatibility name to ease upgrading from `slog v1`
WeldBool	A boolean in Weld.