receiver

type Module ¶

type Module struct {
	modules.BaseModule
	// contains filtered or unexported fields
}

Module - runs through a chain aiming to catch up the head

		and identifies whether the block fits in sequence or signals of rollback.

	|----------------|
	|                | -- types.BlockData -> BlocksOutput
	|     MODULE     |
	|    Receiver    | -- struct{}        -> RollbackOutput
	|                | <- storage.State   -- RollbackInput
    |----------------|

func NewModule(cfg config.Indexer, api node.Api, ws *http.HTTP, state *storage.State) Module

func (r *Module) Close() error

func (r *Module) Level() (types.Level, []byte)

func (r *Module) Start(ctx context.Context)

type Worker ¶ added in v1.13.0

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

func NewWorker(api node.Api, log zerolog.Logger, blocks chan types.BlockData, capacity int) *Worker

func (worker *Worker) Capacity() int

func (worker *Worker) Do(ctx context.Context, level types.Level, appVersion uint64)

func (worker *Worker) SetLiveMode(liveMode bool)