set

May 29, 2021

Changes in this version

type Service

+ Protocol func() GossipProtocol

May 15, 2021

Changes in this version

+ const ServiceType

+ var ErrIntOverflowState = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupState = fmt.Errorf("proto: unexpected end of group")

+ func RegisterServer(node *gossip.Node)

+ func RegisterService(node *gossip.Node)

+ type GossipClient interface

+ Advertise func(ctx context.Context, state *SetElement) error

+ Bootstrap func(ctx context.Context, ch chan<- SetElement) error

+ Repair func(ctx context.Context, state *SetElement) (*SetElement, error)

+ Update func(ctx context.Context, state *SetElement) error

+ type GossipEngine interface

+ type GossipGroup interface

+ Member func(GossipMemberID) GossipMember

+ MemberID func() GossipMemberID

+ Members func() []GossipMember

+ type GossipHandler interface

+ List func(ctx context.Context, ch chan<- SetElement) error

+ Read func(ctx context.Context, key string) (*SetElement, error)

+ Update func(ctx context.Context, entry *SetElement) error

+ type GossipMember interface

+ Client func() *gossip.Peer

+ ID func() GossipMemberID

+ type GossipMemberID gossip.PeerID

+ func (i GossipMemberID) String() string

+ type GossipProtocol interface

+ Clock func() atime.Clock

+ Group func() GossipGroup

+ Server func() GossipServer

+ type GossipServer interface

+ Register func(GossipHandler) error

+ type Server struct

+ func (s *Server) Add(ctx context.Context, request *set.AddRequest) (*set.AddResponse, error)

+ func (s *Server) Clear(ctx context.Context, request *set.ClearRequest) (*set.ClearResponse, error)

+ func (s *Server) Contains(ctx context.Context, request *set.ContainsRequest) (*set.ContainsResponse, error)

+ func (s *Server) Elements(request *set.ElementsRequest, srv set.SetService_ElementsServer) error

+ func (s *Server) Events(request *set.EventsRequest, srv set.SetService_EventsServer) error

+ func (s *Server) Remove(ctx context.Context, request *set.RemoveRequest) (*set.RemoveResponse, error)

+ func (s *Server) Size(ctx context.Context, request *set.SizeRequest) (*set.SizeResponse, error)

+ type Service interface

+ Add func(context.Context, *set.AddRequest) (*set.AddResponse, error)

+ Clear func(context.Context, *set.ClearRequest) (*set.ClearResponse, error)

+ Contains func(context.Context, *set.ContainsRequest) (*set.ContainsResponse, error)

+ Elements func(context.Context, *set.ElementsRequest, chan<- set.ElementsResponse) error

+ Events func(context.Context, *set.EventsRequest, chan<- set.EventsResponse) error

+ Remove func(context.Context, *set.RemoveRequest) (*set.RemoveResponse, error)

+ Size func(context.Context, *set.SizeRequest) (*set.SizeResponse, error)

+ type SetElement struct

+ Value string

+ func (*SetElement) Descriptor() ([]byte, []int)

+ func (*SetElement) ProtoMessage()

+ func (m *SetElement) GetValue() string

+ func (m *SetElement) Marshal() (dAtA []byte, err error)

+ func (m *SetElement) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetElement) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetElement) Reset()

+ func (m *SetElement) Size() (n int)

+ func (m *SetElement) String() string

+ func (m *SetElement) Unmarshal(dAtA []byte) error

+ func (m *SetElement) XXX_DiscardUnknown()

+ func (m *SetElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetElement) XXX_Merge(src proto.Message)

+ func (m *SetElement) XXX_Size() int

+ func (m *SetElement) XXX_Unmarshal(b []byte) error