observer

Documentation

Index

• type Observer
  • func NewObserver(db *gorm.DB, cfg *util.Config, bscExecutor *bsc.Executor) *Observer
  • func (ob *Observer) Alert()
  • func (ob *Observer) DeleteBlockAndTxs(height int64) error
  • func (ob *Observer) Fetch(startHeight int64)
  • func (ob *Observer) GetCurrentBlockLog() *model.BlockLog
  • func (ob *Observer) Prune()
  • func (ob *Observer) SaveBlockAndTxs(blockLog *model.BlockLog, txLogs []interface{}) error
  • func (ob *Observer) Start()
  • func (ob *Observer) UpdateConfirmedNum(height int64) error

Types

type Observer

type Observer struct {
	DB          *gorm.DB
	Config      *util.Config
	BscExecutor *bsc.Executor
}

func NewObserver

func NewObserver(db *gorm.DB, cfg *util.Config, bscExecutor *bsc.Executor) *Observer

func (*Observer) Alert

func (ob *Observer) Alert()

func (*Observer) DeleteBlockAndTxs

func (ob *Observer) DeleteBlockAndTxs(height int64) error

func (*Observer) Fetch

func (ob *Observer) Fetch(startHeight int64)

func (*Observer) GetCurrentBlockLog

func (ob *Observer) GetCurrentBlockLog() *model.BlockLog

func (*Observer) Prune

func (ob *Observer) Prune()

func (*Observer) SaveBlockAndTxs

func (ob *Observer) SaveBlockAndTxs(blockLog *model.BlockLog, txLogs []interface{}) error

func (*Observer) Start

func (ob *Observer) Start()

func (*Observer) UpdateConfirmedNum

func (ob *Observer) UpdateConfirmedNum(height int64) error