net

package

Go to main page

Versions in this module

v1

v1.3.2

Apr 17, 2019

Changes in this version

type MockPeer

+ func (mp *MockPeer) HasBlock(hash types.Hash) bool

+ func (mp *MockPeer) Info() PeerInfo

type Peer

+ HasBlock func(hash types.Hash) bool

+ Info func() PeerInfo

v1.3.1-alpha.1

Mar 21, 2019

v1.3.0

Feb 28, 2019

Changes in this version

+ type BlockSubscriber interface

+ SubscribeAccountBlock func(fn AccountblockCallback) (subId int)

+ SubscribeSnapshotBlock func(fn SnapshotBlockCallback) (subId int)

+ UnsubscribeAccountBlock func(subId int)

+ UnsubscribeSnapshotBlock func(subId int)

+ type ChunkPoolStatus struct

+ Request []ChunkReqStatus

+ type ChunkReqStatus struct

+ Deadline string

+ Done bool

+ From uint64

+ Pieces chunkResponses

+ Target string

+ To uint64

+ type ChunkResponse struct

+ From uint64

+ To uint64

type Config

+ FileAddress string

+ type ExecutorStatus struct

+ Tasks []string

+ type File = *ledger.CompressedFileMeta

+ type FileClientStatus struct

+ FPool FilePoolStatus

+ Queue []File

+ type FileConnStatus struct

+ Addr string

+ Id string

+ Speed float64

+ type FilePoolStatus struct

+ Conns []FileConnStatus

+ type FileServerStatus struct

+ Conns []string

+ type Files []File

+ func (f Files) Len() int

+ func (f Files) Less(i, j int) bool

+ func (f Files) Swap(i, j int)

+ type Handler func(msgId uint64, payload p2p.Serializable)

+ type InvalidHash struct

+ HashList []string

+ type MockPeer struct

+ Handlers map[ViteCmd]Handler

+ func NewMockPeer() *MockPeer

+ func (mp *MockPeer) Disconnect(reason p2p.DiscReason)

+ func (mp *MockPeer) FileAddress() *net2.TCPAddr

+ func (mp *MockPeer) Head() types.Hash

+ func (mp *MockPeer) Height() uint64

+ func (mp *MockPeer) ID() string

+ func (mp *MockPeer) RemoteAddr() *net2.TCPAddr

+ func (mp *MockPeer) Report(err error)

+ func (mp *MockPeer) SeeBlock(hash types.Hash)

+ func (mp *MockPeer) Send(code ViteCmd, msgId uint64, payload p2p.Serializable) (err error)

+ func (mp *MockPeer) SendAccountBlocks(bs []*ledger.AccountBlock, msgId uint64) (err error)

+ func (mp *MockPeer) SendMsg(msg *p2p.Msg) (err error)

+ func (mp *MockPeer) SendNewAccountBlock(b *ledger.AccountBlock) (err error)

+ func (mp *MockPeer) SendNewSnapshotBlock(b *ledger.SnapshotBlock) (err error)

+ func (mp *MockPeer) SendSnapshotBlocks(bs []*ledger.SnapshotBlock, msgId uint64) (err error)

+ func (mp *MockPeer) SetHead(head types.Hash, height uint64)

type NodeInfo

+ Plugins []interface{}

type Peer

+ Head func() types.Hash

+ SendMsg func(msg *p2p.Msg) (err error)

+ type SyncDetail struct

+ type SyncStateSubscriber interface

+ SubscribeSyncStatus func(fn SyncStateCallback) (subId int)

+ SyncState func() SyncState

+ UnsubscribeSyncStatus func(subId int)

type Syncer

+ Detail func() SyncDetail

v1.2.3-alpha.4

Jan 30, 2019

v1.2.3-alpha.3

Jan 28, 2019

v1.2.3-alpha.2

Jan 24, 2019

v1.2.3-alpha.1

Jan 18, 2019

v1.2.2

Jan 14, 2019

v1.2.1

Jan 11, 2019

v1.2.0

Jan 10, 2019

Changes in this version

type Config

+ TopoEnable bool

type Net

+ AddPlugin func(plugin p2p.Plugin)

type NodeInfo

+ PeerCount int

type Peer

+ Disconnect func(reason p2p.DiscReason)

v1.1.2

