metricsutil

Documentation

Index

• type ScanMetrics
  • func NewScanMetrics(pchannel types.PChannelInfo) *ScanMetrics
  • func (m *ScanMetrics) Close()
  • func (m *ScanMetrics) NewScannerMetrics() *ScannerMetrics
  • func (m *ScanMetrics) ObserveAutoCommitTxn()
  • func (m *ScanMetrics) ObserveErrorTxn()
  • func (m *ScanMetrics) ObserveExpiredTxn()
  • func (m *ScanMetrics) ObserveFilteredMessage(msgType message.MessageType, bytes int)
  • func (m *ScanMetrics) ObserveMessage(msgType message.MessageType, bytes int)
  • func (m *ScanMetrics) ObserveTimeTickViolation(msgType message.MessageType)
  • func (m *ScanMetrics) ObserveTxn(state message.TxnState)
• type ScannerMetrics
  • func (m *ScannerMetrics) Close()
  • func (m *ScannerMetrics) UpdatePendingQueueSize(size int)
  • func (m *ScannerMetrics) UpdateTimeTickBufSize(size int)
  • func (m *ScannerMetrics) UpdateTxnBufSize(size int)
• type SegmentAssignMetrics
  • func NewSegmentAssignMetrics(pchannel string) *SegmentAssignMetrics
  • func (m *SegmentAssignMetrics) Close()
  • func (m *SegmentAssignMetrics) ObserveSegmentFlushed(policy string, bytes int64)
  • func (m *SegmentAssignMetrics) UpdateCollectionCount(cnt int)
  • func (m *SegmentAssignMetrics) UpdateGrowingSegmentState(from streamingpb.SegmentAssignmentState, to streamingpb.SegmentAssignmentState)
  • func (m *SegmentAssignMetrics) UpdatePartitionCount(cnt int)
• type TimeTickMetrics
  • func NewTimeTickMetrics(pchannel string) *TimeTickMetrics
  • func (m *TimeTickMetrics) Close()
  • func (m *TimeTickMetrics) CountAcknowledgeTimeTick(isSync bool)
  • func (m *TimeTickMetrics) CountAllocateTimeTick(ts uint64)
  • func (m *TimeTickMetrics) CountMemoryTimeTickSync(ts uint64)
  • func (m *TimeTickMetrics) CountPersistentTimeTickSync(ts uint64)
  • func (m *TimeTickMetrics) CountSyncTimeTick(isSync bool)
  • func (m *TimeTickMetrics) UpdateLastConfirmedTimeTick(ts uint64)
• type TxnMetrics
  • func NewTxnMetrics(pchannel string) *TxnMetrics
  • func (m *TxnMetrics) BeginTxn()
  • func (m *TxnMetrics) Close()
  • func (m *TxnMetrics) Finish(state message.TxnState)
• type WriteGuard
  • func (g *WriteGuard) Finish(err error)
  • func (g *WriteGuard) FinishWALImplAppend()
  • func (g *WriteGuard) StartWALImplAppend()
• type WriteMetrics
  • func NewWriteMetrics(pchannel types.PChannelInfo, walName string) *WriteMetrics
  • func (m *WriteMetrics) Close()
  • func (m *WriteMetrics) StartAppend(msgType message.MessageType, bytes int) *WriteGuard

Types

type ScanMetrics

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

func NewScanMetrics

func NewScanMetrics(pchannel types.PChannelInfo) *ScanMetrics

func (*ScanMetrics) Close

func (m *ScanMetrics) Close()

Close closes the metrics.

func (*ScanMetrics) NewScannerMetrics

func (m *ScanMetrics) NewScannerMetrics() *ScannerMetrics

NewScannerMetrics creates a new scanner metrics.

func (*ScanMetrics) ObserveAutoCommitTxn

func (m *ScanMetrics) ObserveAutoCommitTxn()

ObserveAutoCommitTxn observes the auto commit txn.

func (*ScanMetrics) ObserveErrorTxn

func (m *ScanMetrics) ObserveErrorTxn()

ObserveErrorTxn observes the error txn.

func (*ScanMetrics) ObserveExpiredTxn

func (m *ScanMetrics) ObserveExpiredTxn()

ObserveExpiredTxn observes the expired txn.

func (*ScanMetrics) ObserveFilteredMessage

func (m *ScanMetrics) ObserveFilteredMessage(msgType message.MessageType, bytes int)

ObserveFilteredMessage observes the filtered message.

func (*ScanMetrics) ObserveMessage

func (m *ScanMetrics) ObserveMessage(msgType message.MessageType, bytes int)

