network

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)

Nov 15, 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