poller

Documentation

Index

• func FetchBlocks(client *ethrpc.EthRPC, start, end int) ([]*ethrpc.Block, error)
• type Blocks
  • func NewBlocks(startBlock int, client *ethrpc.EthRPC, backend StatsBackend, ...) *Blocks
  • func (b *Blocks) Run()
• type StatsBackend

Functions

func FetchBlocks

func FetchBlocks(client *ethrpc.EthRPC, start, end int) ([]*ethrpc.Block, error)

Types

type Blocks

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

func NewBlocks

func NewBlocks(startBlock int, client *ethrpc.EthRPC, backend StatsBackend, logger logrus.Ext1FieldLogger) *Blocks

func (*Blocks) Run

func (b *Blocks) Run()

type StatsBackend

type StatsBackend interface {
	RecordBlocks(blocks ...*ethrpc.Block)
}