Categorygithub.com/cockroachdb/cockroachpkgrepstreamstreampb
package
25.1.0+incompatible
Repository: https://github.com/cockroachdb/cockroach.git
Documentation: pkg.go.dev
Overview
Versions
3
Dependencies
5
Dependents
34
Files
330 SLOC

# 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

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
InvalidStreamID is the zero value for StreamID corresponding to no stream.
No description provided by the author
No description provided by the author
No description provided by the author

# Structs

No description provided by the author
DebugLogicalConsumerStatus captures debug state of a logical stream consumer.
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author
No description provided by the author
StreamID is the ID of a replication stream.