set

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrimitive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrimitive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Event_Type_name = map[int32]string{
	0: "NONE",
	1: "ADD",
	2: "REMOVE",
	3: "REPLAY",
}
View Source 
var Event_Type_value = map[string]int32{
	"NONE":   0,
	"ADD":    1,
	"REMOVE": 2,
	"REPLAY": 3,
}
View Source 
var SetCacheStrategy_name = map[int32]string{
	0: "NEAR",
	1: "READ_THROUGH",
	2: "WRITE_THROUGH",
	3: "READ_THROUGH_WRITE_THROUGH",
}
View Source 
var SetCacheStrategy_value = map[string]int32{
	"NEAR":                       0,
	"READ_THROUGH":               1,
	"WRITE_THROUGH":              2,
	"READ_THROUGH_WRITE_THROUGH": 3,
}

Functions

func RegisterSetManagerServer added in v0.7.0 

func RegisterSetManagerServer(s *grpc.Server, srv SetManagerServer)

func RegisterSetServer 

func RegisterSetServer(s *grpc.Server, srv SetServer)

Types

type AddRequest 

type AddRequest struct {
	Element Element `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*AddRequest) Descriptor 

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

func (*AddRequest) GetElement 

func (m *AddRequest) GetElement() Element

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 {
	Element Element `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*AddResponse) Descriptor 

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

func (*AddResponse) GetElement 

func (m *AddResponse) GetElement() Element

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 CloseSessionRequest 

type CloseSessionRequest struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

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

func (*CloseSessionRequest) MarshalToSizedBuffer 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

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

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

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

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

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

func (*CloseSessionRequest) XXX_Merge 

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

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

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

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

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

func (*CloseSessionResponse) MarshalToSizedBuffer 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

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

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

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

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

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

func (*CloseSessionResponse) XXX_Merge 

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

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

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

type ContainsRequest 

type ContainsRequest struct {
	Element Element `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*ContainsRequest) Descriptor 

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

func (*ContainsRequest) GetElement 

func (m *ContainsRequest) GetElement() Element

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,2,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 Element 

type Element struct {
	v1.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"`
	Value         string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Element) Descriptor 

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

func (*Element) GetValue 

func (m *Element) GetValue() string

func (*Element) Marshal 

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

func (*Element) MarshalTo 

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

func (*Element) MarshalToSizedBuffer 

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

func (*Element) ProtoMessage 

func (*Element) ProtoMessage()

func (*Element) Reset 

func (m *Element) Reset()

func (*Element) Size 

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

func (*Element) String 

func (m *Element) String() string

func (*Element) Unmarshal 

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

func (*Element) XXX_DiscardUnknown 

func (m *Element) XXX_DiscardUnknown()

func (*Element) XXX_Marshal 

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

func (*Element) XXX_Merge 

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

func (*Element) XXX_Size 

func (m *Element) XXX_Size() int

func (*Element) XXX_Unmarshal 

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

type ElementsRequest 

type ElementsRequest struct {
}

func (*ElementsRequest) Descriptor 

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

func (*ElementsRequest) Marshal 

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

func (*ElementsRequest) MarshalTo 

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

func (*ElementsRequest) MarshalToSizedBuffer 

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

func (*ElementsRequest) ProtoMessage 

func (*ElementsRequest) ProtoMessage()

func (*ElementsRequest) Reset 

func (m *ElementsRequest) Reset()

func (*ElementsRequest) Size 

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

func (*ElementsRequest) String 

func (m *ElementsRequest) String() string

func (*ElementsRequest) Unmarshal 

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

func (*ElementsRequest) XXX_DiscardUnknown 

func (m *ElementsRequest) XXX_DiscardUnknown()

func (*ElementsRequest) XXX_Marshal 

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

func (*ElementsRequest) XXX_Merge 

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

func (*ElementsRequest) XXX_Size 

func (m *ElementsRequest) XXX_Size() int

func (*ElementsRequest) XXX_Unmarshal 

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

type ElementsResponse 

