network

package

Go to main page

Versions in this module

v1

v1.8.12

Jul 4, 2018

Changes in this version

+ const DefaultNetworkID

+ var BzzSpec = &protocols.Spec

+ var DiscoverySpec = &protocols.Spec

+ func Label(e *entry) string

+ func LogAddrs(nns [][]byte) string

+ func NewNodeIDFromAddr(addr Addr) discover.NodeID

+ func NewPeerPotMap(kadMinProxSize int, addrs [][]byte) map[string]*PeerPot

+ func NotifyDepth(depth uint8, h Overlay)

+ func NotifyPeer(p OverlayAddr, k Overlay)

+ func ToOverlayAddr(id []byte) []byte

+ type Addr interface

+ Over func() []byte

+ String func() string

+ Under func() []byte

+ Update func(OverlayAddr) OverlayAddr

type Bzz

+ NetworkID uint64

+ func NewBzz(config *BzzConfig, kad Overlay, store state.Store, ...) *Bzz

+ func (b *Bzz) APIs() []rpc.API

+ func (b *Bzz) GetHandshake(peerID discover.NodeID) (*HandshakeMsg, bool)

+ func (b *Bzz) NodeInfo() interface{}

+ func (b *Bzz) Protocols() []p2p.Protocol

+ func (b *Bzz) RunProtocol(spec *protocols.Spec, run func(*BzzPeer) error) func(*p2p.Peer, p2p.MsgReadWriter) error

+ func (b *Bzz) UpdateLocalAddr(byteaddr []byte) *BzzAddr

+ type BzzAddr struct

+ OAddr []byte

+ UAddr []byte

+ func NewAddrFromNodeID(id discover.NodeID) *BzzAddr

+ func NewAddrFromNodeIDAndPort(id discover.NodeID, host net.IP, port uint16) *BzzAddr

+ func RandomAddr() *BzzAddr

+ func ToAddr(pa OverlayPeer) *BzzAddr

+ func (a *BzzAddr) Address() []byte

+ func (a *BzzAddr) ID() discover.NodeID

+ func (a *BzzAddr) Over() []byte

+ func (a *BzzAddr) String() string

+ func (a *BzzAddr) Under() []byte

+ func (a *BzzAddr) Update(na OverlayAddr) OverlayAddr

+ type BzzConfig struct

+ HiveParams *HiveParams

+ NetworkID uint64

+ OverlayAddr []byte

+ UnderlayAddr []byte

+ type BzzPeer struct

+ func NewBzzTestPeer(p *protocols.Peer, addr *BzzAddr) *BzzPeer

+ func (p *BzzPeer) LastActive() time.Time

+ func (p *BzzPeer) Off() OverlayAddr

+ type Conn interface

+ Drop func(error)

+ Handshake func(context.Context, interface{}, func(interface{}) error) (interface{}, error)

+ ID func() discover.NodeID

+ Off func() OverlayAddr

+ Run func(func(interface{}) error) error

+ Send func(interface{}) error

+ type HandshakeMsg struct

+ Addr *BzzAddr

+ NetworkID uint64

+ Version uint64

+ func (bh *HandshakeMsg) String() string

+ type Health struct

+ CountNN int

+ CulpritsNN [][]byte

+ Full bool

+ GotNN bool

+ Hive string

+ KnowNN bool

type Hive

+ Store state.Store

+ func (h *Hive) NodeInfo() interface{}

+ func (h *Hive) PeerInfo(id discover.NodeID) interface{}

+ func (h *Hive) Run(p *BzzPeer) error

type HiveParams

+ Discovery bool

+ KeepAliveInterval time.Duration

+ MaxPeersPerRequest uint8

+ PeersBroadcastSetSize uint8

+ type KadParams struct

+ MaxBinSize int

+ MaxProxDisplay int

+ MaxRetries int

+ MinBinSize int

+ MinProxBinSize int

+ Reachable func(OverlayAddr) bool

+ RetryExponent int

+ RetryInterval int64

+ func NewKadParams() *KadParams

+ type Kademlia struct

+ func NewKademlia(addr []byte, params *KadParams) *Kademlia

+ func (k *Kademlia) AddrCountC() <-chan int

+ func (k *Kademlia) BaseAddr() []byte

+ func (k *Kademlia) EachAddr(base []byte, o int, f func(OverlayAddr, int, bool) bool)

+ func (k *Kademlia) EachBin(base []byte, pof pot.Pof, o int, ...)

+ func (k *Kademlia) EachConn(base []byte, o int, f func(OverlayConn, int, bool) bool)

+ func (k *Kademlia) Healthy(pp *PeerPot) *Health

+ func (k *Kademlia) NeighbourhoodDepthC() <-chan int

+ func (k *Kademlia) Off(p OverlayConn)

+ func (k *Kademlia) On(p OverlayConn) (uint8, bool)

+ func (k *Kademlia) Register(peers []OverlayAddr) error

+ func (k *Kademlia) String() string

