ContainsRangeStats makes a FeedEventPredicate that matches when the range contains a checkpoint.

DefaultAppTenantTestingKnobs returns the default testing knobs for an application tenant.

EncodeKV encodes primary key with the specified "values".

EncodeKVs is similar to EncodeKV, but can be used for a table with multiple column families, in which case up to one KV is returned per family.

GetStreamJobIds returns the jod ids of the producer and ingestion jobs.

KeyMatches makes a FeedEventPredicate that matches a given key in a kv batch.

MakeReplicationFeed creates a ReplicationFeed based on a given FeedSource.

MakeSpanConfigRecord makes a dummy span config record with the given ttl.

NewReplicationHelper starts test server with the required cluster settings for streming.

NewReplicationHelperWithDummySpanConfigTable creates a new ReplicationHelper, a tenant, and a mock span config table that a spanConfigStreamClient can listen for updates on.

PrettyRecords pretty prints the span config target and config ttl.

ResolvedAtLeast makes a FeedEventPredicate that matches when a timestamp has been reached.

ReplicationFeed allows tests to search for events on a feed.

ReplicationHelper wraps a test server configured to be run in streaming replication tests.

TenantState maintains test state related to tenant.

FeedSource is a source of events for a ReplicationFeed.

FeedErrorPredicate allows tests to match an error from ReplicationFeed.

FeedEventPredicate allows tests to search a ReplicationFeed.