ObserveMessage observes the message.

func (*ScanMetrics) ObserveTimeTickViolation

func (m *ScanMetrics) ObserveTimeTickViolation(msgType message.MessageType)

ObserveTimeTickViolation observes the time tick violation.

func (*ScanMetrics) ObserveTxn

func (m *ScanMetrics) ObserveTxn(state message.TxnState)

ObserveTxn observes the txn.

type ScannerMetrics

type ScannerMetrics struct {
	*ScanMetrics
	// contains filtered or unexported fields
}

func (*ScannerMetrics) Close

func (m *ScannerMetrics) Close()

func (*ScannerMetrics) UpdatePendingQueueSize

func (m *ScannerMetrics) UpdatePendingQueueSize(size int)

func (*ScannerMetrics) UpdateTimeTickBufSize

func (m *ScannerMetrics) UpdateTimeTickBufSize(size int)

func (*ScannerMetrics) UpdateTxnBufSize

func (m *ScannerMetrics) UpdateTxnBufSize(size int)

type SegmentAssignMetrics

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

SegmentAssignMetrics is the metrics of the segment assignment.

func NewSegmentAssignMetrics

func NewSegmentAssignMetrics(pchannel string) *SegmentAssignMetrics

func (*SegmentAssignMetrics) Close

func (m *SegmentAssignMetrics) Close()

func (*SegmentAssignMetrics) ObserveSegmentFlushed

func (m *SegmentAssignMetrics) ObserveSegmentFlushed(policy string, bytes int64)

func (*SegmentAssignMetrics) UpdateCollectionCount

func (m *SegmentAssignMetrics) UpdateCollectionCount(cnt int)

func (*SegmentAssignMetrics) UpdateGrowingSegmentState

func (m *SegmentAssignMetrics) UpdateGrowingSegmentState(from streamingpb.SegmentAssignmentState, to streamingpb.SegmentAssignmentState)

UpdateGrowingSegmentState updates the metrics of the segment assignment state.

func (*SegmentAssignMetrics) UpdatePartitionCount

func (m *SegmentAssignMetrics) UpdatePartitionCount(cnt int)

type TimeTickMetrics

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

TimeTickMetrics is the metrics for time tick.

func NewTimeTickMetrics

func NewTimeTickMetrics(pchannel string) *TimeTickMetrics

NewTimeTickMetrics creates a new time tick metrics.

func (*TimeTickMetrics) Close

func (m *TimeTickMetrics) Close()

func (*TimeTickMetrics) CountAcknowledgeTimeTick

func (m *TimeTickMetrics) CountAcknowledgeTimeTick(isSync bool)

func (*TimeTickMetrics) CountAllocateTimeTick

func (m *TimeTickMetrics) CountAllocateTimeTick(ts uint64)

func (*TimeTickMetrics) CountMemoryTimeTickSync

func (m *TimeTickMetrics) CountMemoryTimeTickSync(ts uint64)

func (*TimeTickMetrics) CountPersistentTimeTickSync

func (m *TimeTickMetrics) CountPersistentTimeTickSync(ts uint64)

func (*TimeTickMetrics) CountSyncTimeTick

func (m *TimeTickMetrics) CountSyncTimeTick(isSync bool)

func (*TimeTickMetrics) UpdateLastConfirmedTimeTick

func (m *TimeTickMetrics) UpdateLastConfirmedTimeTick(ts uint64)

type TxnMetrics

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

func NewTxnMetrics

func NewTxnMetrics(pchannel string) *TxnMetrics

func (*TxnMetrics) BeginTxn

func (m *TxnMetrics) BeginTxn()

func (*TxnMetrics) Close

func (m *TxnMetrics) Close()

func (*TxnMetrics) Finish

func (m *TxnMetrics) Finish(state message.TxnState)

type WriteGuard

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

func (*WriteGuard) Finish

func (g *WriteGuard) Finish(err error)

func (*WriteGuard) FinishWALImplAppend

func (g *WriteGuard) FinishWALImplAppend()

func (*WriteGuard) StartWALImplAppend

func (g *WriteGuard) StartWALImplAppend()

type WriteMetrics

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

func NewWriteMetrics

func NewWriteMetrics(pchannel types.PChannelInfo, walName string) *WriteMetrics

NewWriteMetrics creates a new WriteMetrics.

func (*WriteMetrics) Close

func (m *WriteMetrics) Close()

func (*WriteMetrics) StartAppend

func (m *WriteMetrics) StartAppend(msgType message.MessageType, bytes int) *WriteGuard