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.

GetRandomStreamClientSingletonForTesting returns the singleton instance of the client.

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

WithStreamID sets the StreamID for the client.

DupProbability controls the probability with which we emit duplicate data events.

EventFrequency is the frequency in nanoseconds that the stream will emit randomly generated KV events.

EventsPerCheckpoint controls approximately how many data events (KV/SST/DelRange) should be emitted between checkpoint events.

defaultDB */.

IngestionTablePrefix is the prefix of the table name used in the generated table descriptor.

NumPartitions controls the number of partitions the client will stream data back on.

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

RandomStreamSchemaPlaceholder is the schema of the KVs emitted by the random stream client.

SSTProbability controls the probability with which we emit SST event.

TenantID specifies the ID of the tenant we are ingesting data into.

ValueRangeKey controls the range of the randomly generated values produced by this workload.

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

RandomStreamClient is a temporary stream client implementation that generates random events.

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.