set

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 13, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const Type = primitiveapi.PrimitiveType_SET

Type is the set primitive type

Variables

View Source 
var (
	ErrInvalidLengthSet        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSet          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSet = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ListenResponse_Type_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "REMOVED",
}
View Source 
var ListenResponse_Type_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"REMOVED": 2,
}

Functions

func RegisterPrimitive 

func RegisterPrimitive(node *atomix.Node)

RegisterPrimitive registers the primitive on the given node

Types

type AddRequest 

type AddRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*AddRequest) Descriptor 

func (*AddRequest) Descriptor() ([]byte, []int)

func (*AddRequest) GetValue 

func (m *AddRequest) GetValue() string

func (*AddRequest) Marshal 

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

func (*AddRequest) MarshalTo 

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

func (*AddRequest) MarshalToSizedBuffer 

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

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) Size 

func (m *AddRequest) Size() (n int)

func (*AddRequest) String 

func (m *AddRequest) String() string

func (*AddRequest) Unmarshal 

func (m *AddRequest) Unmarshal(dAtA []byte) error

func (*AddRequest) XXX_DiscardUnknown 

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal 

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

func (*AddRequest) XXX_Merge 

func (m *AddRequest) XXX_Merge(src proto.Message)

func (*AddRequest) XXX_Size 

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal 

func (m *AddRequest) XXX_Unmarshal(b []byte) error

type AddResponse 

type AddResponse struct {
	Added bool `protobuf:"varint,1,opt,name=added,proto3" json:"added,omitempty"`
}

func (*AddResponse) Descriptor 

func (*AddResponse) Descriptor() ([]byte, []int)

func (*AddResponse) GetAdded 

func (m *AddResponse) GetAdded() bool

func (*AddResponse) Marshal 

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

func (*AddResponse) MarshalTo 

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

func (*AddResponse) MarshalToSizedBuffer 

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

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) Size 

func (m *AddResponse) Size() (n int)

func (*AddResponse) String 

func (m *AddResponse) String() string

func (*AddResponse) Unmarshal 

func (m *AddResponse) Unmarshal(dAtA []byte) error

func (*AddResponse) XXX_DiscardUnknown 

func (m *AddResponse) XXX_DiscardUnknown()

func (*AddResponse) XXX_Marshal 

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

func (*AddResponse) XXX_Merge 

func (m *AddResponse) XXX_Merge(src proto.Message)

func (*AddResponse) XXX_Size 

func (m *AddResponse) XXX_Size() int

func (*AddResponse) XXX_Unmarshal 

func (m *AddResponse) XXX_Unmarshal(b []byte) error

type ClearRequest 

type ClearRequest struct {
}

func (*ClearRequest) Descriptor 

func (*ClearRequest) Descriptor() ([]byte, []int)

func (*ClearRequest) Marshal 

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

func (*ClearRequest) MarshalTo 

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

func (*ClearRequest) MarshalToSizedBuffer 

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

func (*ClearRequest) ProtoMessage 

func (*ClearRequest) ProtoMessage()

func (*ClearRequest) Reset 

func (m *ClearRequest) Reset()

func (*ClearRequest) Size 

func (m *ClearRequest) Size() (n int)

func (*ClearRequest) String 

func (m *ClearRequest) String() string

func (*ClearRequest) Unmarshal 

func (m *ClearRequest) Unmarshal(dAtA []byte) error

func (*ClearRequest) XXX_DiscardUnknown 

func (m *ClearRequest) XXX_DiscardUnknown()

func (*ClearRequest) XXX_Marshal 

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

func (*ClearRequest) XXX_Merge 

func (m *ClearRequest) XXX_Merge(src proto.Message)

func (*ClearRequest) XXX_Size 

func (m *ClearRequest) XXX_Size() int

func (*ClearRequest) XXX_Unmarshal 

func (m *ClearRequest) XXX_Unmarshal(b []byte) error

type ClearResponse 

type ClearResponse struct {
}

func (*ClearResponse) Descriptor 

func (*ClearResponse) Descriptor() ([]byte, []int)

func (*ClearResponse) Marshal 

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

func (*ClearResponse) MarshalTo 

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

func (*ClearResponse) MarshalToSizedBuffer 

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

func (*ClearResponse) ProtoMessage 

func (*ClearResponse) ProtoMessage()

func (*ClearResponse) Reset 

func (m *ClearResponse) Reset()

func (*ClearResponse) Size 

func (m *ClearResponse) Size() (n int)

func (*ClearResponse) String 

