Enum mz_controller::ControllerResponse

pub enum ControllerResponse<T = Timestamp> {
    PeekResponse(Uuid, PeekResponse, OpenTelemetryContext),
    SubscribeResponse(GlobalId, SubscribeResponse<T>),
    ComputeReplicaHeartbeat(ReplicaId, DateTime<Utc>),
    ComputeReplicaMetrics(ReplicaId, Vec<ServiceProcessMetrics>),
    ComputeReplicaWriteFrontiers(BTreeMap<ReplicaId, Vec<(GlobalId, T)>>),
}

Responses that Controller can produce.

Variants

PeekResponse(Uuid, PeekResponse, OpenTelemetryContext)

The worker’s response to a specified (by connection id) peek.

Additionally, an OpenTelemetryContext to forward trace information back into coord. This allows coord traces to be children of work done in compute!

SubscribeResponse(GlobalId, SubscribeResponse<T>)

The worker’s next response to a specified subscribe.

ComputeReplicaHeartbeat(ReplicaId, DateTime<Utc>)

Notification that we have received a message from the given compute replica at the given time.

ComputeReplicaMetrics(ReplicaId, Vec<ServiceProcessMetrics>)

Notification that new resource usage metrics are available for a given replica.

ComputeReplicaWriteFrontiers(BTreeMap<ReplicaId, Vec<(GlobalId, T)>>)

Notification that the write frontiers of the replicas have changed.

Trait Implementations

impl<T: Clone> Clone for ControllerResponse<T>

fn clone(&self) -> ControllerResponse<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for ControllerResponse<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for ControllerResponse<T>where
    T: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
    __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> From<ComputeControllerResponse<T>> for ControllerResponse<T>

fn from(r: ComputeControllerResponse<T>) -> ControllerResponse<T>

Converts to this type from the input type.

impl<T> Serialize for ControllerResponse<T>where
    T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
    __S: Serializer,

Serialize this value into the given Serde serializer.