node

Documentation

Index

• type ProximaNode
  • func New() *ProximaNode
  • func (p *ProximaNode) GetLatestReliableBranch() *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) GetTxInclusion(txid *ledger.TransactionID, slotsBack int) *multistate.TxInclusion
  • func (p *ProximaNode) HeaviestStateForLatestTimeSlot() multistate.SugaredStateReader
  • func (p *ProximaNode) PullFromPeers(txid *ledger.TransactionID)
  • func (p *ProximaNode) PullFromRandomPeers(nPeers int, txid *ledger.TransactionID) int
  • func (p *ProximaNode) QueryTxIDStatusJSONAble(txid *ledger.TransactionID) vertex.TxIDStatusJSONAble
  • func (p *ProximaNode) Start()
  • func (p *ProximaNode) StateStore() global.StateStore
  • func (p *ProximaNode) SubmitTxBytesFromAPI(txBytes []byte, trace bool)
  • 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) GetLatestReliableBranch

func (p *ProximaNode) GetLatestReliableBranch() *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

GetPeersInfo TODO not finished

func (*ProximaNode) GetSyncInfo

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

GetSyncInfo TODO not finished

func (*ProximaNode) GetTxInclusion

func (p *ProximaNode) GetTxInclusion(txid *ledger.TransactionID, slotsBack int) *multistate.TxInclusion

func (*ProximaNode) HeaviestStateForLatestTimeSlot

func (p *ProximaNode) HeaviestStateForLatestTimeSlot() multistate.SugaredStateReader

func (*ProximaNode) PullFromPeers

func (p *ProximaNode) PullFromPeers(txid *ledger.TransactionID)

func (*ProximaNode) PullFromRandomPeers

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

func (*ProximaNode) QueryTxIDStatusJSONAble

func (p *ProximaNode) QueryTxIDStatusJSONAble(txid *ledger.TransactionID) vertex.TxIDStatusJSONAble

func (*ProximaNode) Start

func (p *ProximaNode) Start()

Start starts the node

func (*ProximaNode) StateStore

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

func (*ProximaNode) SubmitTxBytesFromAPI

func (p *ProximaNode) SubmitTxBytesFromAPI(txBytes []byte, trace bool)

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