set

type GossipClient interface {
	Bootstrap(ctx context.Context, ch chan<- SetElement) error
	Repair(ctx context.Context, state *SetElement) (*SetElement, error)
	Advertise(ctx context.Context, state *SetElement) error
	Update(ctx context.Context, state *SetElement) error
}

type GossipEngine interface {
	// contains filtered or unexported methods
}

type GossipGroup interface {
	GossipClient
	MemberID() GossipMemberID
	Members() []GossipMember
	Member(GossipMemberID) GossipMember
}

type GossipHandler interface {
	Read(ctx context.Context, key string) (*SetElement, error)
	List(ctx context.Context, ch chan<- SetElement) error
	Update(ctx context.Context, entry *SetElement) error
}

type GossipMember interface {
	GossipClient
	ID() GossipMemberID
	Client() *gossip.Peer
}

type GossipMemberID gossip.PeerID

type GossipProtocol interface {
	Clock() atime.Clock
	Group() GossipGroup
	Server() GossipServer
}

type GossipServer interface {
	Register(GossipHandler) error
	// contains filtered or unexported methods
}

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

type Service interface {
	gossip.Service
	Protocol() GossipProtocol
	// Size gets the number of elements in the set
	Size(context.Context, *set.SizeRequest) (*set.SizeResponse, error)
	// Contains returns whether the set contains a value
	Contains(context.Context, *set.ContainsRequest) (*set.ContainsResponse, error)
	// Add adds a value to the set
	Add(context.Context, *set.AddRequest) (*set.AddResponse, error)
	// Remove removes a value from the set
	Remove(context.Context, *set.RemoveRequest) (*set.RemoveResponse, error)
	// Clear removes all values from the set
	Clear(context.Context, *set.ClearRequest) (*set.ClearResponse, error)
	// Events listens for set change events
	Events(context.Context, *set.EventsRequest, chan<- set.EventsResponse) error
	// Elements lists all elements in the set
	Elements(context.Context, *set.ElementsRequest, chan<- set.ElementsResponse) error
}

type SetElement struct {
	meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Value           string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}