Documentation ¶
Index ¶
- Variables
- func RegisterSetManagerServer(s *grpc.Server, srv SetManagerServer)
- func RegisterSetServer(s *grpc.Server, srv SetServer)
- type AddRequest
- func (*AddRequest) Descriptor() ([]byte, []int)
- func (m *AddRequest) GetElement() Element
- func (m *AddRequest) Marshal() (dAtA []byte, err error)
- func (m *AddRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AddRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AddRequest) ProtoMessage()
- func (m *AddRequest) Reset()
- func (m *AddRequest) Size() (n int)
- func (m *AddRequest) String() string
- func (m *AddRequest) Unmarshal(dAtA []byte) error
- func (m *AddRequest) XXX_DiscardUnknown()
- func (m *AddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddRequest) XXX_Merge(src proto.Message)
- func (m *AddRequest) XXX_Size() int
- func (m *AddRequest) XXX_Unmarshal(b []byte) error
- type AddResponse
- func (*AddResponse) Descriptor() ([]byte, []int)
- func (m *AddResponse) GetElement() Element
- func (m *AddResponse) Marshal() (dAtA []byte, err error)
- func (m *AddResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AddResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AddResponse) ProtoMessage()
- func (m *AddResponse) Reset()
- func (m *AddResponse) Size() (n int)
- func (m *AddResponse) String() string
- func (m *AddResponse) Unmarshal(dAtA []byte) error
- func (m *AddResponse) XXX_DiscardUnknown()
- func (m *AddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddResponse) XXX_Merge(src proto.Message)
- func (m *AddResponse) XXX_Size() int
- func (m *AddResponse) XXX_Unmarshal(b []byte) error
- type ClearRequest
- func (*ClearRequest) Descriptor() ([]byte, []int)
- func (m *ClearRequest) Marshal() (dAtA []byte, err error)
- func (m *ClearRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ClearRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClearRequest) ProtoMessage()
- func (m *ClearRequest) Reset()
- func (m *ClearRequest) Size() (n int)
- func (m *ClearRequest) String() string
- func (m *ClearRequest) Unmarshal(dAtA []byte) error
- func (m *ClearRequest) XXX_DiscardUnknown()
- func (m *ClearRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClearRequest) XXX_Merge(src proto.Message)
- func (m *ClearRequest) XXX_Size() int
- func (m *ClearRequest) XXX_Unmarshal(b []byte) error
- type ClearResponse
- func (*ClearResponse) Descriptor() ([]byte, []int)
- func (m *ClearResponse) Marshal() (dAtA []byte, err error)
- func (m *ClearResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ClearResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClearResponse) ProtoMessage()
- func (m *ClearResponse) Reset()
- func (m *ClearResponse) Size() (n int)
- func (m *ClearResponse) String() string
- func (m *ClearResponse) Unmarshal(dAtA []byte) error
- func (m *ClearResponse) XXX_DiscardUnknown()
- func (m *ClearResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClearResponse) XXX_Merge(src proto.Message)
- func (m *ClearResponse) XXX_Size() int
- func (m *ClearResponse) XXX_Unmarshal(b []byte) error
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)
- func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
- func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionRequest) ProtoMessage()
- func (m *CloseSessionRequest) Reset()
- func (m *CloseSessionRequest) Size() (n int)
- func (m *CloseSessionRequest) String() string
- func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error
- func (m *CloseSessionRequest) XXX_DiscardUnknown()
- func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionRequest) XXX_Merge(src proto.Message)
- func (m *CloseSessionRequest) XXX_Size() int
- func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)
- func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionResponse) ProtoMessage()
- func (m *CloseSessionResponse) Reset()
- func (m *CloseSessionResponse) Size() (n int)
- func (m *CloseSessionResponse) String() string
- func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error
- func (m *CloseSessionResponse) XXX_DiscardUnknown()
- func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionResponse) XXX_Merge(src proto.Message)
- func (m *CloseSessionResponse) XXX_Size() int
- func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error
- type ContainsRequest
- func (*ContainsRequest) Descriptor() ([]byte, []int)
- func (m *ContainsRequest) GetElement() Element
- func (m *ContainsRequest) Marshal() (dAtA []byte, err error)
- func (m *ContainsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ContainsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContainsRequest) ProtoMessage()
- func (m *ContainsRequest) Reset()
- func (m *ContainsRequest) Size() (n int)
- func (m *ContainsRequest) String() string
- func (m *ContainsRequest) Unmarshal(dAtA []byte) error
- func (m *ContainsRequest) XXX_DiscardUnknown()
- func (m *ContainsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainsRequest) XXX_Merge(src proto.Message)
- func (m *ContainsRequest) XXX_Size() int
- func (m *ContainsRequest) XXX_Unmarshal(b []byte) error
- type ContainsResponse
- func (*ContainsResponse) Descriptor() ([]byte, []int)
- func (m *ContainsResponse) GetContains() bool
- func (m *ContainsResponse) Marshal() (dAtA []byte, err error)
- func (m *ContainsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ContainsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContainsResponse) ProtoMessage()
- func (m *ContainsResponse) Reset()
- func (m *ContainsResponse) Size() (n int)
- func (m *ContainsResponse) String() string
- func (m *ContainsResponse) Unmarshal(dAtA []byte) error
- func (m *ContainsResponse) XXX_DiscardUnknown()
- func (m *ContainsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainsResponse) XXX_Merge(src proto.Message)
- func (m *ContainsResponse) XXX_Size() int
- func (m *ContainsResponse) XXX_Unmarshal(b []byte) error
- type Element
- func (*Element) Descriptor() ([]byte, []int)
- func (m *Element) GetValue() string
- func (m *Element) Marshal() (dAtA []byte, err error)
- func (m *Element) MarshalTo(dAtA []byte) (int, error)
- func (m *Element) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Element) ProtoMessage()
- func (m *Element) Reset()
- func (m *Element) Size() (n int)
- func (m *Element) String() string
- func (m *Element) Unmarshal(dAtA []byte) error
- func (m *Element) XXX_DiscardUnknown()
- func (m *Element) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Element) XXX_Merge(src proto.Message)
- func (m *Element) XXX_Size() int
- func (m *Element) XXX_Unmarshal(b []byte) error
- type ElementsRequest
- func (*ElementsRequest) Descriptor() ([]byte, []int)
- func (m *ElementsRequest) Marshal() (dAtA []byte, err error)
- func (m *ElementsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ElementsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ElementsRequest) ProtoMessage()
- func (m *ElementsRequest) Reset()
- func (m *ElementsRequest) Size() (n int)
- func (m *ElementsRequest) String() string
- func (m *ElementsRequest) Unmarshal(dAtA []byte) error
- func (m *ElementsRequest) XXX_DiscardUnknown()
- func (m *ElementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ElementsRequest) XXX_Merge(src proto.Message)
- func (m *ElementsRequest) XXX_Size() int
- func (m *ElementsRequest) XXX_Unmarshal(b []byte) error
- type ElementsResponse
- func (*ElementsResponse) Descriptor() ([]byte, []int)
- func (m *ElementsResponse) GetElement() Element
- func (m *ElementsResponse) Marshal() (dAtA []byte, err error)
- func (m *ElementsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ElementsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ElementsResponse) ProtoMessage()
- func (m *ElementsResponse) Reset()
- func (m *ElementsResponse) Size() (n int)
- func (m *ElementsResponse) String() string
- func (m *ElementsResponse) Unmarshal(dAtA []byte) error
- func (m *ElementsResponse) XXX_DiscardUnknown()
- func (m *ElementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ElementsResponse) XXX_Merge(src proto.Message)
- func (m *ElementsResponse) XXX_Size() int
- func (m *ElementsResponse) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetElement() Element
- func (m *Event) GetType() Event_Type
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type Event_Type
- type EventsRequest
- func (*EventsRequest) Descriptor() ([]byte, []int)
- func (m *EventsRequest) GetReplay() bool
- func (m *EventsRequest) Marshal() (dAtA []byte, err error)
- func (m *EventsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventsRequest) ProtoMessage()
- func (m *EventsRequest) Reset()
- func (m *EventsRequest) Size() (n int)
- func (m *EventsRequest) String() string
- func (m *EventsRequest) Unmarshal(dAtA []byte) error
- func (m *EventsRequest) XXX_DiscardUnknown()
- func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventsRequest) XXX_Merge(src proto.Message)
- func (m *EventsRequest) XXX_Size() int
- func (m *EventsRequest) XXX_Unmarshal(b []byte) error
- type EventsResponse
- func (*EventsResponse) Descriptor() ([]byte, []int)
- func (m *EventsResponse) GetEvent() Event
- func (m *EventsResponse) Marshal() (dAtA []byte, err error)
- func (m *EventsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventsResponse) ProtoMessage()
- func (m *EventsResponse) Reset()
- func (m *EventsResponse) Size() (n int)
- func (m *EventsResponse) String() string
- func (m *EventsResponse) Unmarshal(dAtA []byte) error
- func (m *EventsResponse) XXX_DiscardUnknown()
- func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventsResponse) XXX_Merge(src proto.Message)
- func (m *EventsResponse) XXX_Size() int
- func (m *EventsResponse) XXX_Unmarshal(b []byte) error
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetOptions() SetSessionOptions
- func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive_v1.ID
- func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionRequest) ProtoMessage()
- func (m *OpenSessionRequest) Reset()
- func (m *OpenSessionRequest) Size() (n int)
- func (m *OpenSessionRequest) String() string
- func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
- func (m *OpenSessionRequest) XXX_DiscardUnknown()
- func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
- func (m *OpenSessionRequest) XXX_Size() int
- func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)
- func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive_v1.SessionID
- func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionResponse) ProtoMessage()
- func (m *OpenSessionResponse) Reset()
- func (m *OpenSessionResponse) Size() (n int)
- func (m *OpenSessionResponse) String() string
- func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
- func (m *OpenSessionResponse) XXX_DiscardUnknown()
- func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
- func (m *OpenSessionResponse) XXX_Size() int
- func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
- type RemoveRequest
- func (*RemoveRequest) Descriptor() ([]byte, []int)
- func (m *RemoveRequest) GetElement() Element
- func (m *RemoveRequest) Marshal() (dAtA []byte, err error)
- func (m *RemoveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RemoveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RemoveRequest) ProtoMessage()
- func (m *RemoveRequest) Reset()
- func (m *RemoveRequest) Size() (n int)
- func (m *RemoveRequest) String() string
- func (m *RemoveRequest) Unmarshal(dAtA []byte) error
- func (m *RemoveRequest) XXX_DiscardUnknown()
- func (m *RemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveRequest) XXX_Merge(src proto.Message)
- func (m *RemoveRequest) XXX_Size() int
- func (m *RemoveRequest) XXX_Unmarshal(b []byte) error
- type RemoveResponse
- func (*RemoveResponse) Descriptor() ([]byte, []int)
- func (m *RemoveResponse) GetElement() Element
- func (m *RemoveResponse) Marshal() (dAtA []byte, err error)
- func (m *RemoveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RemoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RemoveResponse) ProtoMessage()
- func (m *RemoveResponse) Reset()
- func (m *RemoveResponse) Size() (n int)
- func (m *RemoveResponse) String() string
- func (m *RemoveResponse) Unmarshal(dAtA []byte) error
- func (m *RemoveResponse) XXX_DiscardUnknown()
- func (m *RemoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveResponse) XXX_Merge(src proto.Message)
- func (m *RemoveResponse) XXX_Size() int
- func (m *RemoveResponse) XXX_Unmarshal(b []byte) error
- type SetCacheOptions
- func (*SetCacheOptions) Descriptor() ([]byte, []int)
- func (m *SetCacheOptions) GetEnabled() bool
- func (m *SetCacheOptions) GetStrategy() SetCacheStrategy
- func (m *SetCacheOptions) Marshal() (dAtA []byte, err error)
- func (m *SetCacheOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *SetCacheOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetCacheOptions) ProtoMessage()
- func (m *SetCacheOptions) Reset()
- func (m *SetCacheOptions) Size() (n int)
- func (m *SetCacheOptions) String() string
- func (m *SetCacheOptions) Unmarshal(dAtA []byte) error
- func (m *SetCacheOptions) XXX_DiscardUnknown()
- func (m *SetCacheOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetCacheOptions) XXX_Merge(src proto.Message)
- func (m *SetCacheOptions) XXX_Size() int
- func (m *SetCacheOptions) XXX_Unmarshal(b []byte) error
- type SetCacheStrategy
- type SetClient
- type SetManagerClient
- type SetManagerServer
- type SetServer
- type SetSessionOptions
- func (*SetSessionOptions) Descriptor() ([]byte, []int)
- func (m *SetSessionOptions) GetCache() SetCacheOptions
- func (m *SetSessionOptions) Marshal() (dAtA []byte, err error)
- func (m *SetSessionOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *SetSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetSessionOptions) ProtoMessage()
- func (m *SetSessionOptions) Reset()
- func (m *SetSessionOptions) Size() (n int)
- func (m *SetSessionOptions) String() string
- func (m *SetSessionOptions) Unmarshal(dAtA []byte) error
- func (m *SetSessionOptions) XXX_DiscardUnknown()
- func (m *SetSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetSessionOptions) XXX_Merge(src proto.Message)
- func (m *SetSessionOptions) XXX_Size() int
- func (m *SetSessionOptions) XXX_Unmarshal(b []byte) error
- type Set_ElementsClient
- type Set_ElementsServer
- type Set_EventsClient
- type Set_EventsServer
- type SizeRequest
- func (*SizeRequest) Descriptor() ([]byte, []int)
- func (m *SizeRequest) Marshal() (dAtA []byte, err error)
- func (m *SizeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SizeRequest) ProtoMessage()
- func (m *SizeRequest) Reset()
- func (m *SizeRequest) Size() (n int)
- func (m *SizeRequest) String() string
- func (m *SizeRequest) Unmarshal(dAtA []byte) error
- func (m *SizeRequest) XXX_DiscardUnknown()
- func (m *SizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SizeRequest) XXX_Merge(src proto.Message)
- func (m *SizeRequest) XXX_Size() int
- func (m *SizeRequest) XXX_Unmarshal(b []byte) error
- type SizeResponse
- func (*SizeResponse) Descriptor() ([]byte, []int)
- func (m *SizeResponse) GetSize_() uint32
- func (m *SizeResponse) Marshal() (dAtA []byte, err error)
- func (m *SizeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SizeResponse) ProtoMessage()
- func (m *SizeResponse) Reset()
- func (m *SizeResponse) Size() (n int)
- func (m *SizeResponse) String() string
- func (m *SizeResponse) Unmarshal(dAtA []byte) error
- func (m *SizeResponse) XXX_DiscardUnknown()
- func (m *SizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SizeResponse) XXX_Merge(src proto.Message)
- func (m *SizeResponse) XXX_Size() int
- func (m *SizeResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedSetManagerServer
- type UnimplementedSetServer
- func (*UnimplementedSetServer) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)
- func (*UnimplementedSetServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
- func (*UnimplementedSetServer) Contains(ctx context.Context, req *ContainsRequest) (*ContainsResponse, error)
- func (*UnimplementedSetServer) Elements(req *ElementsRequest, srv Set_ElementsServer) error
- func (*UnimplementedSetServer) Events(req *EventsRequest, srv Set_EventsServer) error
- func (*UnimplementedSetServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
- func (*UnimplementedSetServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
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 ¶
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) 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) 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) 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) 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) 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) 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) MarshalToSizedBuffer ¶
func (*Element) ProtoMessage ¶
func (*Element) ProtoMessage()
func (*Element) XXX_DiscardUnknown ¶
func (m *Element) XXX_DiscardUnknown()
func (*Element) XXX_Marshal ¶
func (*Element) XXX_Unmarshal ¶
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) 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) 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) GetElement ¶
func (*Event) GetType ¶
func (m *Event) GetType() Event_Type
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
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) 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) 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) 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) 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) 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) 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) 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)
Click to show internal directories.
Click to hide internal directories.