network

May 24, 2019

Changes in this version

+ var DefaultTestNetworkID = rand.Uint64()

+ func NewEnode(params *EnodeParams) (*enode.Node, error)

+ func NewEnodeRecord(params *EnodeParams) (*enr.Record, error)

+ func PrivateKeyToBzzKey(prvKey *ecdsa.PrivateKey) []byte

+ type ENRAddrEntry struct

+ func NewENRAddrEntry(addr []byte) *ENRAddrEntry

+ func (b *ENRAddrEntry) DecodeRLP(s *rlp.Stream) error

+ func (b ENRAddrEntry) Address() []byte

+ func (b ENRAddrEntry) ENRKey() string

+ func (b ENRAddrEntry) EncodeRLP(w io.Writer) error

+ type ENRBootNodeEntry bool

+ func (b ENRBootNodeEntry) ENRKey() string

+ type ENRLightNodeEntry bool

+ func (b ENRLightNodeEntry) ENRKey() string

+ type EnodeParams struct

+ Bootnode bool

+ EnodeKey *ecdsa.PrivateKey

+ Lightnode bool

+ PrivateKey *ecdsa.PrivateKey

type Hive

+ func (h *Hive) Peer(id enode.ID) *BzzPeer

type Kademlia

+ func (k *Kademlia) ListKnown() []*BzzAddr

+ func (k *Kademlia) Saturation() int

+ func (k *Kademlia) SubscribeToNeighbourhoodDepthChange() (c <-chan struct{}, unsubscribe func())

Feb 23, 2019

Changes in this version

type Bzz

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

type BzzConfig

+ BootnodeMode bool

type Health

+ func (h *Health) Healthy() bool

type Kademlia

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

type PeerPot

+ PeersPerBin []int

Jan 20, 2019

Changes in this version

+ var Pof = pot.DefaultPof(256)

type Health

+ ConnectNN bool

+ CountConnectNN int

+ CountKnowNN int

+ MissingConnectNN [][]byte

+ MissingKnowNN [][]byte

+ Saturated bool

type KadParams

+ NeighbourhoodSize int

Dec 24, 2018

Changes in this version

+ var RequestTimeout = 10 * time.Second

type BzzAddr

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

type BzzPeer

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

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

+ type Fetcher struct

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

+ func (f *Fetcher) Offer(ctx context.Context, source *enode.ID)

+ func (f *Fetcher) Request(ctx context.Context, hopCount uint8)

+ type FetcherFactory struct

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

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

type Kademlia

+ Pof func(pot.Val, pot.Val, int) (int, bool)

+ 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 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)

Aug 26, 2018

Changes in this version

type Bzz

+ LightNode bool

type BzzConfig

+ LightNode bool

type BzzPeer

+ LightNode bool

type HandshakeMsg

+ LightNode bool

Jul 7, 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

+ 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

Mar 27, 2018

Changes in this version

+ const BacklogReq

+ const DeliverReq

+ 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.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 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 NewDefaultHiveParams() *HiveParams

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

+ 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 NewDefaultSyncParams() *SyncParams

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