func (m *ClearResponse) String() string

func (*ClearResponse) Unmarshal 

func (m *ClearResponse) Unmarshal(dAtA []byte) error

func (*ClearResponse) XXX_DiscardUnknown 

func (m *ClearResponse) XXX_DiscardUnknown()

func (*ClearResponse) XXX_Marshal 

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

func (*ClearResponse) XXX_Merge 

func (m *ClearResponse) XXX_Merge(src proto.Message)

func (*ClearResponse) XXX_Size 

func (m *ClearResponse) XXX_Size() int

func (*ClearResponse) XXX_Unmarshal 

func (m *ClearResponse) XXX_Unmarshal(b []byte) error

type ContainsRequest 

type ContainsRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ContainsRequest) Descriptor 

func (*ContainsRequest) Descriptor() ([]byte, []int)

func (*ContainsRequest) GetValue 

func (m *ContainsRequest) GetValue() string

func (*ContainsRequest) Marshal 

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

func (*ContainsRequest) MarshalTo 

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

func (*ContainsRequest) MarshalToSizedBuffer 

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

func (*ContainsRequest) ProtoMessage 

func (*ContainsRequest) ProtoMessage()

func (*ContainsRequest) Reset 

func (m *ContainsRequest) Reset()

func (*ContainsRequest) Size 

func (m *ContainsRequest) Size() (n int)

func (*ContainsRequest) String 

func (m *ContainsRequest) String() string

func (*ContainsRequest) Unmarshal 

func (m *ContainsRequest) Unmarshal(dAtA []byte) error

func (*ContainsRequest) XXX_DiscardUnknown 

func (m *ContainsRequest) XXX_DiscardUnknown()

func (*ContainsRequest) XXX_Marshal 

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

func (*ContainsRequest) XXX_Merge 

func (m *ContainsRequest) XXX_Merge(src proto.Message)

func (*ContainsRequest) XXX_Size 

func (m *ContainsRequest) XXX_Size() int

func (*ContainsRequest) XXX_Unmarshal 

func (m *ContainsRequest) XXX_Unmarshal(b []byte) error

type ContainsResponse 

type ContainsResponse struct {
	Contains bool `protobuf:"varint,1,opt,name=contains,proto3" json:"contains,omitempty"`
}

func (*ContainsResponse) Descriptor 

func (*ContainsResponse) Descriptor() ([]byte, []int)

func (*ContainsResponse) GetContains 

func (m *ContainsResponse) GetContains() bool

func (*ContainsResponse) Marshal 

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

func (*ContainsResponse) MarshalTo 

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

func (*ContainsResponse) MarshalToSizedBuffer 

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

func (*ContainsResponse) ProtoMessage 

func (*ContainsResponse) ProtoMessage()

func (*ContainsResponse) Reset 

func (m *ContainsResponse) Reset()

func (*ContainsResponse) Size 

func (m *ContainsResponse) Size() (n int)

func (*ContainsResponse) String 

func (m *ContainsResponse) String() string

func (*ContainsResponse) Unmarshal 

func (m *ContainsResponse) Unmarshal(dAtA []byte) error

func (*ContainsResponse) XXX_DiscardUnknown 

func (m *ContainsResponse) XXX_DiscardUnknown()

func (*ContainsResponse) XXX_Marshal 

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

func (*ContainsResponse) XXX_Merge 

func (m *ContainsResponse) XXX_Merge(src proto.Message)

func (*ContainsResponse) XXX_Size 

func (m *ContainsResponse) XXX_Size() int

func (*ContainsResponse) XXX_Unmarshal 

func (m *ContainsResponse) XXX_Unmarshal(b []byte) error

type IterateRequest 

type IterateRequest struct {
}

func (*IterateRequest) Descriptor 

func (*IterateRequest) Descriptor() ([]byte, []int)

func (*IterateRequest) Marshal 

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

func (*IterateRequest) MarshalTo 

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

func (*IterateRequest) MarshalToSizedBuffer 

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

func (*IterateRequest) ProtoMessage 

func (*IterateRequest) ProtoMessage()

func (*IterateRequest) Reset 

func (m *IterateRequest) Reset()

func (*IterateRequest) Size 

func (m *IterateRequest) Size() (n int)

func (*IterateRequest) String 

func (m *IterateRequest) String() string

func (*IterateRequest) Unmarshal 

func (m *IterateRequest) Unmarshal(dAtA []byte) error

func (*IterateRequest) XXX_DiscardUnknown 

