netsync

Oct 24, 2019

Changes in this version

+ var ErrPeerMisbehave = errors.New("peer is misbehave")

type BasePeer

+ RemoteAddrHost func() string

type BasePeerSet

+ IsBanned func(ip string, level byte, reason string) bool

type Switch

+ IsBanned func(peerID string, level byte, reason string) bool

Apr 22, 2019

Changes in this version

type BasePeer

+ IsLAN func() bool

Mar 4, 2019

Changes in this version

+ type Switch interface

+ AddBannedPeer func(string) error

+ AddReactor func(name string, reactor p2p.Reactor) p2p.Reactor

+ DialPeerWithAddress func(addr *p2p.NetAddress) error

+ IsListening func() bool

+ NodeInfo func() *p2p.NodeInfo

+ Peers func() *p2p.PeerSet

+ Start func() (bool, error)

+ Stop func() bool

+ StopPeerGracefully func(string)

type SyncManager

+ func (sm *SyncManager) DialPeerWithAddress(addr *p2p.NetAddress) error

+ func (sm *SyncManager) GetNetwork() string

+ func (sm *SyncManager) IsListening() bool

+ func (sm *SyncManager) PeerCount() int

Nov 19, 2018

Changes in this version

type BasePeer

+ TrafficStatus func() (*flowrate.Status, *flowrate.Status)

type BlockchainMessage

+ String func() string

type BlocksMessage

+ func (m *BlocksMessage) String() string

type FilterAddMessage

+ func (m *FilterAddMessage) String() string

type FilterClearMessage

+ func (m *FilterClearMessage) String() string

type FilterLoadMessage

+ func (m *FilterLoadMessage) String() string

type GetBlocksMessage

+ func (m *GetBlocksMessage) String() string

type GetHeadersMessage

+ func (m *GetHeadersMessage) String() string

type GetMerkleBlockMessage

+ func (m *GetMerkleBlockMessage) String() string

type HeadersMessage

+ func (m *HeadersMessage) String() string

type MerkleBlockMessage

+ func (m *MerkleBlockMessage) String() string

type PeerInfo

+ AverageReceivedRate int64

+ AverageSentRate int64

+ CurrentReceivedRate int64

+ CurrentSentRate int64

+ Duration string

+ Ping string

+ TotalReceived int64

+ TotalSent int64

Aug 30, 2018

Changes in this version

+ const FilterAddByte

+ const FilterClearByte

+ const FilterLoadByte

+ const MerkleRequestByte

+ const MerkleResponseByte

type Chain

+ GetTransactionStatus func(*bc.Hash) (*bc.TransactionStatus, error)

+ type FilterAddMessage struct

+ Address []byte

+ type FilterClearMessage struct

+ type FilterLoadMessage struct

+ Addresses [][]byte

+ type GetMerkleBlockMessage struct

+ Height uint64

+ RawHash [32]byte

+ func (m *GetMerkleBlockMessage) GetHash() *bc.Hash

+ type MerkleBlockMessage struct

+ Flags []byte

+ RawBlockHeader []byte

+ RawTxDatas [][]byte

+ RawTxStatuses [][]byte

+ StatusHashes [][32]byte

+ TxHashes [][32]byte

+ func NewMerkleBlockMessage() *MerkleBlockMessage

Jul 26, 2018

Changes in this version

+ const BlocksRequestByte

+ const BlocksResponseByte

+ const HeadersRequestByte

+ const HeadersResponseByte

+ type BasePeer interface

+ Addr func() net.Addr

+ ID func() string

+ ServiceFlag func() consensus.ServiceFlag

+ TrySend func(byte, interface{}) bool

+ type BasePeerSet interface

+ AddBannedPeer func(string) error

+ StopPeerGracefully func(string)

+ type BlockMessage struct

+ RawBlock []byte

+ func NewBlockMessage(block *types.Block) (*BlockMessage, error)

+ func (m *BlockMessage) GetBlock() *types.Block

+ func (m *BlockMessage) String() string

+ type BlocksMessage struct

+ RawBlocks [][]byte

+ func NewBlocksMessage(blocks []*types.Block) (*BlocksMessage, error)

+ func (msg *BlocksMessage) GetBlocks() ([]*types.Block, error)

+ type Chain interface

+ BestBlockHeader func() *types.BlockHeader

+ BestBlockHeight func() uint64

+ CalcNextSeed func(*bc.Hash) (*bc.Hash, error)

+ GetBlockByHash func(*bc.Hash) (*types.Block, error)

+ GetBlockByHeight func(uint64) (*types.Block, error)

+ GetHeaderByHash func(*bc.Hash) (*types.BlockHeader, error)

+ GetHeaderByHeight func(uint64) (*types.BlockHeader, error)

+ InMainChain func(bc.Hash) bool

+ ProcessBlock func(*types.Block) (bool, error)

+ ValidateTx func(*types.Tx) (bool, error)

+ type GetBlockMessage struct

+ Height uint64

+ RawHash [32]byte

+ func (m *GetBlockMessage) GetHash() *bc.Hash

+ func (m *GetBlockMessage) String() string

+ type GetBlocksMessage struct

+ RawBlockLocator [][32]byte

+ RawStopHash [32]byte

+ func NewGetBlocksMessage(blockLocator []*bc.Hash, stopHash *bc.Hash) *GetBlocksMessage

+ func (msg *GetBlocksMessage) GetBlockLocator() []*bc.Hash

+ func (msg *GetBlocksMessage) GetStopHash() *bc.Hash

