impl

Documentation

Index

• type EventProcessor
  • func New(parser parsing.SQLValidator, executor executor.Executor, ...) (*EventProcessor, error)
  • func (ep *EventProcessor) GetLastExecutedBlockNumber() int64
  • func (ep *EventProcessor) Start() error
  • func (ep *EventProcessor) Stop()

Types

type EventProcessor

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

EventProcessor processes new events detected by an event feed.

func New

func New(
	parser parsing.SQLValidator,
	executor executor.Executor,
	ef eventfeed.EventFeed,
	chainID tableland.ChainID,
	opts ...eventprocessor.Option,
) (*EventProcessor, error)

New returns a new EventProcessor.

func (*EventProcessor) GetLastExecutedBlockNumber

func (ep *EventProcessor) GetLastExecutedBlockNumber() int64

GetLastExecutedBlockNumber returns the last executed block number.

func (*EventProcessor) Start

func (ep *EventProcessor) Start() error

Start starts processing new events from the last processed height.

func (*EventProcessor) Stop

func (ep *EventProcessor) Stop()

Stop stops processing new events.