type ElementsResponse struct {
	Element Element `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*ElementsResponse) Descriptor 

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

func (*ElementsResponse) GetElement 

func (m *ElementsResponse) GetElement() Element

func (*ElementsResponse) Marshal 

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

func (*ElementsResponse) MarshalTo 

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

func (*ElementsResponse) MarshalToSizedBuffer 

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

func (*ElementsResponse) ProtoMessage 

func (*ElementsResponse) ProtoMessage()

func (*ElementsResponse) Reset 

func (m *ElementsResponse) Reset()

func (*ElementsResponse) Size 

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

func (*ElementsResponse) String 

func (m *ElementsResponse) String() string

func (*ElementsResponse) Unmarshal 

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

func (*ElementsResponse) XXX_DiscardUnknown 

func (m *ElementsResponse) XXX_DiscardUnknown()

func (*ElementsResponse) XXX_Marshal 

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

func (*ElementsResponse) XXX_Merge 

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

func (*ElementsResponse) XXX_Size 

func (m *ElementsResponse) XXX_Size() int

func (*ElementsResponse) XXX_Unmarshal 

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

type Event 

type Event struct {
	Type    Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.set.v1.Event_Type" json:"type,omitempty"`
	Element Element    `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*Event) Descriptor 

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

func (*Event) GetElement 

func (m *Event) GetElement() Element

func (*Event) GetType 

func (m *Event) GetType() Event_Type

func (*Event) Marshal 

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

func (*Event) MarshalTo 

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

func (*Event) MarshalToSizedBuffer 

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

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

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

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_Type 

type Event_Type int32
const (
	Event_NONE   Event_Type = 0
	Event_ADD    Event_Type = 1
	Event_REMOVE Event_Type = 2
	Event_REPLAY Event_Type = 3
)

func (Event_Type) EnumDescriptor 

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

func (Event_Type) String 

func (x Event_Type) String() string

type EventsRequest 

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

func (*EventsRequest) Descriptor 

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

func (*EventsRequest) GetReplay 

func (m *EventsRequest) GetReplay() bool

func (*EventsRequest) Marshal 

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

func (*EventsRequest) MarshalTo 

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

func (*EventsRequest) MarshalToSizedBuffer 

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

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset 

func (m *EventsRequest) Reset()

func (*EventsRequest) Size 

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

func (*EventsRequest) String 

func (m *EventsRequest) String() string

func (*EventsRequest) Unmarshal 

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

func (*EventsRequest) XXX_DiscardUnknown 

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal 

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

func (*EventsRequest) XXX_Merge 

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

func (*EventsRequest) XXX_Size 

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal 

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

type EventsResponse 

type EventsResponse struct {
	Event Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event"`
}

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) GetEvent 

func (m *EventsResponse) GetEvent() Event

func (*EventsResponse) Marshal 

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

func (*EventsResponse) MarshalTo 

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

func (*EventsResponse) MarshalToSizedBuffer 

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

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) Size 

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

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) Unmarshal 

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

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

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

func (*EventsResponse) XXX_Merge 

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

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

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

type OpenSessionRequest 

type OpenSessionRequest struct {
	PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive_v1.ID `` /* 158-byte string literal not displayed */
	Options     SetSessionOptions                                      `protobuf:"bytes,2,opt,name=options,proto3" json:"options"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetOptions 

func (m *OpenSessionRequest) GetOptions() SetSessionOptions

func (*OpenSessionRequest) GetPrimitiveID 

func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

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

func (*OpenSessionRequest) MarshalToSizedBuffer 

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

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

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

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

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

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

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

func (*OpenSessionRequest) XXX_Merge 

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

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

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

type OpenSessionResponse 

type OpenSessionResponse struct {
	SessionID github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID `` /* 160-byte string literal not displayed */
}

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

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

func (*OpenSessionResponse) MarshalToSizedBuffer 

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

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

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

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

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

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

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

func (*OpenSessionResponse) XXX_Merge 

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

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

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

type RemoveRequest 

type RemoveRequest struct {
	Element Element `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetElement 

func (m *RemoveRequest) GetElement() Element

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 {
	Element Element `protobuf:"bytes,2,opt,name=element,proto3" json:"element"`
}

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) GetElement 

func (m *RemoveResponse) GetElement() Element

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 SetCacheOptions 

