monitor

Documentation

Overview

Package monitor implements the support for monitoring the state of the Tendermint Blockchain

Index

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

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 string,
) (*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. processing is done by outside package; it's implementation specific, for example validator is looking for issuance transactions, verifier for verification requests, etc.

func (*Monitor) GetLowestUnprocessedBlock

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

GetLowestFullUnprocessedBlock returns block on lowest height that is currently not being processed. nolint: golint

func (*Monitor) Halt

func (m *Monitor) Halt()

Halt stops the monitor

func (*Monitor) PrintProcessingState

func (m *Monitor) PrintProcessingState()