metrics

Documentation

Index

• Variables
• type Stats
  • func NewNoopStats() Stats
  • func NewReqStats(logger *zap.Logger) Stats

Variables

var BlockBeginProcess = MetricSet.NewCounter("substreams_block_process_start_counter", "Counter for total block processes started, used for rate")

var BlockEndProcess = MetricSet.NewCounter("substreams_block_process_end_counter", "Counter for total block processes ended, used for rate")

var MetricSet = dmetrics.NewSet()

var SquashersEnded = MetricSet.NewCounter("substreams_total_squash_processes_closed", "Counter for Total squash processes closed, used for active processes")

var SquashersStarted = MetricSet.NewCounter("substreams_total_squash_processes_launched", "Counter for Total squash processes launched, used for rate")

var SquashesLaunched = MetricSet.NewCounter("substreams_total_squashes_launched", "Counter for Total squashes launched, used for rate")

Types

type Stats

type Stats interface {
	StartParallelProcessing()
	EndParallelProcessing()
	RecordBlock(ref bstream.BlockRef)
	RecordFlush(elapsed time.Duration)
	RecordStoreSquasherProgress(module string, blockNum uint64)
	RecordOutputCacheHit()
	RecordOutputCacheMiss()
	RecordBytesWritten(n uint64)
	RecordBytesRead(n uint64)
	Start(each time.Duration)
	Shutdown()
}

func NewNoopStats

func NewNoopStats() Stats

func NewReqStats

func NewReqStats(logger *zap.Logger) Stats