Expand description
Types for cluster-internal control messages that can be broadcast to all workers from individual operators/workers.
Structs§
- Dynamic storage instance configuration parameters that are used during dataflow rendering. Changes to these parameters are applied to
StorageWorker
s in a consistent order with source and sink creation. - A receiver for
InternalStorageCommand
s broadcasted by workers. - A sender broadcasting
InternalStorageCommand
s to all workers.
Enums§
- 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.