ethereum

Documentation

Index

• type Config
  • func MustParseConfig(logger util.Logger) *Config
• type Driver
  • func NewDriver(cfg *Config, nodeClient nodeClient.Client, logger util.Logger, cursor uint64) (*Driver, error)
  • func (d *Driver) Accumulate(res interface{}) pool.Runner
  • func (d *Driver) Blockchain() string
  • func (d *Driver) Delete(object interface{}, model interface{}) error
  • func (d *Driver) FetchABI(ctx context.Context, deployments []string) (map[string]*models.Contract, error)
  • func (d *Driver) FetchMetadata(ctx context.Context, deployments []string, blockNumber uint64) (map[string]*models.Contract, error)
  • func (d *Driver) FetchSequence(blockHeight uint64) map[string]pool.Runner
  • func (d *Driver) Fetchers() map[string]pool.FeedTransformer
  • func (d *Driver) Find(object interface{}, model interface{}) ([]interface{}, error)
  • func (d *Driver) GetChainTipNumber(ctx context.Context) (uint64, error)
  • func (d *Driver) Upsert(object interface{}, model interface{}) error
  • func (d *Driver) UpsertBatch(objects []interface{}, model interface{}) error
  • func (d *Driver) Writers() []pool.FeedTransformer

Types

type Config

type Config struct {
	MaxRetries int                  `env:"HTTP_MAX_RETRIES" envDefault:"5"`
	Blockchain constants.Blockchain `env:"BLOCKCHAIN,required"`
}

Config stores configurable properties of the driver

func MustParseConfig

func MustParseConfig(logger util.Logger) *Config

MustParseConfig uses env.Parse to initialize config with environment variables

type Driver

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

Driver is the container for all ETL business logic

func NewDriver

func NewDriver(cfg *Config, nodeClient nodeClient.Client, logger util.Logger, cursor uint64) (*Driver, error)

NewDriver constructs a new Driver

func (*Driver) Accumulate

func (d *Driver) Accumulate(res interface{}) pool.Runner

Accumulate combines ABI and metadata to form complete contracts and fragments using result from the "fetch" step

func (*Driver) Blockchain

func (d *Driver) Blockchain() string

Blockchain returns the name of the blockchain

func (*Driver) Delete

func (d *Driver) Delete(object interface{}, model interface{}) error

func (*Driver) FetchABI

func (d *Driver) FetchABI(ctx context.Context, deployments []string) (map[string]*models.Contract, error)

func (*Driver) FetchMetadata

func (d *Driver) FetchMetadata(ctx context.Context, deployments []string, blockNumber uint64) (map[string]*models.Contract, error)

func (*Driver) FetchSequence

func (d *Driver) FetchSequence(blockHeight uint64) map[string]pool.Runner

FetchSequence defines the parallelizable steps in the fetch sequence

func (*Driver) Fetchers

func (d *Driver) Fetchers() map[string]pool.FeedTransformer

func (*Driver) Find

func (d *Driver) Find(object interface{}, model interface{}) ([]interface{}, error)

func (*Driver) GetChainTipNumber

func (d *Driver) GetChainTipNumber(ctx context.Context) (uint64, error)

GetChainTipNumber gets the block number of the chaintip

func (*Driver) Upsert

func (d *Driver) Upsert(object interface{}, model interface{}) error

func (*Driver) UpsertBatch

func (d *Driver) UpsertBatch(objects []interface{}, model interface{}) error

func (*Driver) Writers

func (d *Driver) Writers() []pool.FeedTransformer

Writers defines a set of parallelizable write steps for processing contracts, method fragments, event fragments