Dec 20, 2018

Changes in this version

type NodeInfo

+ Latency []int64

v1.1.1

Dec 8, 2018

Changes in this version

+ const CmdSet

+ const DefaultPort

+ const Vite

+ var NULL_ADDRESS = types.Address

+ type AccountblockCallback = func(addr types.Address, block *ledger.AccountBlock, source types.BlockSource)

+ type Broadcaster interface

+ BroadcastAccountBlock func(block *ledger.AccountBlock)

+ BroadcastAccountBlocks func(blocks []*ledger.AccountBlock)

+ BroadcastSnapshotBlock func(block *ledger.SnapshotBlock)

+ BroadcastSnapshotBlocks func(blocks []*ledger.SnapshotBlock)

+ type Chain interface

+ Compressor func() *compress.Compressor

+ GetAccountBlockByHash func(blockHash *types.Hash) (*ledger.AccountBlock, error)

+ GetAccountBlockByHeight func(addr *types.Address, height uint64) (*ledger.AccountBlock, error)

+ GetAccountBlocksByHash func(addr types.Address, origin *types.Hash, count uint64, forward bool) ([]*ledger.AccountBlock, error)

+ GetAccountBlocksByHeight func(addr types.Address, start, count uint64, forward bool) ([]*ledger.AccountBlock, error)

+ GetConfirmSubLedger func(start, end uint64) ([]*ledger.SnapshotBlock, map[types.Address][]*ledger.AccountBlock, error)

+ GetGenesisSnapshotBlock func() *ledger.SnapshotBlock

+ GetLatestSnapshotBlock func() *ledger.SnapshotBlock

+ GetSnapshotBlockByHash func(hash *types.Hash) (*ledger.SnapshotBlock, error)

+ GetSnapshotBlockByHeight func(height uint64) (*ledger.SnapshotBlock, error)

+ GetSnapshotBlocksByHash func(origin *types.Hash, count uint64, forward, content bool) ([]*ledger.SnapshotBlock, error)

+ GetSnapshotBlocksByHeight func(height, count uint64, forward, content bool) ([]*ledger.SnapshotBlock, error)

+ GetSubLedgerByHash func(origin *types.Hash, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64, error)

+ GetSubLedgerByHeight func(start, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64)

+ type Config struct

+ Chain Chain

+ Interval int64

+ Port uint16

+ Single bool

+ Topic string

+ TopoDisabled bool

+ Topology []string

+ Verifier Verifier

+ type Fetcher interface

+ FetchAccountBlocks func(start types.Hash, count uint64, address *types.Address)

+ FetchAccountBlocksWithHeight func(start types.Hash, count uint64, address *types.Address, sHeight uint64)

+ FetchSnapshotBlocks func(start types.Hash, count uint64)

+ type Filter interface

+ type MsgHandler interface

+ Cmds func() []ViteCmd

+ Handle func(msg *p2p.Msg, sender Peer) error

+ ID func() string

+ type MsgIder interface

+ MsgID func() uint64

+ type Net interface

+ Info func() *NodeInfo

+ Protocols func() []*p2p.Protocol

+ Start func(svr *p2p.Server) error

+ Stop func()

+ Tasks func() []*Task

+ func New(cfg *Config) Net

+ type NodeInfo struct

+ Peers []*PeerInfo

+ type Peer interface

+ FileAddress func() *net2.TCPAddr

+ Height func() uint64

+ ID func() string

+ RemoteAddr func() *net2.TCPAddr

+ Report func(err error)

+ SeeBlock func(hash types.Hash)

+ Send func(code ViteCmd, msgId uint64, payload p2p.Serializable) (err error)

+ SendAccountBlocks func(bs []*ledger.AccountBlock, msgId uint64) (err error)

+ SendNewAccountBlock func(b *ledger.AccountBlock) (err error)

+ SendNewSnapshotBlock func(b *ledger.SnapshotBlock) (err error)

+ SendSnapshotBlocks func(bs []*ledger.SnapshotBlock, msgId uint64) (err error)

+ SetHead func(head types.Hash, height uint64)

+ type PeerInfo struct

+ Addr string

+ Created string

+ Head string

+ Height uint64

+ ID string

+ func (p *PeerInfo) String() string

+ type Receiver interface

