network

package

Go to main page

Versions in this module

v1

v1.0.7

May 11, 2021

v1.0.6

Jul 26, 2019

Changes in this version

+ var Pof = pot.DefaultPof(256)

+ var RequestTimeout = 10 * time.Second

type Bzz

+ func (b *Bzz) GetOrCreateHandshake(peerID enode.ID) (*HandshakeMsg, bool)

type BzzAddr

+ func NewAddr(node *enode.Node) *BzzAddr

type BzzConfig

+ BootnodeMode bool

type BzzPeer

+ func NewBzzPeer(p *protocols.Peer) *BzzPeer

+ func (p *BzzPeer) ID() enode.ID

+ type Fetcher struct

+ func NewFetcher(ctx context.Context, addr storage.Address, rf RequestFunc, skipCheck bool) *Fetcher

+ func (f *Fetcher) Offer(source *enode.ID)

+ func (f *Fetcher) Request(hopCount uint8)

+ type FetcherFactory struct

+ func NewFetcherFactory(request RequestFunc, skipCheck bool) *FetcherFactory

+ func (f *FetcherFactory) New(ctx context.Context, source storage.Address, peers *sync.Map) storage.NetFetcher

type Health

+ ConnectNN bool

+ CountConnectNN int

+ CountKnowNN int

+ MissingConnectNN [][]byte

+ MissingKnowNN [][]byte

+ Saturated bool

+ func (h *Health) Healthy() bool

type KadParams

+ NeighbourhoodSize int

type Kademlia

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

+ func (k *Kademlia) NeighbourhoodDepth() (depth int)

type Peer

+ func NewPeer(p *BzzPeer, kad *Kademlia) *Peer

+ func (d *Peer) HandleMsg(ctx context.Context, msg interface{}) error

+ func (d *Peer) NotifyDepth(po uint8)

+ func (d *Peer) NotifyPeer(a *BzzAddr, po uint8)

type PeerPot

+ PeersPerBin []int

+ type Request struct

+ Addr storage.Address

+ HopCount uint8

+ SkipCheck bool

+ Source *enode.ID

+ func NewRequest(addr storage.Address, skipCheck bool, peersToSkip *sync.Map) *Request

+ func (r *Request) SkipPeer(nodeID string) bool

+ type RequestFunc func(context.Context, *Request) (*enode.ID, chan struct{}, error)

v1.0.4

Dec 7, 2018

Changes in this version

type Bzz

+ LightNode bool

type BzzConfig

+ LightNode bool

type BzzPeer

+ LightNode bool

type HandshakeMsg

+ LightNode bool

v1.0.3

Sep 18, 2018

Changes in this version

+ const BacklogReq

+ const DefaultNetworkID

+ const DeliverReq

+ const High

+ const HistoryReq

+ const Low

+ const Medium

+ const PropagateReq

+ const ProtocolMaxMsgSize

+ const PushReq

+ var BzzSpec = &protocols.Spec

+ var DiscoverySpec = &protocols.Spec

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

+ func Label(e *entry) string

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

+ func NewForwarder(hive *Hive) *forwarder

+ 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 Push(p *peer, key storage.Key, priority uint)

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

+ type Addr interface

+ Over func() []byte

+ String func() string

+ Under func() []byte

+ Update func(OverlayAddr) OverlayAddr

+ type Bzz struct

+ 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(context.Context, interface{}) error) error

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

+ type DbAccess struct

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

+ type Depo struct

+ func NewDepo(hash storage.SwarmHasher, 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 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 struct

+ Store state.Store

+ func NewHive(params *HiveParams, overlay Overlay, store state.Store) *Hive

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

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

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

+ func (h *Hive) Start(server *p2p.Server) error

+ func (h *Hive) Stop() error

+ type HiveParams struct

+ Discovery bool

+ KeepAliveInterval time.Duration

+ MaxPeersPerRequest uint8

+ PeersBroadcastSetSize uint8

+ func NewHiveParams() *HiveParams

+ 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

+ type SyncParams struct

+ KeyBufferSize uint

+ RequestDbBatchSize uint

+ RequestDbPath string

+ SyncBatchSize uint

+ SyncBufferSize uint

+ SyncCacheSize uint

+ SyncModes []bool

+ SyncPriorities []uint

+ func NewDefaultSyncParams() *SyncParams

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

v1.0.3-v3

Sep 26, 2018

v1.0.3-v2

Sep 21, 2018

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