collector

Documentation

Index

• type Collector
  • func NewCollector(nodePublicAddress string, nodePrivateAddress string, ...) *Collector
  • func (c *Collector) GetAccountState(address string) (uint64, uint64, error)
  • func (c *Collector) Run() error
  • func (c *Collector) StartHttpServer(apiHost string, apiPort int)
• type Listener

Types

type Collector

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

func NewCollector

func NewCollector(nodePublicAddress string, nodePrivateAddress string, syncMissingLayersFlag bool,
	syncFromLayerFlag int, recalculateEpochStatsFlag bool,
	listener Listener, db sql2.StateDatabase, dbClient sql.DatabaseClient, atxSyncFlag bool) *Collector

func (*Collector) GetAccountState

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

func (*Collector) Run

func (c *Collector) Run() error

func (*Collector) StartHttpServer

func (c *Collector) StartHttpServer(apiHost string, apiPort int)

type Listener

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
	GetTransactions(parent context.Context, query *bson.D, opts ...*options.FindOptions) ([]model.Transaction, error)
	UpdateTransactionState(parent context.Context, id string, state int32) error
	UpdateEpochStats(layer uint32)
	OnActivation(atx *types.ActivationTx)
	GetLastActivationReceived() int64
	RecalculateEpochStats()
	OnActivations(atxs []*model.Activation)
}