MakeCheckpointEvent creates an Event from a resolved timestamp.

MakeDeleteRangeEvent creates an Event from a DeleteRange.

MakeKVEvent creates an Event from a KV.

MakeSSTableEvent creates an Event from a SSTable.

NewStreamStatusErr creates a new StreamStatusErr.

CheckpointEvent indicates that GetResolvedSpans will be meaningful.

DeleteRangeEvent indicates that the DeleteRange field of an event holds a DeleteRange which needs to be ingested.

KVEvent indicates that the KV field of an event holds an updated KV which needs to be ingested.

SpanConfigEvent indicates that the SpanConfig field of an event holds an updated SpanConfigRecord.

SSTableEvent indicates that the SSTable field of an event holds an updated SSTable which needs to be ingested.

CrossClusterReplicationEnabled enables the ability to setup and control a cross cluster replication stream.

DumpFrontierEntries controls the frequency at which we persist the entries in the frontier to the `system.job_info` table.

JobCheckpointFrequency controls the frequency of frontier checkpoints into the jobs table.

ReplicateSpanConfigsEnabled controls whether we replicate span configurations from the source system tenant to the destination system tenant.

StreamProducerMuxRangefeeds controls whether we start event streams using the mux rangefeeds.

StreamReplicationConsumerHeartbeatFrequency controls frequency the stream replication destination cluster sends heartbeat to the source cluster to keep the stream alive.

StreamReplicationJobLivenessTimeout controls how long we wait for to kill an inactive producer job.

StreamReplicationMinCheckpointFrequency controls the minimum frequency the stream replication source cluster sends checkpoints to destination cluster.

StreamReplicationStreamLivenessTrackFrequency controls frequency to check the liveness of a streaming replication producer job.

StreamStatusErr is an error that encapsulate a replication stream's inactive status.

Event describes an event emitted by a cluster to cluster stream.

EventType enumerates all possible events emitted over a cluster stream.

PartitionAddress is the address where the stream client should be able to read the events produced by a partition of a stream.

StreamAddress is the location of the stream.