indexer

Documentation

Index

• func Flags(v *viper.Viper, f *pflag.FlagSet)
• func NewIndexerListenerError(err error) error
• type Configuration
  • func NewConfigurationFromViper(v *viper.Viper) *Configuration
• type Indexer
  • func New(listener events.HeadListener, aggregator data.Aggregator, ...) *Indexer
  • func (indexer *Indexer) Start(ctx context.Context) error
  • func (indexer *Indexer) Stop()

Functions

func Flags

func Flags(v *viper.Viper, f *pflag.FlagSet)

func NewIndexerListenerError

func NewIndexerListenerError(err error) error

Types

type Configuration

type Configuration struct {
	BeaconAPIURL               string
	RelayAPIURLs               []string
	DatabaseMigrationSourceURL string
	DatabaseConnURL            string
}

func NewConfigurationFromViper

func NewConfigurationFromViper(v *viper.Viper) *Configuration

type Indexer

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

func New

func New(listener events.HeadListener,
	aggregator data.Aggregator,
	preprocessor *data.Preprocessor,
	storage storage.Manager,
) *Indexer

func (*Indexer) Start

func (indexer *Indexer) Start(ctx context.Context) error

func (*Indexer) Stop

func (indexer *Indexer) Stop()