Versions in this module Expand all Collapse all v1 v1.4.9 Sep 30, 2020 Changes in this version + const DefDigestWaitTime + const DefRequestWaitTime + const DefResponseWaitTime + type DigestFilter func(context interface{}) func(digestItem string) bool + type PullAdapter interface + Hello func(dest string, nonce uint64) + SelectPeers func() []string + SendDigest func(digest []string, nonce uint64, context interface{}) + SendReq func(dest string, items []string, nonce uint64) + SendRes func(items []string, context interface{}, nonce uint64) + type PullEngine struct + func NewPullEngine(participant PullAdapter, sleepTime time.Duration, config PullEngineConfig) *PullEngine + func NewPullEngineWithFilter(participant PullAdapter, sleepTime time.Duration, df DigestFilter, ...) *PullEngine + func (engine *PullEngine) Add(seqs ...string) + func (engine *PullEngine) OnDigest(digest []string, nonce uint64, context interface{}) + func (engine *PullEngine) OnHello(nonce uint64, context interface{}) + func (engine *PullEngine) OnReq(items []string, nonce uint64, context interface{}) + func (engine *PullEngine) OnRes(items []string, nonce uint64) + func (engine *PullEngine) Remove(seqs ...string) + func (engine *PullEngine) Stop() + type PullEngineConfig struct + DigestWaitTime time.Duration + RequestWaitTime time.Duration + ResponseWaitTime time.Duration Incompatible versions in this module v2.1.1+incompatible Jun 1, 2020