Struct mz_coord::tail::PendingTail

pub(crate) struct PendingTail {
    channel: UnboundedSender<PeekResponseUnary>,
    emit_progress: bool,
    arity: usize,
}

A description of a pending tail from coord’s perspective

Fields

channel: UnboundedSender<PeekResponseUnary>

Channel to send responses to the client

The responses have the form PeekResponseUnary but should perhaps become TailResponse.

emit_progress: bool

Whether progress information should be emitted

arity: usize

Number of columns in the output

Implementations

impl PendingTail

pub(crate) fn new(
    channel: UnboundedSender<PeekResponseUnary>,
    emit_progress: bool,
    arity: usize
) -> Self

Create a new PendingTail.

• The channel receives batches of finalized PeekResponses.
• If emit_progress is true, the finalized rows are either data or progress updates
• arity is the arity of the sink relation.

pub(crate) fn process_response(&mut self, response: TailResponse) -> bool

Process a tail response

Returns true if the sink should be removed.