GetFirstActiveClient iterates through each provided stream address and returns the first client it's able to successfully dial.

GetFirstActiveSpanConfigClient iterates through each provided stream address and returns the first client it's able to successfully Dial.

NewHeartbeatSender creates a new HeartbeatSender.

NewStreamClient creates a new stream client based on the stream address.

WithBatchSize requests the producer emit batches up to the specified size.

WithCompression controls requesting a compressed stream from the producer.

WithDiff controls whether the producer-side rangefeeds should be started with the WithDiff option NB: Callers should note that initial scan results will not contain a diff.

WithFiltering controls whether the producer side rangefeed is started with the WithFiltering option, eliding rows where OmitInRangefeed was set at write-time.

WithStreamID sets the StreamID for the client.

RandomGenScheme is the URI scheme used to create a test load.

SslInlineURLParam is a non-standard connection URL parameter.

GetRandomStreamClientSingletonForTesting returns the singleton instance of the client.

ErrorStreamClient always returns an error when consuming a partition.

HeartbeatSender periodically sends a heartbeat for the given streamID to the given client.

MockStreamClient will return the slice of events associated to the stream partition being consumed.

PartitionInfo describes a partition of a replication stream, i.e.

Topology is a configuration of stream partitions.

Client provides methods to stream updates from an application tenant.

Dialer is a wrapper for different kinds of clients which stream updates from a tenant.

SpanConfigClient provides methods to interact with a stream of span config updates of a specific application tenant.

Subscription represents subscription to a replication stream partition.

CheckpointToken is an opaque identifier which can be used to represent checkpoint information to start a stream processor.

DialInterceptFn is a function that will intercept Dial calls made to an InterceptableStreamClient.

HeartbeatInterceptFn is a function that will intercept calls to a client's Heartbeat.

InterceptFn is a function that will intercept events emitted by an InterceptableStreamClient.

An Option configures some part of a Client.

SSTableMakerFn is a function that generates RangeFeedSSTable event with a given list of roachpb.KeyValue.

SubscriptionToken is an opaque identifier returned by Plan which can be used to subscribe to a given partition.