package
25.1.0+incompatible
Repository: https://github.com/cockroachdb/cockroach.git
Documentation: pkg.go.dev
# Functions
GetActiveLogicalConsumerStatuses gets the DebugLogicalConsumerStatus for all registered logical consumer processors in the process.
GetActiveProducerStatuses gets the DebugProducerStatus for all registered stream producers in the process.
RegisterActiveLogicalConsumerStatus registers a DebugLogicalConsumerStatus so that it is returned by GetActiveLogicalConsumerStatuses.
RegisterProducerStatus registers a DebugProducerStatus so that it is returned by GetActiveProducerStatuses.
UnregisterActiveLogicalConsumerStatus unregisters a previously registered DebugLogicalConsumerStatus.
UnregisterProducerStatus unregisters a previously registered DebugProducerStatus.
# Constants
InvalidStreamID is the zero value for StreamID corresponding to no stream.
# Structs
DebugLogicalConsumerStatus captures debug state of a logical stream consumer.