metrics

Documentation

Index

• Variables
• func RegisterMetricSet(zlog *zap.Logger)
• type Config
• type Stats
  • func NewReqStats(config *Config, logger *zap.Logger) *Stats
  • func (s *Stats) AggregatedModulesStats() []*pbsubstreamsrpc.ModuleStats
  • func (s *Stats) JobsStats() []*pbsubstreamsrpc.Job
  • func (s *Stats) LocalModulesStats() []*pbssinternal.ModuleStats
  • func (s *Stats) LogAndClose()
  • func (s *Stats) RecordBlock(ref bstream.BlockRef)
  • func (s *Stats) RecordEndSubrequest(jobIdx uint64)
  • func (s *Stats) RecordInitializationComplete()
  • func (s *Stats) RecordJobUpdate(jobIdx uint64, upd *pbssinternal.Update)
  • func (s *Stats) RecordModuleMergeComplete(module string)
  • func (s *Stats) RecordModuleMerging(module string)
  • func (s *Stats) RecordModuleWasmBlock(moduleName string, elapsed time.Duration)
  • func (s *Stats) RecordModuleWasmExternalCall(moduleName string, extension string, elapsed time.Duration)
  • func (s *Stats) RecordModuleWasmStoreDeletePrefix(moduleName string, sizeBytes uint64, elapsed time.Duration)
  • func (s *Stats) RecordModuleWasmStoreRead(moduleName string, elapsed time.Duration)
  • func (s *Stats) RecordModuleWasmStoreWrite(moduleName string, sizeBytes uint64, elapsed time.Duration)
  • func (s *Stats) RecordNewSubrequest(stage uint32, startBlock, stopBlock uint64) (id uint64)
  • func (s *Stats) RecordStages(stages []*pbsubstreamsrpc.Stage)
  • func (s *Stats) RemoteBytesConsumption() (read uint64, written uint64)
  • func (s *Stats) Stage(module string) (uint32, *pbsubstreamsrpc.Stage)
  • func (s *Stats) Stages() []*pbsubstreamsrpc.Stage

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 struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewReqStats

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

func (*Stats) AggregatedModulesStats

func (s *Stats) AggregatedModulesStats() []*pbsubstreamsrpc.ModuleStats

func (*Stats) JobsStats

func (s *Stats) JobsStats() []*pbsubstreamsrpc.Job

func (*Stats) LocalModulesStats

func (s *Stats) LocalModulesStats() []*pbssinternal.ModuleStats

func (*Stats) LogAndClose

func (s *Stats) LogAndClose()

func (*Stats) RecordBlock

func (s *Stats) RecordBlock(ref bstream.BlockRef)

func (*Stats) RecordEndSubrequest

func (s *Stats) RecordEndSubrequest(jobIdx uint64)

func (*Stats) RecordInitializationComplete

func (s *Stats) RecordInitializationComplete()

func (*Stats) RecordJobUpdate

func (s *Stats) RecordJobUpdate(jobIdx uint64, upd *pbssinternal.Update)

RecordJobUpdate will be called each time a job sends an update message

func (*Stats) RecordModuleMergeComplete

func (s *Stats) RecordModuleMergeComplete(module string)

func (*Stats) RecordModuleMerging

func (s *Stats) RecordModuleMerging(module string)

func (*Stats) RecordModuleWasmBlock

func (s *Stats) RecordModuleWasmBlock(moduleName string, elapsed time.Duration)

RecordModuleWasmBlock should be called once per module per block. `elapsed` is the time spent in executing the WASM code, including store and extension calls

func (*Stats) RecordModuleWasmExternalCall

func (s *Stats) RecordModuleWasmExternalCall(moduleName string, extension string, elapsed time.Duration)

RecordModuleWasmExternalCall can be called multiple times per module per block, for each external module call (ex: eth_call). `elapsed` is the time spent in executing that call.

func (*Stats) RecordModuleWasmStoreDeletePrefix

func (s *Stats) RecordModuleWasmStoreDeletePrefix(moduleName string, sizeBytes uint64, elapsed time.Duration)

RecordModuleWasmStoreDeletePrefix can be called multiple times per module per block `elapsed` is the time spent in executing that operation.

func (*Stats) RecordModuleWasmStoreRead

func (s *Stats) RecordModuleWasmStoreRead(moduleName string, elapsed time.Duration)

RecordModuleWasmStoreRead can be called multiple times per module per block `elapsed` is the time spent in executing that operation.

func (*Stats) RecordModuleWasmStoreWrite

func (s *Stats) RecordModuleWasmStoreWrite(moduleName string, sizeBytes uint64, elapsed time.Duration)

RecordModuleWasmStoreWrite can be called multiple times per module per block `elapsed` is the time spent in executing that operation.

func (*Stats) RecordNewSubrequest

func (s *Stats) RecordNewSubrequest(stage uint32, startBlock, stopBlock uint64) (id uint64)

func (*Stats) RecordStages

func (s *Stats) RecordStages(stages []*pbsubstreamsrpc.Stage)

func (*Stats) RemoteBytesConsumption

func (s *Stats) RemoteBytesConsumption() (read uint64, written uint64)

func (*Stats) Stage

func (s *Stats) Stage(module string) (uint32, *pbsubstreamsrpc.Stage)

func (*Stats) Stages

func (s *Stats) Stages() []*pbsubstreamsrpc.Stage