indexer

May 30, 2024

Changes in this version

type Processor

+ Shutdown func(ctx context.Context) error

May 16, 2024

Changes in this version

+ type Indexer struct

+ Datasource datasources.Datasource[T]

+ Processor Processor[T]

+ func New[T Input](processor Processor[T], datasource datasources.Datasource[T]) *Indexer[T]

+ func (i *Indexer[T]) Run(ctx context.Context) (err error)

+ func (i *Indexer[T]) Shutdown() error

+ func (i *Indexer[T]) ShutdownWithContext(ctx context.Context) (err error)

+ func (i *Indexer[T]) ShutdownWithTimeout(timeout time.Duration) error

+ type IndexerWorker interface

+ Run func(ctx context.Context) (err error)

+ Shutdown func() error

+ ShutdownWithContext func(ctx context.Context) (err error)

+ ShutdownWithTimeout func(timeout time.Duration) error

+ type Input interface

+ BlockHeader func() types.BlockHeader

+ type Processor interface

+ CurrentBlock func(ctx context.Context) (types.BlockHeader, error)

+ GetIndexedBlock func(ctx context.Context, height int64) (types.BlockHeader, error)

+ Name func() string

+ Process func(ctx context.Context, inputs []T) error

+ RevertData func(ctx context.Context, from int64) error

+ VerifyStates func(ctx context.Context) error