metricsutil

package
v0.10.3-0...-e09f431 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL