metrics

Documentation

Index

• Variables
• func RegisterMetricSet(zlog *zap.Logger)
• type Config
• type Stats
  • func NewNoopStats() Stats
  • func NewReqStats(config *Config, logger *zap.Logger) Stats

Variables

var AppReadiness = MetricSet.NewAppReadiness("firehose")

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")

Functions

func RegisterMetricSet

func RegisterMetricSet(zlog *zap.Logger)

Types

type Config

type Config struct {
	UserID           string
	ApiKeyID         string
	OutputModule     string
	OutputModuleHash string
	ProductionMode   bool
	Tier2            bool
}

type Stats

type Stats interface {
	RecordParallelDuration(elapsed time.Duration)
	RecordWasmExtDuration(wasmExtName string, elapsed time.Duration)
	RecordModuleExecDuration(elapsed time.Duration)
	RecordBlock(ref bstream.BlockRef)
	LogAndClose()
}

func NewNoopStats

func NewNoopStats() Stats

func NewReqStats

func NewReqStats(config *Config, logger *zap.Logger) Stats