risingwave_pb::task_service

Type Alias PbGetStreamResponse

source
pub type PbGetStreamResponse = GetStreamResponse;
Expand description

Alias for GetStreamResponse.

Aliased Type§

struct PbGetStreamResponse {
    pub message: Option<StreamMessage>,
    pub permits: Option<Permits>,
}

Fields§

§message: Option<StreamMessage>§permits: Option<Permits>

The number of permits acquired for this message, which should be sent back to the upstream with add_permits. In theory, this can also be derived from the message itself by the receiver. Here we send it explicitly to avoid any sense of inconsistency for the derivation logic, so the receiver can simply send it back verbatim.