metrics

Documentation

Index

• type AverageDuration
  • func (p *AverageDuration) Add(duration time.Duration)
  • func (p *AverageDuration) Raw() int64
  • func (p *AverageDuration) Reset()
  • func (p *AverageDuration) String() string
• type Provider
  • func New() *Provider
  • func (p *Provider) GetIndexingTime() string
  • func (p *Provider) GetInvalidBlocks() int64
  • func (p *Provider) GetLatestBLock() int64
  • func (p *Provider) GetProcessingTime() string
  • func (p *Provider) GetRawIndexingTime() int64
  • func (p *Provider) GetRawProcessingTime() int64
  • func (p *Provider) GetRawScrapingTime() int64
  • func (p *Provider) GetReorgedBlocks() int64
  • func (p *Provider) GetScrapingTime() string
  • func (p *Provider) GetTodoLength() int64
  • func (p *Provider) RecordIndexingTime(duration time.Duration)
  • func (p *Provider) RecordInvalidBlock()
  • func (p *Provider) RecordLatestBlock(block int64)
  • func (p *Provider) RecordProcessingTime(duration time.Duration)
  • func (p *Provider) RecordReorgedBlock()
  • func (p *Provider) RecordScrapingTime(duration time.Duration)
  • func (p *Provider) RecordTodoLength(len int64)
  • func (p *Provider) Reset()

Types

type AverageDuration

type AverageDuration struct {
	RollingAvg   int64
	Measurements int64
}

func (*AverageDuration) Add

func (p *AverageDuration) Add(duration time.Duration)

func (*AverageDuration) Raw

func (p *AverageDuration) Raw() int64

func (*AverageDuration) Reset

func (p *AverageDuration) Reset()

func (*AverageDuration) String

func (p *AverageDuration) String() string

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func New

func New() *Provider

func (*Provider) GetIndexingTime

func (p *Provider) GetIndexingTime() string

func (*Provider) GetInvalidBlocks

func (p *Provider) GetInvalidBlocks() int64

func (*Provider) GetLatestBLock

func (p *Provider) GetLatestBLock() int64

func (*Provider) GetProcessingTime

func (p *Provider) GetProcessingTime() string

func (*Provider) GetRawIndexingTime

func (p *Provider) GetRawIndexingTime() int64

func (*Provider) GetRawProcessingTime

func (p *Provider) GetRawProcessingTime() int64

func (*Provider) GetRawScrapingTime

func (p *Provider) GetRawScrapingTime() int64

func (*Provider) GetReorgedBlocks

func (p *Provider) GetReorgedBlocks() int64

func (*Provider) GetScrapingTime

func (p *Provider) GetScrapingTime() string

func (*Provider) GetTodoLength

func (p *Provider) GetTodoLength() int64

func (*Provider) RecordIndexingTime

func (p *Provider) RecordIndexingTime(duration time.Duration)

func (*Provider) RecordInvalidBlock

func (p *Provider) RecordInvalidBlock()

func (*Provider) RecordLatestBlock

func (p *Provider) RecordLatestBlock(block int64)

func (*Provider) RecordProcessingTime

func (p *Provider) RecordProcessingTime(duration time.Duration)

func (*Provider) RecordReorgedBlock

func (p *Provider) RecordReorgedBlock()

func (*Provider) RecordScrapingTime

func (p *Provider) RecordScrapingTime(duration time.Duration)

func (*Provider) RecordTodoLength

func (p *Provider) RecordTodoLength(len int64)

func (*Provider) Reset

func (p *Provider) Reset()