Versions in this module Expand all Collapse all v0 v0.0.1 May 1, 2023 v0.0.0 Apr 28, 2023 Changes in this version + type Config struct + Blockchain constants.Blockchain + MaxRetries int + func MustParseConfig(logger util.Logger) *Config + type Driver struct + 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
Go to main page