entry

May 3, 2020

Changes in this version

type DefaultHolder

+ func (d *DefaultHolder) MaxParallelPulls() uint32

+ func (d *DefaultHolder) PushTracker() PendingPushTracker

+ func (d *DefaultHolder) SupportPendingRequests() bool

+ type DefaultPushTracker struct

+ func NewDefaultPushTracker(pullDelay time.Duration) *DefaultPushTracker

+ func (d *DefaultPushTracker) AddPendingPush(id peer.ID, hash common.Hash128)

+ func (d *DefaultPushTracker) RegisterPull(hash common.Hash128)

+ func (d *DefaultPushTracker) RemovePull(hash common.Hash128)

+ func (d *DefaultPushTracker) Requests() chan PendingPulls

+ func (d *DefaultPushTracker) Run()

+ func (d *DefaultPushTracker) SetHolder(holder Holder)

type Holder

+ MaxParallelPulls func() uint32

+ PushTracker func() PendingPushTracker

+ SupportPendingRequests func() bool

+ type PendingPulls struct

+ Hash common.Hash128

+ Id peer.ID

+ type PendingPushTracker interface

+ AddPendingPush func(id peer.ID, hash common.Hash128)

+ RegisterPull func(hash common.Hash128)

+ RemovePull func(hash common.Hash128)

+ Requests func() chan PendingPulls

+ Run func()

+ SetHolder func(holder Holder)

Apr 3, 2020

Changes in this version

+ type DefaultHolder struct

+ func (d *DefaultHolder) Add(hash common.Hash128, entry interface{})

+ func (d *DefaultHolder) Get(hash common.Hash128) (interface{}, bool)

+ func (d *DefaultHolder) Has(hash common.Hash128) bool

+ func (d *DefaultHolder) MaxPulls() uint32

+ type Holder interface

+ Add func(hash common.Hash128, entry interface{})

+ Get func(hash common.Hash128) (interface{}, bool)

+ Has func(hash common.Hash128) bool

+ MaxPulls func() uint32

+ func NewDefaultHolder(maxPulls int) Holder