Versions in this module Expand all Collapse all v1 v1.5.99 Aug 25, 2017 v1.5.97 Apr 24, 2017 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
Go to main page