Documentation
¶
Index ¶
- type MetricsBus
- func (m *MetricsBus) AppInfo() basemetrics.Counter
- func (m *MetricsBus) AppInitDuration() basemetrics.Gauge
- func (m *MetricsBus) BatchCollectTime() basemetrics.Histogram
- func (m *MetricsBus) BatchExecuteInvokeTime() basemetrics.Histogram
- func (m *MetricsBus) BatchItemsCount() basemetrics.Histogram
- func (m *MetricsBus) BatchSize() basemetrics.Histogram
- func (m *MetricsBus) BatchSizeEstimatedDiff() basemetrics.Histogram
- func (m *MetricsBus) BlockTxCount() basemetrics.Histogram
- func (m *MetricsBus) CollectorProcessBlockNum() basemetrics.Gauge
- func (m *MetricsBus) CreateChild(labels ...basemetrics.Label) metrics.Metrics
- func (m *MetricsBus) HeightLedgerBlocks() basemetrics.Gauge
- func (m *MetricsBus) TotalBatchExecuted() basemetrics.Counter
- func (m *MetricsBus) TotalBatchSize() basemetrics.Counter
- func (m *MetricsBus) TotalExecutedTx() basemetrics.Counter
- func (m *MetricsBus) TotalOrderingReqSizeExceeded() basemetrics.Counter
- func (m *MetricsBus) TotalRobotStarted() basemetrics.Counter
- func (m *MetricsBus) TotalRobotStopped() basemetrics.Counter
- func (m *MetricsBus) TotalSrcChErrors() basemetrics.Counter
- func (m *MetricsBus) TxWaitingCount() basemetrics.Gauge
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetricsBus ¶
type MetricsBus struct {
// contains filtered or unexported fields
}
MetricsBus is a prometheus implementation of metrics bus
func NewMetrics ¶
func NewMetrics(ctx context.Context, mPrefix string) (*MetricsBus, error)
NewMetrics creates a new prometheus metrics bus
func (*MetricsBus) AppInfo ¶
func (m *MetricsBus) AppInfo() basemetrics.Counter
AppInfo returns a counter of application info
func (*MetricsBus) AppInitDuration ¶
func (m *MetricsBus) AppInitDuration() basemetrics.Gauge
AppInitDuration returns a gauge of application init duration
func (*MetricsBus) BatchCollectTime ¶
func (m *MetricsBus) BatchCollectTime() basemetrics.Histogram
BatchCollectTime returns a histogram of batch collect time
func (*MetricsBus) BatchExecuteInvokeTime ¶
func (m *MetricsBus) BatchExecuteInvokeTime() basemetrics.Histogram
BatchExecuteInvokeTime returns a histogram of batch execute invoke time
func (*MetricsBus) BatchItemsCount ¶
func (m *MetricsBus) BatchItemsCount() basemetrics.Histogram
BatchItemsCount returns a histogram of batch items count
func (*MetricsBus) BatchSize ¶
func (m *MetricsBus) BatchSize() basemetrics.Histogram
BatchSize returns a histogram of batch size
func (*MetricsBus) BatchSizeEstimatedDiff ¶
func (m *MetricsBus) BatchSizeEstimatedDiff() basemetrics.Histogram
BatchSizeEstimatedDiff returns a histogram of batch size estimated diff
func (*MetricsBus) BlockTxCount ¶
func (m *MetricsBus) BlockTxCount() basemetrics.Histogram
BlockTxCount returns a histogram of block tx count
func (*MetricsBus) CollectorProcessBlockNum ¶
func (m *MetricsBus) CollectorProcessBlockNum() basemetrics.Gauge
CollectorProcessBlockNum returns a gauge of collector process block num
func (*MetricsBus) CreateChild ¶
func (m *MetricsBus) CreateChild(labels ...basemetrics.Label) metrics.Metrics
CreateChild creates a child metrics bus
func (*MetricsBus) HeightLedgerBlocks ¶
func (m *MetricsBus) HeightLedgerBlocks() basemetrics.Gauge
HeightLedgerBlocks returns a gauge of height ledger blocks
func (*MetricsBus) TotalBatchExecuted ¶
func (m *MetricsBus) TotalBatchExecuted() basemetrics.Counter
TotalBatchExecuted returns a counter of total executed batches
func (*MetricsBus) TotalBatchSize ¶
func (m *MetricsBus) TotalBatchSize() basemetrics.Counter
TotalBatchSize returns a counter of total batch size
func (*MetricsBus) TotalExecutedTx ¶
func (m *MetricsBus) TotalExecutedTx() basemetrics.Counter
TotalExecutedTx returns a counter of total executed transactions
func (*MetricsBus) TotalOrderingReqSizeExceeded ¶
func (m *MetricsBus) TotalOrderingReqSizeExceeded() basemetrics.Counter
TotalOrderingReqSizeExceeded returns a counter of total ordering request size exceeded
func (*MetricsBus) TotalRobotStarted ¶
func (m *MetricsBus) TotalRobotStarted() basemetrics.Counter
TotalRobotStarted returns a counter of total started robots
func (*MetricsBus) TotalRobotStopped ¶
func (m *MetricsBus) TotalRobotStopped() basemetrics.Counter
TotalRobotStopped returns a counter of total stopped robots
func (*MetricsBus) TotalSrcChErrors ¶
func (m *MetricsBus) TotalSrcChErrors() basemetrics.Counter
TotalSrcChErrors returns a counter of total source channel errors
func (*MetricsBus) TxWaitingCount ¶
func (m *MetricsBus) TxWaitingCount() basemetrics.Gauge
TxWaitingCount returns a gauge of transaction waiting count
Source Files