IsFlowRetryableError returns true if an error represents a retryable flow error.

NewFlowBase creates a new FlowBase.

NewFlowRegistry creates a new FlowRegistry.

NewFlowScheduler creates a new FlowScheduler.

NewInboundStreamInfo returns a new InboundStreamInfo.

NewOutbox creates a new Outbox.

NewOutboxSyncFlowStream sets up an outbox for the special "sync flow" stream.

Flow status indicators.

Flow status indicators.

Flow status indicators.

FuseAggressively means serialize unordered input synchronizers.

FuseNormally means fuse what you can, but don't serialize unordered input synchronizers.

PreferredEncoding is the encoding used for EncDatums that don't already have an encoding available.

SettingFlowStreamTimeout is a cluster setting that sets the default flow stream timeout.

FlowBase is the shared logic between row based and vectorized flows.

FlowRegistry allows clients to look up flows by ID and to wait for flows to be registered.

FlowScheduler manages running flows and decides when to queue and when to start flows.

InboundStreamInfo represents the endpoint where a data stream from another node connects to a flow.

Outbox implements an outgoing mailbox as a RowReceiver that receives rows and sends them to a gRPC stream.

OutboxStats are the stats collected by an Outbox.

RowInboundStreamHandler is an InboundStreamHandler for the row based flow.

StreamDecoder converts a sequence of ProducerMessage to rows and metadata records.

StreamEncoder converts EncDatum rows into a sequence of ProducerMessage.

TestingKnobs are the testing knobs for flowinfra.

Flow represents a flow which consists of processors and streams.

InboundStreamHandler is a handler of an inbound stream.

Releasable is an interface for objects than can be Released back into a memory pool when finished.

Startable is any component that can be started (a router or an outbox).

FuseOpt specifies options for processor fusing at Flow.Setup() time.

StartableFn is an adapter when a customer function (i.e.