collector

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

type Listener interface {
	OnNetworkInfo(genesisId string, genesisTime uint64, epochNumLayers uint32, maxTransactionsPerSecond uint64, layerDuration uint64, postUnitSize uint64)
	OnNodeStatus(connectedPeers uint64, isSynced bool, syncedLayer uint32, topLayer uint32, verifiedLayer uint32)
	OnLayer(layer *pb.Layer)
	OnAccounts(accounts []*types.Account)
	OnReward(reward *pb.Reward)
	OnMalfeasanceProof(proof *pb.MalfeasanceProof)
	OnTransactionResult(res *pb.TransactionResult, state *pb.TransactionState)
	GetLastLayer(parent context.Context) uint32
	LayersInQueue() int
	IsLayerInQueue(layer *pb.Layer) bool
	GetEpochNumLayers() uint32
}