counter

type CounterState struct {
	meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Increments      map[string]int64 `` /* 162-byte string literal not displayed */
	Decrements      map[string]int64 `` /* 162-byte string literal not displayed */
}

type GossipClient interface {
	Bootstrap(ctx context.Context) (*CounterState, error)
	Repair(ctx context.Context, state *CounterState) (*CounterState, error)
	Advertise(ctx context.Context, state *CounterState) error
	Update(ctx context.Context, state *CounterState) 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) (*CounterState, error)
	Update(ctx context.Context, state *CounterState) 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 counter value
	Set(context.Context, *counter.SetRequest) (*counter.SetResponse, error)
	// Get gets the current counter value
	Get(context.Context, *counter.GetRequest) (*counter.GetResponse, error)
	// Increment increments the counter value
	Increment(context.Context, *counter.IncrementRequest) (*counter.IncrementResponse, error)
	// Decrement decrements the counter value
	Decrement(context.Context, *counter.DecrementRequest) (*counter.DecrementResponse, error)
}