_map

type GossipClient interface {
	Bootstrap(ctx context.Context, ch chan<- MapEntry) error
	Repair(ctx context.Context, state *MapEntry) (*MapEntry, error)
	Advertise(ctx context.Context, state *MapEntry) error
	Update(ctx context.Context, state *MapEntry) 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) (*MapEntry, error)
	List(ctx context.Context, ch chan<- MapEntry) error
	Update(ctx context.Context, entry *MapEntry) 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 MapEntry struct {
	Key   MapKey    `protobuf:"bytes,1,opt,name=key,proto3" json:"key"`
	Value *MapValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

type MapKey struct {
	meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Key             string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

type MapValue struct {
	Value []byte         `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	TTL   *time.Duration `protobuf:"bytes,2,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"`
}

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

type Service interface {
	gossip.Service
	Protocol() GossipProtocol
	// Size returns the size of the map
	Size(context.Context, *_map.SizeRequest) (*_map.SizeResponse, error)
	// Put puts an entry into the map
	Put(context.Context, *_map.PutRequest) (*_map.PutResponse, error)
	// Get gets the entry for a key
	Get(context.Context, *_map.GetRequest) (*_map.GetResponse, error)
	// Remove removes an entry from the map
	Remove(context.Context, *_map.RemoveRequest) (*_map.RemoveResponse, error)
	// Clear removes all entries from the map
	Clear(context.Context, *_map.ClearRequest) (*_map.ClearResponse, error)
	// Events listens for change events
	Events(context.Context, *_map.EventsRequest, chan<- _map.EventsResponse) error
	// Entries lists all entries in the map
	Entries(context.Context, *_map.EntriesRequest, chan<- _map.EntriesResponse) error
}