metrics

Documentation

Index

• type BlockMetrics
  • func NewBlockMetrics() *BlockMetrics
  • func (m *BlockMetrics) MarshalLogObject(encoder zapcore.ObjectEncoder) error
• type ExecutionTime
  • func (e *ExecutionTime) Clean()
  • func (e *ExecutionTime) Finalize(t time.Duration)
  • func (e *ExecutionTime) MarshalLogObject(encoder zapcore.ObjectEncoder) error
  • func (e *ExecutionTime) String() string

Types

type BlockMetrics

type BlockMetrics struct {
	LastBlockRef bstream.BlockRef
	BlockRate    *rate

	Exec *ExecutionTime
}

func NewBlockMetrics

func NewBlockMetrics() *BlockMetrics

func (*BlockMetrics) MarshalLogObject

func (m *BlockMetrics) MarshalLogObject(encoder zapcore.ObjectEncoder) error

type ExecutionTime

type ExecutionTime struct {
	TotalExecution   time.Duration
	WaitForBlock     time.Duration
	UnmarshalBlock   time.Duration
	BlockProc        time.Duration
	Rpc              time.Duration
	StoreFlush       time.Duration
	StoreUpdatesOnly time.Duration
	StoreInsertsOnly time.Duration
	SelectQueries    time.Duration
	FullLoadTime     time.Duration

	CacheLookupTime time.Duration
	CacheWriteTime  time.Duration

	SelectQueriesDurations map[string]time.Duration
	SelectQueriesCounts    map[string]int64

	StoreSave int64
	StoreCall int64
	Count     int64
}

func (*ExecutionTime) Clean

func (e *ExecutionTime) Clean()

func (*ExecutionTime) Finalize

func (e *ExecutionTime) Finalize(t time.Duration)

func (*ExecutionTime) MarshalLogObject

func (e *ExecutionTime) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*ExecutionTime) String

func (e *ExecutionTime) String() string