Categorygithub.com/cockroachdb/cockroachpkgcrossclusterphysical
package
25.1.0+incompatible
Repository: https://github.com/cockroachdb/cockroach.git
Documentation: pkg.go.dev
Versions
1
Dependencies
78
Dependents
2
Files
5.2k SLOC

# Functions

MakeMetrics makes the metrics for stream ingestion job monitoring.

# Variables

CannotSetExpirationWindowErr get returned if the user attempts to specify the EXPIRATION WINDOW option to create a replication stream, as this job setting should only be set from the producer cluster.

# Structs

MergedSubscription combines multiple subscriptions into a single merged stream of events.
Metrics are for production monitoring of stream ingestion jobs.
PartitionEvent augments a normal event with the partition it came from.