account

Documentation

Index

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

Constants

const (
	MIGRATION_TABLE_NAME = "account_schema_migrations"
	MIGRATION_DIRECOTRY  = "projection/account/migrations"
)

Variables

var (
	NewAccountsView              = account_view.NewAccountsView
	UpdateLastHandledEventHeight = (*Account).UpdateLastHandledEventHeight
)

Types

type Account

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

Account number, sequence number, balances are fetched from the latest state (regardless of current replaying height)

func NewAccount

func NewAccount(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	cosmosClient cosmosapp_interface.Client,
	config *appprojection.Config,
) *Account

func (*Account) GetEventsToListen

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

func (*Account) HandleEvents

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

func (*Account) OnInit

func (projection *Account) OnInit() error