Versions in this module Expand all Collapse all v1 v1.4.6 Feb 25, 2020 Changes in this version + func SelectEndpoints(k int, peerPool []discovery.NetworkMember) []*comm.RemotePeer + type Config struct + Channel common.ChainID + ID string + MsgType proto.PullMsgType + PeerCountToSelect int + PullEngineConfig algo.PullEngineConfig + PullInterval time.Duration + Tag proto.GossipMessage_Tag + type EgressDigestFilter func(helloMsg proto.ReceivedMessage) func(digestItem string) bool + type IngressDigestFilter func(digestMsg *proto.DataDigest) *proto.DataDigest + type Mediator interface + Add func(*proto.SignedGossipMessage) + HandleMessage func(msg proto.ReceivedMessage) + RegisterMsgHook func(MsgType, MessageHook) + Remove func(digest string) + Stop func() + func NewPullMediator(config Config, adapter *PullAdapter) Mediator + type MembershipService interface + GetMembership func() []discovery.NetworkMember + type MessageHook func(itemIDs []string, items []*proto.SignedGossipMessage, ...) + type MsgType int + const DigestMsgType + const HelloMsgType + const RequestMsgType + const ResponseMsgType + type PullAdapter struct + EgressDigFilter EgressDigestFilter + IdExtractor proto.IdentifierExtractor + IngressDigFilter IngressDigestFilter + MemSvc MembershipService + MsgCons proto.MsgConsumer + Sndr Sender + type Sender interface + Send func(msg *proto.SignedGossipMessage, peers ...*comm.RemotePeer) Incompatible versions in this module v2.0.1+incompatible Feb 26, 2020
Go to main page