monitor

Documentation

Overview

Package monitor implements the support for monitoring the state of the Tendermint Blockchain (later Ethereum I guess?) to sign all committed requests.

Index

• type Monitor
  • func New(l *logger.Logger, tmClient *tmclient.Client, store *storage.Database, id int64) (*Monitor, error)
  • func (m *Monitor) FinalizeHeight(height int64)
  • func (m *Monitor) GetLowestFullUnprocessedBlock() (int64, *block)
  • func (m *Monitor) Halt()

Types

type Monitor

type Monitor struct {
	sync.Mutex
	worker.Worker
	// contains filtered or unexported fields
}

Monitor represents the Blockchain monitor

func New

func New(l *logger.Logger, tmClient *tmclient.Client, store *storage.Database, id int64) (*Monitor, error)

New creates a new monitor.

func (*Monitor) FinalizeHeight

func (m *Monitor) FinalizeHeight(height int64)

FinalizeHeight gets called when all txs from a particular block are processed.

func (*Monitor) GetLowestFullUnprocessedBlock

func (m *Monitor) GetLowestFullUnprocessedBlock() (int64, *block)

GetLowestFullUnprocessedBlock returns block on lowest height that is currently not being processed. FIXME: it doesn't actually return the lowest, but does it matter? nolint: golint

func (*Monitor) Halt

func (m *Monitor) Halt()

Halt stops the monitor and unsubscribes from any open queries.