parser

package

v1.2.0 Latest Latest Go to latest Published: Jun 10, 2021 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/coinboxorg/blockatlas

Documentation ¶

Index ¶

func FetchBlocks(params Params, lastParsedBlock, currentBlock int64) ([]types.Block, error)
func GetBlocksIntervalToFetch(params Params, tracker models.Tracker) (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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FetchBlocks ¶

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

func GetBlocksIntervalToFetch ¶

func GetBlocksIntervalToFetch(params Params, tracker models.Tracker) (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
}

Source Files ¶

View all Source files

parser.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL