parser

Documentation

Index

• func FetchBlocks(params Params, lastParsedBlock, currentBlock int64) ([]types.Block, error)
• func GetBlocksIntervalToFetch(params Params) (int64, int64, error)
• func GetInterval(value int, minInterval, maxInterval time.Duration) time.Duration
• func GetNextBlocksToParse(lastParsedBlock int64, currentBlock int64, maxBlocks int64) (int64, int64, error)
• func RunParser(params Params, ctx context.Context)
• func SaveLastParsedBlock(params Params, blocks []types.Block) error
• type GetBlockByNumber
• type Params

Functions

func FetchBlocks

func FetchBlocks(params Params, lastParsedBlock, currentBlock int64) ([]types.Block, error)

func GetBlocksIntervalToFetch

func GetBlocksIntervalToFetch(params Params) (int64, int64, error)

func GetInterval

func GetInterval(value int, minInterval, maxInterval time.Duration) time.Duration

func GetNextBlocksToParse

func GetNextBlocksToParse(lastParsedBlock int64, currentBlock int64, maxBlocks int64) (int64, int64, error)

func RunParser

func RunParser(params Params, ctx context.Context)

func SaveLastParsedBlock

func SaveLastParsedBlock(params Params, blocks []types.Block) error

Types

type GetBlockByNumber

type GetBlockByNumber func(num int64) (*types.Block, error)

type Params

type Params struct {
	Api                                       blockatlas.BlockAPI
	TransactionsExchange                      mq.Exchange
	ParsingBlocksInterval, FetchBlocksTimeout time.Duration
	MaxBlocks                                 int64
	StopChannel                               chan<- struct{}
	Database                                  *db.Instance
}