eventhandler

Documentation

Index

• type Handler
• type ProjectionHandler
  • 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
  • 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

Types

type Handler

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

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

	Id() string
}

type ProjectionHandler

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

func NewProjectionHandler

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

func (*ProjectionHandler) GetLastHandledEventHeight

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

func (*ProjectionHandler) HandleEvents

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

func (*ProjectionHandler) Id

func (handler *ProjectionHandler) Id() string

type RDbEventStoreHandler

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

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

func NewRDbEventStoreHandler

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

func (*RDbEventStoreHandler) GetLastHandledEventHeight

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

func (*RDbEventStoreHandler) HandleEvents

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

func (*RDbEventStoreHandler) Id

func (handler *RDbEventStoreHandler) Id() string