+ type GetHeadersMessage struct

+ RawBlockLocator [][32]byte

+ RawStopHash [32]byte

+ func NewGetHeadersMessage(blockLocator []*bc.Hash, stopHash *bc.Hash) *GetHeadersMessage

+ func (msg *GetHeadersMessage) GetBlockLocator() []*bc.Hash

+ func (msg *GetHeadersMessage) GetStopHash() *bc.Hash

+ type HeadersMessage struct

+ RawHeaders [][]byte

+ func NewHeadersMessage(headers []*types.BlockHeader) (*HeadersMessage, error)

+ func (msg *HeadersMessage) GetHeaders() ([]*types.BlockHeader, error)

+ type PeerInfo struct

+ Delay uint32

+ Height uint64

+ ID string

+ RemoteAddr string

type SyncManager

+ func (sm *SyncManager) BestPeer() *PeerInfo

+ func (sm *SyncManager) GetPeerInfos() []*PeerInfo

+ func (sm *SyncManager) IsCaughtUp() bool

+ func (sm *SyncManager) StopPeer(peerID string) error

+ type TransactionMessage struct

+ RawTx []byte

+ func NewTransactionMessage(tx *types.Tx) (*TransactionMessage, error)

+ func (m *TransactionMessage) GetTransaction() (*types.Tx, error)

+ func (m *TransactionMessage) String() string

Jun 19, 2018

Changes in this version

type SyncManager

+ func (sm *SyncManager) GetNewTxCh() chan *types.Tx

Apr 23, 2018

Changes in this version

+ var ErrDiffGenesisHash = errors.New("Different genesis hash")

type StatusResponseMessage

+ GenesisHash [32]byte

+ func (m *StatusResponseMessage) GetGenesisHash() *bc.Hash

Apr 17, 2018

Changes in this version

+ var ErrStatusRequest = errors.New("Status request error")

Apr 10, 2018

Changes in this version

+ const BlockRequestByte

+ const BlockResponseByte

+ const BlockchainChannel

+ const NewMineBlockByte

+ const NewTransactionByte

+ const StatusRequestByte

+ const StatusResponseByte

+ var ErrProtocolHandshakeTimeout = errors.New("Protocol handshake timeout")

+ type BlockRequestMessage struct

+ Height uint64

+ RawHash [32]byte

+ func (m *BlockRequestMessage) GetHash() *bc.Hash

+ func (m *BlockRequestMessage) String() string

+ type BlockResponseMessage struct

+ RawBlock []byte

+ func NewBlockResponseMessage(block *types.Block) (*BlockResponseMessage, error)

+ func (m *BlockResponseMessage) GetBlock() *types.Block

+ func (m *BlockResponseMessage) String() string

+ type BlockchainMessage interface

+ func DecodeMessage(bz []byte) (msgType byte, msg BlockchainMessage, err error)

+ type Fetcher struct

+ func NewFetcher(chain *core.Chain, sw *p2p.Switch, peers *peerSet) *Fetcher

+ func (f *Fetcher) Enqueue(peer string, block *types.Block) error

+ func (f *Fetcher) Start()

+ func (f *Fetcher) Stop()

+ type MineBlockMessage struct

+ RawBlock []byte

+ func NewMinedBlockMessage(block *types.Block) (*MineBlockMessage, error)

+ func (m *MineBlockMessage) GetMineBlock() (*types.Block, error)

+ func (m *MineBlockMessage) String() string

+ type ProtocolReactor struct

+ func NewProtocolReactor(chain *protocol.Chain, txPool *protocol.TxPool, sw *p2p.Switch, ...) *ProtocolReactor

+ func (pr *ProtocolReactor) AddPeer(peer *p2p.Peer) error

+ func (pr *ProtocolReactor) GetChannels() []*p2p.ChannelDescriptor

+ func (pr *ProtocolReactor) OnStart() error

+ func (pr *ProtocolReactor) OnStop()

+ func (pr *ProtocolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte)

+ func (pr *ProtocolReactor) RemovePeer(peer *p2p.Peer, reason interface{})

+ type Response struct

+ Data interface{}

+ Msg string

+ Status string

+ type StatusRequestMessage struct

+ func (m *StatusRequestMessage) String() string

+ type StatusResponseMessage struct

+ Height uint64

+ RawHash [32]byte

+ func NewStatusResponseMessage(blockHeader *types.BlockHeader) *StatusResponseMessage

+ func (m *StatusResponseMessage) GetHash() *bc.Hash

+ func (m *StatusResponseMessage) String() string

+ type SyncManager struct

+ func NewSyncManager(config *cfg.Config, chain *core.Chain, txPool *core.TxPool, ...) (*SyncManager, error)

+ func (sm *SyncManager) BlockKeeper() *blockKeeper

+ func (sm *SyncManager) DialSeeds(seeds []string) error

+ func (sm *SyncManager) NodeInfo() *p2p.NodeInfo

+ func (sm *SyncManager) Peers() *peerSet

+ func (sm *SyncManager) Start()

+ func (sm *SyncManager) Stop()

+ func (sm *SyncManager) Switch() *p2p.Switch

+ type TransactionNotifyMessage struct

+ RawTx []byte

+ func NewTransactionNotifyMessage(tx *types.Tx) (*TransactionNotifyMessage, error)

+ func (m *TransactionNotifyMessage) GetTransaction() (*types.Tx, error)

+ func (m *TransactionNotifyMessage) String() string