func (m *IterateRequest) XXX_DiscardUnknown()

func (*IterateRequest) XXX_Marshal 

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

func (*IterateRequest) XXX_Merge 

func (m *IterateRequest) XXX_Merge(src proto.Message)

func (*IterateRequest) XXX_Size 

func (m *IterateRequest) XXX_Size() int

func (*IterateRequest) XXX_Unmarshal 

func (m *IterateRequest) XXX_Unmarshal(b []byte) error

type IterateResponse 

type IterateResponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*IterateResponse) Descriptor 

func (*IterateResponse) Descriptor() ([]byte, []int)

func (*IterateResponse) GetValue 

func (m *IterateResponse) GetValue() string

func (*IterateResponse) Marshal 

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

func (*IterateResponse) MarshalTo 

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

func (*IterateResponse) MarshalToSizedBuffer 

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

func (*IterateResponse) ProtoMessage 

func (*IterateResponse) ProtoMessage()

func (*IterateResponse) Reset 

func (m *IterateResponse) Reset()

func (*IterateResponse) Size 

func (m *IterateResponse) Size() (n int)

func (*IterateResponse) String 

func (m *IterateResponse) String() string

func (*IterateResponse) Unmarshal 

func (m *IterateResponse) Unmarshal(dAtA []byte) error

func (*IterateResponse) XXX_DiscardUnknown 

func (m *IterateResponse) XXX_DiscardUnknown()

func (*IterateResponse) XXX_Marshal 

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

func (*IterateResponse) XXX_Merge 

func (m *IterateResponse) XXX_Merge(src proto.Message)

func (*IterateResponse) XXX_Size 

func (m *IterateResponse) XXX_Size() int

func (*IterateResponse) XXX_Unmarshal 

func (m *IterateResponse) XXX_Unmarshal(b []byte) error

type ListenRequest 

type ListenRequest struct {
	Replay bool `protobuf:"varint,1,opt,name=replay,proto3" json:"replay,omitempty"`
}

func (*ListenRequest) Descriptor 

func (*ListenRequest) Descriptor() ([]byte, []int)

func (*ListenRequest) GetReplay 

func (m *ListenRequest) GetReplay() bool

func (*ListenRequest) Marshal 

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

func (*ListenRequest) MarshalTo 

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

func (*ListenRequest) MarshalToSizedBuffer 

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

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) Size 

func (m *ListenRequest) Size() (n int)

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) Unmarshal 

func (m *ListenRequest) Unmarshal(dAtA []byte) error

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

func (m *ListenRequest) XXX_Merge(src proto.Message)

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

func (m *ListenRequest) XXX_Unmarshal(b []byte) error

type ListenResponse 

