eventhandler

package

v1.7.39 Latest Latest Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Handler interface {
	GetLastHandledEventHeight() (*int64, error)

	HandleEvents(blockHeight int64, events []event.Event) error

	Id() string
}

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

func NewProjectionHandler(logger applogger.Logger, projection projection_entity.Projection) *ProjectionHandler

func (handler *ProjectionHandler) GetLastHandledEventHeight() (*int64, error)

func (handler *ProjectionHandler) HandleEvents(blockHeight int64, events []event.Event) error

func (handler *ProjectionHandler) Id() string

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

RDbEventStoreHandler is an event handler which persist the event to event store

func NewRDbEventStoreHandler(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	eventRegistry *event.Registry,
) *RDbEventStoreHandler

func (handler *RDbEventStoreHandler) GetLastHandledEventHeight() (*int64, error)

func (handler *RDbEventStoreHandler) HandleEvents(blockHeight int64, events []event.Event) error

func (handler *RDbEventStoreHandler) Id() string