Module dataflow_types::client [−][src]
Expand description
Traits and types for controller of the dataflow subsystem.
Re-exports
pub use controller::Controller;Modules
A client that maintains summaries of the involved objects.
Clients whose implementation is partitioned across a set of subclients (e.g. timely workers).
A client backed by a process-local timely worker thread.
Structs
A helper struct which allows us to interpret a Client as a Stream of Response.
A convenience type for compatibility.
A wrapper for enumerating any available result from a client.
Data about timestamp bindings that dataflow workers send to the coordinator
Enums
Explicit instructions for timely dataflow workers.
Commands related to the computation and maintenance of views.
The kind of compute command that was received
Responses that the compute nature of a worker/dataflow can provide back to the coordinator.
Responses that the worker/dataflow can provide back to the coordinator.
Commands related to the ingress and egress of collections.
the kind of storage command that was received
Responses that the storage nature of a worker/dataflow can provide back to the coordinator.
Constants
A default value whose use we can track down and remove later.
Traits
A client to a running dataflow server.
Methods that reflect actions that can be performed against a compute instance.
Methods that reflect actions that can be performed against the storage layer.
Type Definitions
An abstraction allowing us to name difference compute instances.