gossip

type CatalogHandler interface {
	Name() string
	Model() *model.Model
	//just notify the model is updated
	SelfUpdate(...*pb.PeerID)
	HandleUpdate(*pb.GossipMsg_Update, CatalogPeerPolicies)
	HandleDigest(*pb.StreamHandler, *pb.GossipMsg_Digest, CatalogPeerPolicies)
}

type CatalogHelper interface {
	Name() string
	GetPolicies() CatalogPolicies //caller do not need to check the interface

	TransDigestToPb(model.Digest) *pb.GossipMsg_Digest
	TransPbToDigest(*pb.GossipMsg_Digest) model.Digest

	TransUpdateToPb(CatalogPeerPolicies, model.Update) *pb.GossipMsg_Update
	TransPbToUpdate(CatalogPeerPolicies, *pb.GossipMsg_Update) (model.Update, error)
}

type CatalogPeerPolicies interface {
	GetId() string //equal to peerId.GetName()
	AllowRecvUpdate() bool
	PushUpdateQuota() int
	PushUpdate(int)
	RecordViolation(error)
	ScoringPeer(s int, weight uint)
}

type CatalogPolicies interface {
	AllowRecvUpdate() bool //the catalogy allow response a pull when accepting pulling from far-end
	PushCount() int        //how many push expected to do in one schedule gossip work
	MaxTrackPeers() int    //how many peers the catalog should track
	PullTimeout() int      //in seconds
}

type GossipHandler interface {
	HandleMessage(*pb.StreamHandler, *pb.GossipMsg) error
	Stop()
}

type GossipStub struct {
	*pb.StreamStub
	peerACL.AccessControl
	// contains filtered or unexported fields
}

type PeerPolicies interface {
	GetId() string
	IsPolicyViolated() error
	RecvUpdate(int)
	RecordViolation(e error)
	AllowRecvUpdate() bool
	PushUpdateQuota() int
	PushUpdate(int)
	ScoringPeer(int, uint)
	ResetIntervals(int)
}