telemetry

Documentation

Index

• func UnregisterLogStreamMetrics(m *Metrics, lsid types.LogStreamID)
• type LogStreamMetrics
  • func RegisterLogStreamMetrics(m *Metrics, tpid types.TopicID, lsid types.LogStreamID) (*LogStreamMetrics, error)
• type Metrics
  • func RegisterMetrics(meter metric.Meter) (m *Metrics, err error)

Functions

func UnregisterLogStreamMetrics

func UnregisterLogStreamMetrics(m *Metrics, lsid types.LogStreamID)

Types

type LogStreamMetrics

type LogStreamMetrics struct {
	AppendLogs             atomic.Int64
	AppendBytes            atomic.Int64
	AppendDuration         atomic.Int64
	AppendOperations       atomic.Int64
	AppendPreparationMicro atomic.Int64
	AppendBatchCommitGap   atomic.Int64

	SequencerOperationDuration  atomic.Int64
	SequencerFanoutDuration     atomic.Int64
	SequencerOperations         atomic.Int64
	SequencerInflightOperations atomic.Int64

	WriterOperationDuration  atomic.Int64
	WriterOperations         atomic.Int64
	WriterInflightOperations atomic.Int64

	CommitterOperationDuration atomic.Int64
	CommitterOperations        atomic.Int64
	CommitterLogs              atomic.Int64

	ReplicateClientOperationDuration  atomic.Int64
	ReplicateClientOperations         atomic.Int64
	ReplicateClientInflightOperations atomic.Int64

	ReplicateServerOperations atomic.Int64

	ReplicateLogs             atomic.Int64
	ReplicateBytes            atomic.Int64
	ReplicateDuration         atomic.Int64
	ReplicateOperations       atomic.Int64
	ReplicatePreparationMicro atomic.Int64
	// contains filtered or unexported fields
}

func RegisterLogStreamMetrics

func RegisterLogStreamMetrics(m *Metrics, tpid types.TopicID, lsid types.LogStreamID) (*LogStreamMetrics, error)

type Metrics

type Metrics struct {
	// contains filtered or unexported fields
}

func RegisterMetrics

func RegisterMetrics(meter metric.Meter) (m *Metrics, err error)