observer

Documentation

Index

• type Config
• type Dependencies
• type Observer
  • func NewObserver(c *Config, d *Dependencies) *Observer
  • func (o *Observer) Alert()
  • func (ob *Observer) DeleteBlock(height int64) error
  • func (ob *Observer) GetCurrentBlockLog() (*block.Log, error)
  • func (ob *Observer) Prune()
  • func (ob *Observer) RecordBlockAndTxs(b *common.Block) error
  • func (o *Observer) Start()
  • func (ob *Observer) Update()

Types

type Config

type Config struct {
	StartHeight        int64
	ConfirmNum         int64
	FetchInterval      time.Duration
	BlockUpdateTimeout time.Duration
}

type Dependencies

type Dependencies struct {
	DB       *gorm.DB
	Recorder recorder.IRecorder
}

type Observer

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

func NewObserver

func NewObserver(c *Config, d *Dependencies) *Observer

NewObserver returns the observer instance

func (*Observer) Alert

func (o *Observer) Alert()

Alert sends alerts to tg group if there is no new block fetched in a specific time

func (*Observer) DeleteBlock

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

func (*Observer) GetCurrentBlockLog

func (ob *Observer) GetCurrentBlockLog() (*block.Log, error)

GetCurrentBlockLog returns the highest block log

func (*Observer) Prune

func (ob *Observer) Prune()

Prune prunes the outdated blocks

func (*Observer) RecordBlockAndTxs

func (ob *Observer) RecordBlockAndTxs(b *common.Block) error

func (*Observer) Start

func (o *Observer) Start()

Start starts the routines of observer

func (*Observer) Update

func (ob *Observer) Update()

Update starts the main routine for updating blocks