pushpull

type DefaultHolder struct {
	// contains filtered or unexported fields
}

type DefaultPushTracker struct {
	// contains filtered or unexported fields
}

type Holder interface {
	Add(hash common.Hash128, entry interface{}, shardId common.ShardId, highPriority bool)
	Has(hash common.Hash128) bool
	Get(hash common.Hash128) (entry interface{}, shardId common.ShardId, highPriority bool, present bool)
	MaxParallelPulls() uint32
	SupportPendingRequests() bool
	PushTracker() PendingPushTracker
}

type PendingPulls struct {
	Id   peer.ID
	Hash common.Hash128
}

type PendingPushTracker interface {
	RegisterPull(hash common.Hash128)
	AddPendingPush(id peer.ID, hash common.Hash128)
	Requests() chan PendingPulls
	Run()
	SetHolder(holder Holder)
	RemovePull(hash common.Hash128)
}