Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var BlockProcess = Metricset.NewCounter("substreams_block_process_start_counter", "Counter for total block processes started, used for rate")
View Source
var Metricset = dmetrics.NewSet()
View Source
var SquashCount = Metricset.NewCounter("substreams_total_squashes_launched", "Counter for Total squashes launched, used for rate")
View Source
var SquashersEnded = Metricset.NewCounter("substreams_total_squash_processes_closed", "Counter for Total squash processes closed, used for active processes")
View Source
var SquashersStarted = Metricset.NewCounter("substreams_total_squash_processes_launched", "Counter for Total squash processes launched, used for rate")
Functions ¶
This section is empty.
Types ¶
type Stats ¶
type Stats interface {
StartBackProcessing()
EndBackProcessing()
RecordBlock(ref bstream.BlockRef)
RecordFlush(elapsed time.Duration)
RecordStoreSquasherProgress(module string, blockNum uint64)
RecordOutputCacheHit()
RecordOutputCacheMiss()
Start(each time.Duration)
Shutdown()
}
func NewNoopStats ¶
func NewNoopStats() Stats
func NewReqStats ¶
Source Files
Click to show internal directories.
Click to hide internal directories.