+ func (k *Kademlia) SuggestPeer() (a OverlayAddr, o int, want bool)

+ type Overlay interface

+ BaseAddr func() []byte

+ EachAddr func([]byte, int, func(OverlayAddr, int, bool) bool)

+ EachConn func([]byte, int, func(OverlayConn, int, bool) bool)

+ Healthy func(*PeerPot) *Health

+ Off func(OverlayConn)

+ On func(OverlayConn) (depth uint8, changed bool)

+ Register func([]OverlayAddr) error

+ String func() string

+ SuggestPeer func() (OverlayAddr, int, bool)

+ type OverlayAddr interface

+ Update func(OverlayAddr) OverlayAddr

+ type OverlayConn interface

+ Drop func(error)

+ Off func() OverlayAddr

+ type OverlayPeer interface

+ Address func() []byte

+ type Peer interface

+ LastActive func() time.Time

+ type PeerPot struct

+ EmptyBins []int

+ NNSet [][]byte

v1.8.11

Jun 12, 2018

v1.8.10

May 30, 2018

v1.8.8

May 14, 2018

v1.8.7

May 2, 2018

v1.8.5

Apr 23, 2018

v1.8.3

Mar 26, 2018

v1.8.0

Feb 14, 2018

Changes in this version

type HiveParams

+ func NewDefaultHiveParams() *HiveParams

+ func (self *HiveParams) Init(path string)

type SyncParams

+ func NewDefaultSyncParams() *SyncParams

+ func (self *SyncParams) Init(path string)

v1.7.0

Sep 14, 2017

v1.6.5

Jun 1, 2017

v1.6.4

Jun 1, 2017

v1.6.0

Apr 14, 2017

v1.5.8

Feb 1, 2017

v1.5.1

Nov 16, 2016

Changes in this version

+ const BacklogReq

+ const DeliverReq

+ const ErrDecode

+ const ErrExtraStatusMsg

+ const ErrInvalidMsgCode

+ const ErrMsgTooLarge

+ const ErrNetworkIdMismatch

+ const ErrNoStatusMsg

+ const ErrSwap

+ const ErrSync

+ const ErrUnwanted

+ const ErrVersionMismatch

+ const High

+ const HistoryReq

+ const Low

+ const Medium

+ const NetworkId

+ const PropagateReq

+ const ProtocolLength

+ const ProtocolMaxMsgSize

+ const PushReq

+ const Version

+ func Bzz(cloud StorageHandler, backend chequebook.Backend, hive *Hive, ...) (p2p.Protocol, error)

+ func Deliver(p *peer, req interface{}, ty int)

+ func NewForwarder(hive *Hive) *forwarder

+ func Push(p *peer, key storage.Key, priority uint)

+ type DbAccess struct

+ func NewDbAccess(loc *storage.LocalStore) *DbAccess

+ type Depo struct

+ func NewDepo(hash storage.Hasher, localStore, remoteStore storage.ChunkStore) *Depo

+ func (self *Depo) HandleDeliveryRequestMsg(req *deliveryRequestMsgData, p *peer) error

+ func (self *Depo) HandleRetrieveRequestMsg(req *retrieveRequestMsgData, p *peer)

+ func (self *Depo) HandleStoreRequestMsg(req *storeRequestMsgData, p *peer)

+ func (self *Depo) HandleUnsyncedKeysMsg(req *unsyncedKeysMsgData, p *peer) error

+ type Hive struct

+ func NewHive(addr common.Hash, params *HiveParams, swapEnabled, syncEnabled bool) *Hive

+ func (self *Hive) Addr() kademlia.Address

+ func (self *Hive) BlockNetworkRead(on bool)

+ func (self *Hive) BlockNetworkWrite(on bool)

+ func (self *Hive) DropAll()

+ func (self *Hive) HandlePeersMsg(req *peersMsgData, from *peer)

+ func (self *Hive) Start(id discover.NodeID, listenAddr func() string, connectPeer func(string) error) (err error)

+ func (self *Hive) Stop() error

+ func (self *Hive) String() string

+ func (self *Hive) SwapEnabled(on bool)

+ func (self *Hive) SyncEnabled(on bool)

+ type HiveParams struct

+ CallInterval uint64

+ KadDbPath string

+ func NewHiveParams(path string) *HiveParams

+ type StorageHandler interface

+ HandleDeliveryRequestMsg func(req *deliveryRequestMsgData, p *peer) error

+ HandleRetrieveRequestMsg func(req *retrieveRequestMsgData, p *peer)

+ HandleStoreRequestMsg func(req *storeRequestMsgData, p *peer)

+ HandleUnsyncedKeysMsg func(req *unsyncedKeysMsgData, p *peer) error

+ type SyncParams struct

+ KeyBufferSize uint

+ RequestDbBatchSize uint

+ RequestDbPath string

+ SyncBatchSize uint

+ SyncBufferSize uint

+ SyncCacheSize uint

+ SyncModes []bool

+ SyncPriorities []uint

+ func NewSyncParams(bzzdir string) *SyncParams

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