node

Documentation

Index

• type ProximaNode
  • func New() *ProximaNode
  • func (p *ProximaNode) CheckTransactionInLRB(txid ledger.TransactionID, maxDepth int) (lrbid ledger.TransactionID, foundAtDepth int)
  • func (p *ProximaNode) DurationSinceLastMessageFromPeer() time.Duration
  • func (p *ProximaNode) EvidenceNumberOfTxDependencies(n int)
  • func (p *ProximaNode) EvidencePastConeSize(sz int)
  • func (p *ProximaNode) GetKnownLatestMilestonesJSONAble() map[string]tippool.LatestSequencerTipDataJSONAble
  • func (p *ProximaNode) GetLatestReliableBranch() (ret *multistate.BranchData)
  • func (p *ProximaNode) GetNodeInfo() *global.NodeInfo
  • func (p *ProximaNode) GetOwnSequencerID() *ledger.ChainID
  • func (p *ProximaNode) GetPeersInfo() *api.PeersInfo
  • func (p *ProximaNode) GetSyncInfo() *api.SyncInfo
  • func (p *ProximaNode) LatestReliableState() (multistate.SugaredStateReader, error)
  • func (p *ProximaNode) OnTransaction(fun func(tx *transaction.Transaction) bool)
  • func (p *ProximaNode) PullFromNPeers(nPeers int, txid *ledger.TransactionID) int
  • func (p *ProximaNode) SelfPeerID() peer.ID
  • func (p *ProximaNode) SnapshotBranchID() *ledger.TransactionID
  • func (p *ProximaNode) Start()
  • func (p *ProximaNode) StateStore() multistate.StateStore
  • func (p *ProximaNode) SubmitTxBytesFromAPI(txBytes []byte)
  • func (p *ProximaNode) SubmitTxBytesFromInflator(txBytes []byte)
  • func (p *ProximaNode) TxBytesStore() global.TxBytesStore
  • func (p *ProximaNode) WaitAllDBClosed()
  • func (p *ProximaNode) WaitAllWorkProcessesToStop()

Types

type ProximaNode

type ProximaNode struct {
	*global.Global
	// contains filtered or unexported fields
}

func New

func New() *ProximaNode

func (*ProximaNode) CheckTransactionInLRB

func (p *ProximaNode) CheckTransactionInLRB(txid ledger.TransactionID, maxDepth int) (lrbid ledger.TransactionID, foundAtDepth int)

func (*ProximaNode) DurationSinceLastMessageFromPeer

func (p *ProximaNode) DurationSinceLastMessageFromPeer() time.Duration

func (*ProximaNode) EvidenceNumberOfTxDependencies

func (p *ProximaNode) EvidenceNumberOfTxDependencies(n int)

func (*ProximaNode) EvidencePastConeSize

func (p *ProximaNode) EvidencePastConeSize(sz int)

func (*ProximaNode) GetKnownLatestMilestonesJSONAble

func (p *ProximaNode) GetKnownLatestMilestonesJSONAble() map[string]tippool.LatestSequencerTipDataJSONAble

func (*ProximaNode) GetLatestReliableBranch

func (p *ProximaNode) GetLatestReliableBranch() (ret *multistate.BranchData)

func (*ProximaNode) GetNodeInfo

func (p *ProximaNode) GetNodeInfo() *global.NodeInfo

GetNodeInfo TODO not finished

func (*ProximaNode) GetOwnSequencerID

func (p *ProximaNode) GetOwnSequencerID() *ledger.ChainID

func (*ProximaNode) GetPeersInfo

func (p *ProximaNode) GetPeersInfo() *api.PeersInfo

func (*ProximaNode) GetSyncInfo

func (p *ProximaNode) GetSyncInfo() *api.SyncInfo

GetSyncInfo TODO not finished

func (*ProximaNode) LatestReliableState

func (p *ProximaNode) LatestReliableState() (multistate.SugaredStateReader, error)

func (*ProximaNode) OnTransaction

func (p *ProximaNode) OnTransaction(fun func(tx *transaction.Transaction) bool)

func (*ProximaNode) PullFromNPeers

func (p *ProximaNode) PullFromNPeers(nPeers int, txid *ledger.TransactionID) int

func (*ProximaNode) SelfPeerID

func (p *ProximaNode) SelfPeerID() peer.ID

func (*ProximaNode) SnapshotBranchID

func (p *ProximaNode) SnapshotBranchID() *ledger.TransactionID

func (*ProximaNode) Start

func (p *ProximaNode) Start()

Start starts the node

func (*ProximaNode) StateStore

func (p *ProximaNode) StateStore() multistate.StateStore

func (*ProximaNode) SubmitTxBytesFromAPI

func (p *ProximaNode) SubmitTxBytesFromAPI(txBytes []byte)

func (*ProximaNode) SubmitTxBytesFromInflator

func (p *ProximaNode) SubmitTxBytesFromInflator(txBytes []byte)

func (*ProximaNode) TxBytesStore

func (p *ProximaNode) TxBytesStore() global.TxBytesStore

func (*ProximaNode) WaitAllDBClosed

func (p *ProximaNode) WaitAllDBClosed()

WaitAllDBClosed ensuring databases has been closed

func (*ProximaNode) WaitAllWorkProcessesToStop

func (p *ProximaNode) WaitAllWorkProcessesToStop()

WaitAllWorkProcessesToStop wait everything to stop before closing databases