node

Documentation

Index

• func InitNode(pubKey *crypto.PubKey) Noder
• func NewNode() *node
• func NonTLSDial(nodeAddr string) (net.Conn, error)
• func TLSDial(nodeAddr string) (net.Conn, error)
• type ConnectingNodes
• type RetryConnAddrs
• type TXNPool
  • func (this *TXNPool) AppendTxnPool(txn *transaction.Transaction, poolVerify bool) ErrCode
  • func (this *TXNPool) CleanSubmittedTransactions(block *ledger.Block) error
  • func (this *TXNPool) GetTransaction(hash common.Uint256) *transaction.Transaction
  • func (this *TXNPool) GetTransactionCount() int
  • func (this *TXNPool) GetTxnPool(byCount bool) map[common.Uint256]*transaction.Transaction

Functions

func InitNode

func InitNode(pubKey *crypto.PubKey) Noder

func NewNode

func NewNode() *node

func NonTLSDial

func NonTLSDial(nodeAddr string) (net.Conn, error)

func TLSDial

func TLSDial(nodeAddr string) (net.Conn, error)

Types

type ConnectingNodes

type ConnectingNodes struct {
	sync.RWMutex
	ConnectingAddrs []string
}

type RetryConnAddrs

type RetryConnAddrs struct {
	sync.RWMutex
	RetryAddrs map[string]int
}

type TXNPool

type TXNPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*TXNPool) AppendTxnPool

func (this *TXNPool) AppendTxnPool(txn *transaction.Transaction, poolVerify bool) ErrCode

func (*TXNPool) CleanSubmittedTransactions

func (this *TXNPool) CleanSubmittedTransactions(block *ledger.Block) error

func (*TXNPool) GetTransaction

func (this *TXNPool) GetTransaction(hash common.Uint256) *transaction.Transaction

func (*TXNPool) GetTransactionCount

func (this *TXNPool) GetTransactionCount() int

func (*TXNPool) GetTxnPool

func (this *TXNPool) GetTxnPool(byCount bool) map[common.Uint256]*transaction.Transaction