Expand description

Traits and types for controller of the dataflow subsystem.

Re-exports

pub use controller::Controller;

Modules

A representative of STORAGE and COMPUTE that maintains summaries of the involved objects.

A client to a remote dataflow server.

Clients whose implementation is partitioned across a set of subclients (e.g. timely workers).

A client backed by a process-local timely worker thread.

Generated client implementations.

Nested message and enum types in ProtoComputeCommand.

Nested message and enum types in ProtoComputeResponse.

Generated server implementations.

Generated client implementations.

Nested message and enum types in ProtoStorageCommand.

Nested message and enum types in ProtoStorageResponse.

Generated server implementations.

A client backed by multiple replicas.

Structs

Configuration sent to new compute instances.

Data about timestamp bindings, sent to the coordinator, in service of a specific “linearized” read request

A convenience type for compatibility.

Peek at an arrangement.

A convenience type for compatibility.

Enums

Commands related to the computation and maintenance of views.

Responses that the compute nature of a worker/dataflow can provide back to the coordinator.

Responses that the controller can provide back to the coordinator.

Commands related to the ingress and egress of collections.

Responses that the storage nature of a worker/dataflow can provide back to the coordinator.

Traits

A client to a compute server.

Trait for clients that can connect to an address

A client to a running dataflow server.

Trait for clients that can be disconnected and reconnected.

A client to a storage server.

Type Definitions

An abstraction allowing us to name different compute instances.

A LocalClient for the compute layer.

A LocalClient for the storage layer.

Identifier of a process within a replica.

An abstraction allowing us to name different replicas.