account_message

Documentation

Index

• Constants
• Variables
• type AccountMessage
  • func NewAccountMessage(logger applogger.Logger, rdbConn rdb.Conn, accountAddressPrefix string, ...) *AccountMessage
  • func (_ *AccountMessage) GetEventsToListen() []string
  • func (projection *AccountMessage) HandleEvents(height int64, events []event_entity.Event) error
  • func (projection *AccountMessage) OnInit() error

Constants

const (
	MIGRATION_TABLE_NAME = "account_message_schema_migrations"
	MIGRATION_DIRECOTRY  = "projection/account_message/migrations"
)

Variables

var (
	NewAccountMessages           = view.NewAccountMessagesView
	NewAccountMessagesTotal      = view.NewAccountMessagesTotalView
	UpdateLastHandledEventHeight = (*AccountMessage).UpdateLastHandledEventHeight
)

Types

type AccountMessage

type AccountMessage struct {
	*rdbprojectionbase.Base
	// contains filtered or unexported fields
}

func NewAccountMessage

func NewAccountMessage(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	accountAddressPrefix string,
	config *appprojection.Config,
) *AccountMessage

func (*AccountMessage) GetEventsToListen

func (_ *AccountMessage) GetEventsToListen() []string

func (*AccountMessage) HandleEvents

func (projection *AccountMessage) HandleEvents(height int64, events []event_entity.Event) error

func (*AccountMessage) OnInit

func (projection *AccountMessage) OnInit() error