Expand description
Types for cluster-internal control messages that can be broadcast to all workers from individual operators/workers.
Structs§
- Dataflow
Parameters - Dynamic storage instance configuration parameters that are used during dataflow rendering.
Changes to these parameters are applied to
StorageWorkers in a consistent order with source and sink creation. - Indexed
Command 🔒 - Internal
Command Receiver - A receiver for
InternalStorageCommands broadcasted by workers. - Internal
Command Sender - A sender broadcasting
InternalStorageCommands to all workers.
Enums§
- Internal
Storage Command - Internal commands that can be sent by individual operators/workers that will be broadcast to all workers. The worker main loop will receive those and act on them.