Enum mz_compute_client::controller::ComputeControllerResponse

pub enum ComputeControllerResponse<T> {
    PeekNotification(Uuid, PeekNotification, OpenTelemetryContext),
    SubscribeResponse(GlobalId, SubscribeBatch<T>),
    CopyToResponse(GlobalId, Result<u64, Error>),
    FrontierUpper {
        id: GlobalId,
        upper: Antichain<T>,
    },
}

Responses from the compute controller.

Variants

PeekNotification(Uuid, PeekNotification, OpenTelemetryContext)

See PeekNotification.

SubscribeResponse(GlobalId, SubscribeBatch<T>)

See crate::protocol::response::ComputeResponse::SubscribeResponse.

CopyToResponse(GlobalId, Result<u64, Error>)

The response from a dataflow containing an CopyToS3Oneshot sink.

The GlobalId identifies the sink. The Result is the response from the sink, where an Ok(n) indicates that n rows were successfully copied to S3 and an Err indicates that an error was encountered during the copy operation.

For a given CopyToS3Oneshot sink, there will be at most one CopyToResponse produced. (The sink may produce no responses if its dataflow is dropped before completion.)

FrontierUpper

A response reporting advancement of a collection’s upper frontier.

Once a collection’s upper (aka “write frontier”) has advanced to beyond a given time, the contents of the collection as of that time have been sealed and cannot change anymore.

Fields

id: GlobalId

The ID of a compute collection.

upper: Antichain<T>

The new upper frontier of the identified compute collection.

Trait Implementations

impl<T: Debug> Debug for ComputeControllerResponse<T>

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

Formats the value using the given formatter.