value

type GossipClient interface {
	Bootstrap(ctx context.Context) (*ValueState, error)
	Repair(ctx context.Context, state *ValueState) (*ValueState, error)
	Advertise(ctx context.Context, state *ValueState) error
	Update(ctx context.Context, state *ValueState) 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) (*ValueState, error)
	Update(ctx context.Context, state *ValueState) 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
	// Set sets the value
	Set(context.Context, *value.SetRequest) (*value.SetResponse, error)
	// Get gets the value
	Get(context.Context, *value.GetRequest) (*value.GetResponse, error)
	// Events listens for value change events
	Events(context.Context, *value.EventsRequest, chan<- value.EventsResponse) error
}

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