+ ReceiveAccountBlock func(block *ledger.AccountBlock)

+ ReceiveAccountBlocks func(blocks []*ledger.AccountBlock)

+ ReceiveNewAccountBlock func(block *ledger.AccountBlock)

+ ReceiveNewSnapshotBlock func(block *ledger.SnapshotBlock)

+ ReceiveSnapshotBlock func(block *ledger.SnapshotBlock)

+ ReceiveSnapshotBlocks func(blocks []*ledger.SnapshotBlock)

+ SubscribeAccountBlock func(fn AccountblockCallback) (subId int)

+ SubscribeSnapshotBlock func(fn SnapshotBlockCallback) (subId int)

+ UnsubscribeAccountBlock func(subId int)

+ UnsubscribeSnapshotBlock func(subId int)

+ type Request interface

+ Band func() (from, to uint64)

+ Catch func(err error)

+ Done func(ctx context)

+ Expired func() bool

+ Handle func(ctx context, msg *p2p.Msg, peer Peer)

+ ID func() uint64

+ Peer func() Peer

+ Req func() Request

+ Run func(ctx context)

+ SetBand func(from, to uint64)

+ SetID func(id uint64)

+ SetPeer func(peer Peer)

+ State func() reqState

+ type SnapshotBlockCallback = func(block *ledger.SnapshotBlock, source types.BlockSource)

+ type Subscriber interface

+ SubscribeAccountBlock func(fn AccountblockCallback) (subId int)

+ SubscribeSnapshotBlock func(fn SnapshotBlockCallback) (subId int)

+ SubscribeSyncStatus func(fn SyncStateCallback) (subId int)

+ SyncState func() SyncState

+ UnsubscribeAccountBlock func(subId int)

+ UnsubscribeSnapshotBlock func(subId int)

+ UnsubscribeSyncStatus func(subId int)

+ type SyncState uint

+ const SyncCancel

+ const SyncDownloaded

+ const SyncNotStart

+ const Syncdone

+ const Syncerr

+ const Syncing

+ func (s SyncState) String() string

+ type SyncStateCallback = func(SyncState)

+ type SyncStateFeed struct

+ func (s *SyncStateFeed) Notify(st SyncState)

+ func (s *SyncStateFeed) Sub(fn SyncStateCallback) int

+ func (s *SyncStateFeed) Unsub(subId int)

+ type SyncStatus struct

+ Current uint64

+ From uint64

+ Received uint64

+ State SyncState

+ To uint64

+ type Syncer interface

+ Status func() *SyncStatus

+ SubscribeSyncStatus func(fn SyncStateCallback) (subId int)

+ SyncState func() SyncState

+ UnsubscribeSyncStatus func(subId int)

+ type Task struct

+ Msg string

+ Sender string

+ type Verifier interface

+ VerifyNetAb func(block *ledger.AccountBlock) error

+ VerifyNetSb func(block *ledger.SnapshotBlock) error

+ type ViteCmd p2p.Cmd

+ const AccountBlocksCode

+ const ExceptionCode

+ const FileListCode

+ const ForkCode

+ const FullSnapshotBlocksCode

+ const GetAccountBlocksByHashCode

+ const GetAccountBlocksCode

+ const GetChunkCode

+ const GetFilesCode

+ const GetFullSnapshotBlocksByHashCode

+ const GetFullSnapshotBlocksCode

+ const GetMultiAccountBlocksCode

+ const GetSnapshotBlocksByHashCode

+ const GetSnapshotBlocksCode

+ const GetSnapshotBlocksContentByHashCode

+ const GetSnapshotBlocksContentCode

+ const GetSubLedgerCode

+ const HandshakeCode

+ const NewAccountBlockCode

+ const NewSnapshotBlockCode

+ const SnapshotBlocksCode

+ const SnapshotBlocksContentCode

+ const StatusCode

+ const SubLedgerCode

+ func (t ViteCmd) String() string

Incompatible versions in this module

v2.2.0+incompatible

Jun 25, 2019

v2.1.5+incompatible

Jun 12, 2019

v2.1.4+incompatible

May 30, 2019

v2.1.3+incompatible

May 22, 2019

v2.1.2+incompatible

May 21, 2019

v2.1.1+incompatible

May 21, 2019

v2.0.0+incompatible

May 21, 2019

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