collector

Documentation

Index

• type Collector
  • func NewCollector(nodeAddress string, listener Listener) *Collector
  • func (c *Collector) GetAccountState(address string) (uint64, uint64, error)
  • func (c *Collector) Run()
• type Listener

Types

type Collector

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

func NewCollector

func NewCollector(nodeAddress string, listener Listener) *Collector

func (*Collector) GetAccountState

func (c *Collector) GetAccountState(address string) (uint64, uint64, error)

func (*Collector) Run

func (c *Collector) Run()

type Listener

type Listener interface {
	OnNetworkInfo(genesisId string, genesisTime uint64, epochNumLayers uint64, maxTransactionsPerSecond uint64, layerDuration uint64, postUnitSize uint64)
	OnNodeStatus(connectedPeers uint64, isSynced bool, syncedLayer uint32, topLayer uint32, verifiedLayer uint32)
	OnLayer(layer *pb.Layer)
	OnAccount(account *pb.Account)
	OnReward(reward *pb.Reward)
	OnTransactionReceipt(receipt *pb.TransactionReceipt)
	GetLastLayer(parent context.Context) uint32
}