pull

type Config struct {
	ID                string
	PullInterval      time.Duration
	Channel           common.ChannelID
	PeerCountToSelect int
	Tag               proto.GossipMessage_Tag
	MsgType           proto.PullMsgType
	PullEngineConfig  algo.PullEngineConfig
}

type EgressDigestFilter func(helloMsg protoext.ReceivedMessage) func(digestItem string) bool

type IdentifierExtractor func(*protoext.SignedGossipMessage) string

type IngressDigestFilter func(digestMsg *proto.DataDigest) *proto.DataDigest

type Mediator interface {
	Stop()

	RegisterMsgHook(MsgType, MessageHook)

	Add(*protoext.SignedGossipMessage)

	Remove(digest string)

	HandleMessage(msg protoext.ReceivedMessage)
}

type MembershipService interface {
	GetMembership() []discovery.NetworkMember
}

type MessageHook func(itemIDs []string, items []*protoext.SignedGossipMessage, msg protoext.ReceivedMessage)

type MsgConsumer func(message *protoext.SignedGossipMessage)

type MsgType int

type PullAdapter struct {
	Sndr             Sender
	MemSvc           MembershipService
	IdExtractor      IdentifierExtractor
	MsgCons          MsgConsumer
	EgressDigFilter  EgressDigestFilter
	IngressDigFilter IngressDigestFilter
}

type Sender interface {
	Send(msg *protoext.SignedGossipMessage, peers ...*comm.RemotePeer)
}