protocol

package

Go to main page

Versions in this module

v0

v0.2.2

Feb 19, 2019

Changes in this version

+ const FlagNode

type Noder

+ GetLastActive func() time.Time

+ IsCurrent func() bool

+ NAFilter func() p2p.NAFilter

+ RegisterTxPoolListener func(listener TxnPoolListener)

+ SetLastActive func(now time.Time)

+ SetNAFilter func(filter p2p.NAFilter)

+ UnregisterTxPoolListener func(listener TxnPoolListener)

+ type TxnPoolListener interface

+ OnIllegalBlockTxnReceived func(txn *types.Transaction)

v0.2.1

Dec 3, 2018

Changes in this version

+ const MaxIDCached

+ var States = map[State]string

+ type Handler interface

+ HandleMessage func(message p2p.Message)

+ MakeEmptyMessage func(cmd string) (p2p.Message, error)

type Noder

+ Connected func() bool

+ Disconnect func()

+ IP func() net.IP

+ SendMessage func(msg p2p.Message)

+ UpdateHandler func(handler Handler)

+ type State int32

+ const ESTABLISHED

+ const HAND

+ const HANDSHAKE

+ const HANDSHAKED

+ const INACTIVITY

+ const INIT

+ func (s State) String() string

v0.2.1-80ce

Dec 10, 2018

v0.2.0

Aug 20, 2018

Changes in this version

+ const HeartbeatDuration

+ const SyncBlockTimeout

type Noder

+ GetNeighborNodes func() []Noder

+ Heartbeat func()

+ IsExternal func() bool

v0.1.1

Jul 4, 2018

Changes in this version

+ const ConnectionMonitor

+ const HandshakeTimeout

type Noder

+ AddNeighborNode func(Noder)

+ AddToConnectingList func(addr string) bool

+ AddToHandshakeQueue func(node Noder)

+ ConnectNodes func()

+ DelNeighborNode func(id uint64) (Noder, bool)

+ GetConnectionCount func() uint

+ GetNeighbourAddresses func() []p2p.NetAddress

+ GetNeighbourCount func() uint32

+ GetTransactionPool func(bool) map[common.Uint256]*core.Transaction

+ IsDuplicateSidechainTx func(sidechainTxHash common.Uint256) bool

+ NetAddress func() p2p.NetAddress

+ RemoveFromConnectingList func(addr string)

+ RemoveFromHandshakeQueue func(node Noder)

+ RequireNeighbourList func()

v0.1.0

Jun 8, 2018

Changes in this version

+ const ConnMonitor

+ const DefaultMaxPeers

+ const DialTimeout

+ const KeepAliveTimeout

+ const MaxIdCached

+ const MaxOutBoundCount

+ const MaxSyncHdrReq

+ const MinConnectionCount

+ const OpenService

+ const ProtocolVersion

+ const TimesOfUpdateTime

+ type Noder interface

+ AcqSyncBlkReqSem func()

+ AcqSyncHdrReqSem func()

+ AddKnownAddress func(na p2p.NetAddress)

+ AddNbrNode func(Noder)

+ AddRequestedBlock func(hash Uint256)

+ Addr func() string

+ Addr16 func() ([16]byte, error)

+ AppendToTxnPool func(*Transaction) ErrCode

+ BloomFilter func() *bloom.Filter

+ CleanSubmittedTransactions func(block *Block) error

+ CloseConn func()

+ Connect func(nodeAddr string) error

+ ConnectSeeds func()

+ DelNbrNode func(id uint64) (Noder, bool)

+ DeleteRequestedBlock func(hash Uint256)

+ DumpInfo func()

+ ExistHash func(hash Uint256) bool

+ ExistedID func(id Uint256) bool

+ FindSyncNode func() (Noder, error)

+ GetAddressCnt func() uint64

+ GetBestHeightNoder func() Noder

+ GetConn func() net.Conn

+ GetConnectionCnt func() uint

+ GetEvent func(eventName string) *events.Event

+ GetLastActiveTime func() time.Time

+ GetNbrNodeCnt func() uint32

+ GetNeighborAddrs func() ([]p2p.NetAddress, uint64)

+ GetNeighborHeights func() ([]uint64, uint64)

+ GetNeighborNoder func() []Noder

+ GetRequestBlockList func() map[Uint256]time.Time

+ GetRxTxnCnt func() uint64

+ GetStartHash func() Uint256

+ GetStopHash func() Uint256

+ GetTime func() int64

+ GetTransaction func(hash Uint256) *Transaction

+ GetTxnCnt func() uint64

+ GetTxnPool func(bool) map[Uint256]*Transaction

+ Height func() uint64

+ HttpInfoPort func() int

+ ID func() uint64

+ IncRxTxnCnt func()

+ IsAddrInNbrList func(addr string) bool

+ IsFromExtraNet func() bool

+ IsNeighborNoder func(n Noder) bool

+ IsRelay func() bool

+ IsRequestedBlock func(hash Uint256) bool

+ IsSyncFailed func() bool

+ IsSyncHeaders func() bool

+ LoadFilter func(filter *msg.FilterLoad)

+ MaybeAcceptTransaction func(txn *Transaction) error

+ NeedMoreAddresses func() bool

+ NodeEstablished func(uid uint64) bool

+ Port func() uint16

+ RandGetAddresses func(nbrAddrs []p2p.NetAddress) []p2p.NetAddress

+ RandSelectAddresses func() []p2p.NetAddress

+ RelSyncBlkReqSem func()

+ RelSyncHdrReqSem func()

+ Relay func(Noder, interface{}) error

+ RemoveAddrInConnectingList func(addr string)

+ RemoveTransaction func(txn *Transaction)

+ ReqNeighborList func()

+ ResetRequestedBlock func()

+ Send func(msg p2p.Message)

+ Services func() uint64

+ SetAddrInConnectingList func(addr string) bool

+ SetHeight func(height uint64)

+ SetHttpInfoPort func(uint16)

+ SetStartHash func(hash Uint256)

+ SetState func(state uint)

+ SetStopHash func(hash Uint256)

+ SetSyncHeaders func(b bool)

+ State func() uint

+ UpdateInfo func(t time.Time, version uint32, services uint64, port uint16, nonce uint64, ...)

+ UpdateLastActive func()

+ UpdateLastDisconn func(id uint64)

+ UpdateMsgHelper func(handler p2p.MsgHandler)

+ Version func() uint32

+ WaitForSyncFinish func()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL