telemetry

Documentation

Index

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

Functions

func UnregisterLogStreamMetrics

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

Types

type LogStreamMetrics

type LogStreamMetrics struct {
	AppendLogs             int64
	AppendBytes            int64
	AppendDuration         int64
	AppendOperations       int64
	AppendPreparationMicro int64
	AppendBatchCommitGap   int64

	SequencerOperationDuration  int64
	SequencerFanoutDuration     int64
	SequencerOperations         int64
	SequencerInflightOperations int64

	WriterOperationDuration  int64
	WriterOperations         int64
	WriterInflightOperations int64

	CommitterOperationDuration int64
	CommitterOperations        int64
	CommitterLogs              int64

	ReplicateClientOperationDuration  int64
	ReplicateClientOperations         int64
	ReplicateClientInflightOperations int64

	ReplicateServerOperations int64

	ReplicateLogs             int64
	ReplicateBytes            int64
	ReplicateDuration         int64
	ReplicateOperations       int64
	ReplicatePreparationMicro int64
}

func RegisterLogStreamMetrics

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

type Metrics

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

func RegisterMetrics

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