type SetCacheOptions struct {
	Enabled  bool             `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Strategy SetCacheStrategy `protobuf:"varint,2,opt,name=strategy,proto3,enum=atomix.primitive.set.v1.SetCacheStrategy" json:"strategy,omitempty"`
}

func (*SetCacheOptions) Descriptor 

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

func (*SetCacheOptions) GetEnabled 

func (m *SetCacheOptions) GetEnabled() bool

func (*SetCacheOptions) GetStrategy 

func (m *SetCacheOptions) GetStrategy() SetCacheStrategy

func (*SetCacheOptions) Marshal 

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

func (*SetCacheOptions) MarshalTo 

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

func (*SetCacheOptions) MarshalToSizedBuffer 

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

func (*SetCacheOptions) ProtoMessage 

func (*SetCacheOptions) ProtoMessage()

func (*SetCacheOptions) Reset 

func (m *SetCacheOptions) Reset()

func (*SetCacheOptions) Size 

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

func (*SetCacheOptions) String 

func (m *SetCacheOptions) String() string

func (*SetCacheOptions) Unmarshal 

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

func (*SetCacheOptions) XXX_DiscardUnknown 

func (m *SetCacheOptions) XXX_DiscardUnknown()

func (*SetCacheOptions) XXX_Marshal 

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

func (*SetCacheOptions) XXX_Merge 

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

func (*SetCacheOptions) XXX_Size 

func (m *SetCacheOptions) XXX_Size() int

func (*SetCacheOptions) XXX_Unmarshal 

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

type SetCacheStrategy 

type SetCacheStrategy int32
const (
	SetCacheStrategy_NEAR                       SetCacheStrategy = 0
	SetCacheStrategy_READ_THROUGH               SetCacheStrategy = 1
	SetCacheStrategy_WRITE_THROUGH              SetCacheStrategy = 2
	SetCacheStrategy_READ_THROUGH_WRITE_THROUGH SetCacheStrategy = 3
)

func (SetCacheStrategy) EnumDescriptor 

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

func (SetCacheStrategy) String 

func (x SetCacheStrategy) String() string

type SetClient 

type SetClient interface {
	// Size gets the number of elements in the set
	Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
	// Contains returns whether the set contains a value
	Contains(ctx context.Context, in *ContainsRequest, opts ...grpc.CallOption) (*ContainsResponse, error)
	// Add adds a value to the set
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	// Remove removes a value from the set
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	// Clear removes all values from the set
	Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
	// Events listens for set change events
	Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (Set_EventsClient, error)
	// Elements lists all elements in the set
	Elements(ctx context.Context, in *ElementsRequest, opts ...grpc.CallOption) (Set_ElementsClient, error)
}

SetClient is the client API for Set service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSetClient 

func NewSetClient(cc *grpc.ClientConn) SetClient

type SetManagerClient added in v0.7.0 

type SetManagerClient interface {
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

SetManagerClient is the client API for SetManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSetManagerClient added in v0.7.0 

func NewSetManagerClient(cc *grpc.ClientConn) SetManagerClient

type SetManagerServer added in v0.7.0 

type SetManagerServer interface {
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
}

SetManagerServer is the server API for SetManager service.

type SetServer 

type SetServer interface {
	// Size gets the number of elements in the set
	Size(context.Context, *SizeRequest) (*SizeResponse, error)
	// Contains returns whether the set contains a value
	Contains(context.Context, *ContainsRequest) (*ContainsResponse, error)
	// Add adds a value to the set
	Add(context.Context, *AddRequest) (*AddResponse, error)
	// Remove removes a value from the set
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	// Clear removes all values from the set
	Clear(context.Context, *ClearRequest) (*ClearResponse, error)
	// Events listens for set change events
	Events(*EventsRequest, Set_EventsServer) error
	// Elements lists all elements in the set
	Elements(*ElementsRequest, Set_ElementsServer) error
}

SetServer is the server API for Set service.

type SetSessionOptions 

type SetSessionOptions struct {
	Cache SetCacheOptions `protobuf:"bytes,1,opt,name=cache,proto3" json:"cache"`
}

func (*SetSessionOptions) Descriptor 

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

func (*SetSessionOptions) GetCache 

func (m *SetSessionOptions) GetCache() SetCacheOptions

func (*SetSessionOptions) Marshal 

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

func (*SetSessionOptions) MarshalTo 

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

func (*SetSessionOptions) MarshalToSizedBuffer 

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

func (*SetSessionOptions) ProtoMessage 

func (*SetSessionOptions) ProtoMessage()

func (*SetSessionOptions) Reset 

func (m *SetSessionOptions) Reset()

func (*SetSessionOptions) Size 

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

func (*SetSessionOptions) String 

func (m *SetSessionOptions) String() string

func (*SetSessionOptions) Unmarshal 

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

func (*SetSessionOptions) XXX_DiscardUnknown 

func (m *SetSessionOptions) XXX_DiscardUnknown()

func (*SetSessionOptions) XXX_Marshal 

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

func (*SetSessionOptions) XXX_Merge 

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

func (*SetSessionOptions) XXX_Size 

func (m *SetSessionOptions) XXX_Size() int

func (*SetSessionOptions) XXX_Unmarshal 

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

type Set_ElementsClient 

type Set_ElementsClient interface {
	Recv() (*ElementsResponse, error)
	grpc.ClientStream
}

type Set_ElementsServer 

type Set_ElementsServer interface {
	Send(*ElementsResponse) error
	grpc.ServerStream
}

type Set_EventsClient 

type Set_EventsClient interface {
	Recv() (*EventsResponse, error)
	grpc.ClientStream
}

type Set_EventsServer 

type Set_EventsServer interface {
	Send(*EventsResponse) error
	grpc.ServerStream
}

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,2,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

type UnimplementedSetManagerServer added in v0.7.0 

type UnimplementedSetManagerServer struct {
}

UnimplementedSetManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSetManagerServer) CloseSession added in v0.7.0 

func (*UnimplementedSetManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedSetManagerServer) OpenSession added in v0.7.0 

func (*UnimplementedSetManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error)

type UnimplementedSetServer 

type UnimplementedSetServer struct {
}

UnimplementedSetServer can be embedded to have forward compatible implementations.

func (*UnimplementedSetServer) Add 

func (*UnimplementedSetServer) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)

func (*UnimplementedSetServer) Clear 

func (*UnimplementedSetServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)

func (*UnimplementedSetServer) Contains 

func (*UnimplementedSetServer) Contains(ctx context.Context, req *ContainsRequest) (*ContainsResponse, error)

func (*UnimplementedSetServer) Elements 

func (*UnimplementedSetServer) Elements(req *ElementsRequest, srv Set_ElementsServer) error

func (*UnimplementedSetServer) Events 

func (*UnimplementedSetServer) Events(req *EventsRequest, srv Set_EventsServer) error

func (*UnimplementedSetServer) Remove 

func (*UnimplementedSetServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)

func (*UnimplementedSetServer) Size 

func (*UnimplementedSetServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, 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.