gossip_model

type Digest interface{}

type Model struct {
	sync.Mutex
	ReadOnly bool
	// contains filtered or unexported fields
}

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

type PullerHelper interface {
	EncodeDigest(Digest) proto.Message
	//Handle method in PullerHandler is ensured to be called
	CanPull() *Puller
}

type PushHelper interface {
	PullerHelper
	//must allow nil input and encode an message include "empty" update
	EncodeUpdate(Update) proto.Message
}

type ScuttlebuttDigest interface {
	GlobalDigest() Digest
	PeerDigest() []peersDig
	IsPartial() bool
}

type ScuttlebuttPeerStatus interface {
	To() VClock
	PickFrom(VClock, Update) (ScuttlebuttPeerUpdate, Update)
	Update(string, ScuttlebuttPeerUpdate, ScuttlebuttStatus) error
}

type ScuttlebuttPeerUpdate interface {
	To() VClock
}

type ScuttlebuttStatus interface {
	Status
	NewPeer(string) ScuttlebuttPeerStatus
	RemovePeer(string, ScuttlebuttPeerStatus)
	MissedUpdate(string, ScuttlebuttPeerUpdate) error
}

type ScuttlebuttUpdate interface {
	GlobalUpdate() Update
	PeerUpdate() []peersUpdate
}

type Status interface {
	GenDigest() Digest
	Update(Update) error
	MakeUpdate(Digest) Update
}

type TestPeer interface {
	CreateModel() *Model
	LocalUpdate(ks []string)
	DumpPeers() []string
	DumpSelfData() map[string]int
	DumpData() map[string]int
}

type Test_Scuttlebutt struct {
	Peers map[string]*Test_Scuttlebutt_Peer `` /* 130-byte string literal not displayed */
}

type Test_Scuttlebutt_Peer struct {
	Datas map[string]int32 `` /* 131-byte string literal not displayed */
}

type Update interface {
	Gossip_IsUpdateIn() bool
}

type VClock interface {
	Less(VClock) bool //VClock can be NEVER less than nil (indicate to "oldest" time)
}