type ListenResponse struct {
	Type  ListenResponse_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.set.service.ListenResponse_Type" json:"type,omitempty"`
	Value string              `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ListenResponse) Descriptor 

func (*ListenResponse) Descriptor() ([]byte, []int)

func (*ListenResponse) GetType 

func (m *ListenResponse) GetType() ListenResponse_Type

func (*ListenResponse) GetValue 

func (m *ListenResponse) GetValue() string

func (*ListenResponse) Marshal 

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

func (*ListenResponse) MarshalTo 

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

func (*ListenResponse) MarshalToSizedBuffer 

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

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset 

func (m *ListenResponse) Reset()

func (*ListenResponse) Size 

func (m *ListenResponse) Size() (n int)

func (*ListenResponse) String 

func (m *ListenResponse) String() string

func (*ListenResponse) Unmarshal 

func (m *ListenResponse) Unmarshal(dAtA []byte) error

func (*ListenResponse) XXX_DiscardUnknown 

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal 

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

func (*ListenResponse) XXX_Merge 

func (m *ListenResponse) XXX_Merge(src proto.Message)

func (*ListenResponse) XXX_Size 

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal 

func (m *ListenResponse) XXX_Unmarshal(b []byte) error

type ListenResponse_Type 

type ListenResponse_Type int32
const (
	ListenResponse_NONE    ListenResponse_Type = 0
	ListenResponse_ADDED   ListenResponse_Type = 1
	ListenResponse_REMOVED ListenResponse_Type = 2
)

func (ListenResponse_Type) EnumDescriptor 

func (ListenResponse_Type) EnumDescriptor() ([]byte, []int)

func (ListenResponse_Type) String 

func (x ListenResponse_Type) String() string

type Primitive 

type Primitive struct{}

Primitive is the counter primitive

func (*Primitive) NewService 

func (p *Primitive) NewService(scheduler primitive.Scheduler, context primitive.ServiceContext) primitive.Service

NewService creates a new set service

func (*Primitive) RegisterServer 

func (p *Primitive) RegisterServer(server *grpc.Server, protocol primitive.Protocol)

RegisterServer registers the set server with the protocol

type RemoveRequest 

type RemoveRequest struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RemoveRequest) Descriptor 

func (*RemoveRequest) Descriptor() ([]byte, []int)

func (*RemoveRequest) GetValue 

func (m *RemoveRequest) GetValue() string

func (*RemoveRequest) Marshal 

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

func (*RemoveRequest) MarshalTo 

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

func (*RemoveRequest) MarshalToSizedBuffer 

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

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) Size 

func (m *RemoveRequest) Size() (n int)

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) Unmarshal 

func (m *RemoveRequest) Unmarshal(dAtA []byte) error

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

func (m *RemoveRequest) XXX_Merge(src proto.Message)

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

func (m *RemoveRequest) XXX_Unmarshal(b []byte) error

type RemoveResponse 

type RemoveResponse struct {
	Removed bool `protobuf:"varint,1,opt,name=removed,proto3" json:"removed,omitempty"`
}

func (*RemoveResponse) Descriptor 

func (*RemoveResponse) Descriptor() ([]byte, []int)

func (*RemoveResponse) GetRemoved 

func (m *RemoveResponse) GetRemoved() bool

func (*RemoveResponse) Marshal 

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

func (*RemoveResponse) MarshalTo 

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

func (*RemoveResponse) MarshalToSizedBuffer 

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

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) Reset 

func (m *RemoveResponse) Reset()

func (*RemoveResponse) Size 

func (m *RemoveResponse) Size() (n int)

func (*RemoveResponse) String 

func (m *RemoveResponse) String() string

func (*RemoveResponse) Unmarshal 

func (m *RemoveResponse) Unmarshal(dAtA []byte) error

func (*RemoveResponse) XXX_DiscardUnknown 

func (m *RemoveResponse) XXX_DiscardUnknown()

func (*RemoveResponse) XXX_Marshal 

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

func (*RemoveResponse) XXX_Merge 

func (m *RemoveResponse) XXX_Merge(src proto.Message)

func (*RemoveResponse) XXX_Size 

func (m *RemoveResponse) XXX_Size() int

func (*RemoveResponse) XXX_Unmarshal 

func (m *RemoveResponse) XXX_Unmarshal(b []byte) error

type Server 

type Server struct {
	*primitive.Server
}

Server is an implementation of SetServiceServer for the set primitive

func (*Server) Add 

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

Add adds an element to the set

func (*Server) Clear 

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

Clear removes all elements from the set

func (*Server) Close 

func (s *Server) Close(ctx context.Context, request *api.CloseRequest) (*api.CloseResponse, error)

Close closes a session

func (*Server) Contains 

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

Contains checks whether the set contains an element

func (*Server) Create 

func (s *Server) Create(ctx context.Context, request *api.CreateRequest) (*api.CreateResponse, error)

Create opens a new session

func (*Server) Events 

func (s *Server) Events(request *api.EventRequest, srv api.SetService_EventsServer) error

Events listens for set change events

func (*Server) Iterate 

func (s *Server) Iterate(request *api.IterateRequest, srv api.SetService_IterateServer) error

Iterate lists all elements currently in the set

func (*Server) Remove 

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

Remove removes an element from the set

func (*Server) Size 

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

Size gets the number of elements in the set

type Service 

type Service struct {
	primitive.Service
	// contains filtered or unexported fields
}

Service is a state machine for a list primitive

func (*Service) Add 

func (s *Service) Add(bytes []byte) ([]byte, error)

Add adds an element to the set

func (*Service) Backup 

func (s *Service) Backup(writer io.Writer) error

Backup takes a snapshot of the service

func (*Service) Clear 

func (s *Service) Clear(bytes []byte) ([]byte, error)

Clear removes all elements from the set

func (*Service) Contains 

func (s *Service) Contains(bytes []byte) ([]byte, error)

Contains checks whether the set contains an element

func (*Service) Events 

func (s *Service) Events(bytes []byte, stream primitive.Stream)

Events registers a channel on which to send set change events

func (*Service) Iterate 

func (s *Service) Iterate(bytes []byte, stream primitive.Stream)

Iterate sends all current set elements on the given channel

func (*Service) Remove 

func (s *Service) Remove(bytes []byte) ([]byte, error)

Remove removes an element from the set

func (*Service) Restore 

func (s *Service) Restore(reader io.Reader) error

Restore restores the service from a snapshot

func (*Service) Size 

func (s *Service) Size(bytes []byte) ([]byte, error)

Size gets the number of elements in the set

type SetSnapshot 

type SetSnapshot struct {
	Values map[string]bool `` /* 154-byte string literal not displayed */
}

Set snapshot

func (*SetSnapshot) Descriptor 

func (*SetSnapshot) Descriptor() ([]byte, []int)

func (*SetSnapshot) GetValues 

func (m *SetSnapshot) GetValues() map[string]bool

func (*SetSnapshot) Marshal 

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

func (*SetSnapshot) MarshalTo 

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

func (*SetSnapshot) MarshalToSizedBuffer 

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

func (*SetSnapshot) ProtoMessage 

func (*SetSnapshot) ProtoMessage()

func (*SetSnapshot) Reset 

func (m *SetSnapshot) Reset()

func (*SetSnapshot) Size 

func (m *SetSnapshot) Size() (n int)

func (*SetSnapshot) String 

func (m *SetSnapshot) String() string

func (*SetSnapshot) Unmarshal 

func (m *SetSnapshot) Unmarshal(dAtA []byte) error

func (*SetSnapshot) XXX_DiscardUnknown 

func (m *SetSnapshot) XXX_DiscardUnknown()

func (*SetSnapshot) XXX_Marshal 

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

func (*SetSnapshot) XXX_Merge 

func (m *SetSnapshot) XXX_Merge(src proto.Message)

func (*SetSnapshot) XXX_Size 

func (m *SetSnapshot) XXX_Size() int

func (*SetSnapshot) XXX_Unmarshal 

func (m *SetSnapshot) XXX_Unmarshal(b []byte) error

type SizeRequest 

type SizeRequest struct {
}

func (*SizeRequest) Descriptor 

func (*SizeRequest) Descriptor() ([]byte, []int)

func (*SizeRequest) Marshal 

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

func (*SizeRequest) MarshalTo 

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

func (*SizeRequest) MarshalToSizedBuffer 

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

func (*SizeRequest) ProtoMessage 

func (*SizeRequest) ProtoMessage()

func (*SizeRequest) Reset 

func (m *SizeRequest) Reset()

func (*SizeRequest) Size 

func (m *SizeRequest) Size() (n int)

func (*SizeRequest) String 

func (m *SizeRequest) String() string

func (*SizeRequest) Unmarshal 

func (m *SizeRequest) Unmarshal(dAtA []byte) error

func (*SizeRequest) XXX_DiscardUnknown 

func (m *SizeRequest) XXX_DiscardUnknown()

func (*SizeRequest) XXX_Marshal 

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

func (*SizeRequest) XXX_Merge 

func (m *SizeRequest) XXX_Merge(src proto.Message)

func (*SizeRequest) XXX_Size 

func (m *SizeRequest) XXX_Size() int

func (*SizeRequest) XXX_Unmarshal 

func (m *SizeRequest) XXX_Unmarshal(b []byte) error

type SizeResponse 

type SizeResponse struct {
	Size_ uint32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
}

func (*SizeResponse) Descriptor 

func (*SizeResponse) Descriptor() ([]byte, []int)

func (*SizeResponse) GetSize_ 

func (m *SizeResponse) GetSize_() uint32

func (*SizeResponse) Marshal 

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

func (*SizeResponse) MarshalTo 

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

func (*SizeResponse) MarshalToSizedBuffer 

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

func (*SizeResponse) ProtoMessage 

func (*SizeResponse) ProtoMessage()

func (*SizeResponse) Reset 

func (m *SizeResponse) Reset()

func (*SizeResponse) Size 

func (m *SizeResponse) Size() (n int)

func (*SizeResponse) String 

func (m *SizeResponse) String() string

func (*SizeResponse) Unmarshal 

func (m *SizeResponse) Unmarshal(dAtA []byte) error

func (*SizeResponse) XXX_DiscardUnknown 

func (m *SizeResponse) XXX_DiscardUnknown()

func (*SizeResponse) XXX_Marshal 

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

func (*SizeResponse) XXX_Merge 

func (m *SizeResponse) XXX_Merge(src proto.Message)

func (*SizeResponse) XXX_Size 

func (m *SizeResponse) XXX_Size() int

func (*SizeResponse) XXX_Unmarshal 

func (m *SizeResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.