fetcher

Documentation

Index

• type Config
• type Fetcher
  • func New(conf Config) (*Fetcher, error)
  • func (f *Fetcher) Start()
  • func (f *Fetcher) Stop()
• type ProcessorFunc

Types

type Config

type Config struct {
	Host       string
	APIToken   string
	RPS        int
	StartRound *uint64
	Processor  ProcessorFunc
}

Config represents a configuration

type Fetcher

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

Fetcher handles block fetching from algod or indexer

func New

func New(conf Config) (*Fetcher, error)

New creates a new fetcher

func (*Fetcher) Start

func (f *Fetcher) Start()

Start starts fetching data from the blockchain

func (*Fetcher) Stop

func (f *Fetcher) Stop()

Stop stops the fetcher

type ProcessorFunc

type ProcessorFunc func(*models.Block)

ProcessorFunc represents a processor function that consume blocks