indexer

Documentation

Index

• Variables
• type Config
  • func NewConfig(v *viper.Viper) (*Config, error)
• type Indexer
  • func NewIndexer(params Params) *Indexer
  • func (i *Indexer) SyncBlocks(ctx context.Context)
  • func (i *Indexer) SyncStore(ctx context.Context)
• type Params

Variables

var Module = module.Module{
	{Constructor: NewConfig},
	{Constructor: NewIndexer},
}

Module indexer worker

Types

type Config

type Config struct {
	Addresses   []string
	ChainSize   int
	ScanTimeout time.Duration
	SyncTimeout time.Duration
}

Config is worker settings

func NewConfig

func NewConfig(v *viper.Viper) (*Config, error)

type Indexer

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

Indexer - is a worker, that find transactions in block-chain

func NewIndexer

func NewIndexer(params Params) *Indexer

NewIndexer worker

func (*Indexer) SyncBlocks

func (i *Indexer) SyncBlocks(ctx context.Context)

SyncBlocks to sync blocks and transactions:

func (*Indexer) SyncStore

func (i *Indexer) SyncStore(ctx context.Context)

SyncStore receive messages from channel and try to sync with store

type Params

type Params struct {
	dig.In

	Client *eth.Client
	Config *Config
	Logger *zap.SugaredLogger
	Store  *store.Store
	Viper  *viper.Viper
}

Params to create new worker