Versions in this module Expand all Collapse all v0 v0.8.0 Nov 21, 2021 v0.7.0 Nov 19, 2021 Changes in this version + var ErrIntOverflowManager = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthManager = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupManager = fmt.Errorf("proto: unexpected end of group") + func RegisterMapManagerServer(s *grpc.Server, srv MapManagerServer) + type MapManagerClient interface + CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) + OpenSession func(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) + func NewMapManagerClient(cc *grpc.ClientConn) MapManagerClient + type MapManagerServer interface + CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) + OpenSession func(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) + type UnimplementedMapManagerServer struct + func (*UnimplementedMapManagerServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error) + func (*UnimplementedMapManagerServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error) v0.6.1 Nov 13, 2021 v0.6.0 Nov 3, 2021 v0.5.0 Nov 2, 2021 Changes in this version + var ErrIntOverflowPrimitive = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSession = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPrimitive = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSession = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPrimitive = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupSession = fmt.Errorf("proto: unexpected end of group") + var Event_Type_name = map[int32]string + var Event_Type_value = map[string]int32 + var MapCacheStrategy_name = map[int32]string + var MapCacheStrategy_value = map[string]int32 + func RegisterMapServer(s *grpc.Server, srv MapServer) + func RegisterMapSessionServer(s *grpc.Server, srv MapSessionServer) + type ClearRequest struct + func (*ClearRequest) Descriptor() ([]byte, []int) + func (*ClearRequest) ProtoMessage() + 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 (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 struct + func (*ClearResponse) Descriptor() ([]byte, []int) + func (*ClearResponse) ProtoMessage() + 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 (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 struct + SessionID github_com_atomix_atomix_api_go_atomix_primitive.SessionID + func (*CloseSessionRequest) Descriptor() ([]byte, []int) + func (*CloseSessionRequest) ProtoMessage() + func (m *CloseSessionRequest) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive.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 (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 struct + func (*CloseSessionResponse) Descriptor() ([]byte, []int) + func (*CloseSessionResponse) ProtoMessage() + 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 (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 EntriesRequest struct + func (*EntriesRequest) Descriptor() ([]byte, []int) + func (*EntriesRequest) ProtoMessage() + func (m *EntriesRequest) Marshal() (dAtA []byte, err error) + func (m *EntriesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *EntriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EntriesRequest) Reset() + func (m *EntriesRequest) Size() (n int) + func (m *EntriesRequest) String() string + func (m *EntriesRequest) Unmarshal(dAtA []byte) error + func (m *EntriesRequest) XXX_DiscardUnknown() + func (m *EntriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EntriesRequest) XXX_Merge(src proto.Message) + func (m *EntriesRequest) XXX_Size() int + func (m *EntriesRequest) XXX_Unmarshal(b []byte) error + type EntriesResponse struct + Entry Entry + func (*EntriesResponse) Descriptor() ([]byte, []int) + func (*EntriesResponse) ProtoMessage() + func (m *EntriesResponse) GetEntry() Entry + func (m *EntriesResponse) Marshal() (dAtA []byte, err error) + func (m *EntriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EntriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EntriesResponse) Reset() + func (m *EntriesResponse) Size() (n int) + func (m *EntriesResponse) String() string + func (m *EntriesResponse) Unmarshal(dAtA []byte) error + func (m *EntriesResponse) XXX_DiscardUnknown() + func (m *EntriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EntriesResponse) XXX_Merge(src proto.Message) + func (m *EntriesResponse) XXX_Size() int + func (m *EntriesResponse) XXX_Unmarshal(b []byte) error + type Entry struct + Key Key + Value *Value + func (*Entry) Descriptor() ([]byte, []int) + func (*Entry) ProtoMessage() + func (m *Entry) GetKey() Key + func (m *Entry) GetValue() *Value + func (m *Entry) Marshal() (dAtA []byte, err error) + func (m *Entry) MarshalTo(dAtA []byte) (int, error) + func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Entry) Reset() + func (m *Entry) Size() (n int) + func (m *Entry) String() string + func (m *Entry) Unmarshal(dAtA []byte) error + func (m *Entry) XXX_DiscardUnknown() + func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Entry) XXX_Merge(src proto.Message) + func (m *Entry) XXX_Size() int + func (m *Entry) XXX_Unmarshal(b []byte) error + type Event struct + Entry Entry + Type Event_Type + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetEntry() Entry + 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 (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 int32 + const Event_INSERT + const Event_NONE + const Event_REMOVE + const Event_REPLAY + const Event_UPDATE + func (Event_Type) EnumDescriptor() ([]byte, []int) + func (x Event_Type) String() string + type EventsRequest struct + Key string + Replay bool + func (*EventsRequest) Descriptor() ([]byte, []int) + func (*EventsRequest) ProtoMessage() + func (m *EventsRequest) GetKey() string + 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 (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 struct + Event Event + func (*EventsResponse) Descriptor() ([]byte, []int) + func (*EventsResponse) ProtoMessage() + 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 (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 GetRequest struct + Key string + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetKey() string + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) Unmarshal(dAtA []byte) error + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Entry Entry + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetEntry() Entry + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) Unmarshal(dAtA []byte) error + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type Key struct + Key string + func (*Key) Descriptor() ([]byte, []int) + func (*Key) ProtoMessage() + func (m *Key) GetKey() string + func (m *Key) Marshal() (dAtA []byte, err error) + func (m *Key) MarshalTo(dAtA []byte) (int, error) + func (m *Key) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Key) Reset() + func (m *Key) Size() (n int) + func (m *Key) String() string + func (m *Key) Unmarshal(dAtA []byte) error + func (m *Key) XXX_DiscardUnknown() + func (m *Key) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Key) XXX_Merge(src proto.Message) + func (m *Key) XXX_Size() int + func (m *Key) XXX_Unmarshal(b []byte) error + type MapCacheOptions struct + Enabled bool + Strategy MapCacheStrategy + func (*MapCacheOptions) Descriptor() ([]byte, []int) + func (*MapCacheOptions) ProtoMessage() + func (m *MapCacheOptions) GetEnabled() bool + func (m *MapCacheOptions) GetStrategy() MapCacheStrategy + func (m *MapCacheOptions) Marshal() (dAtA []byte, err error) + func (m *MapCacheOptions) MarshalTo(dAtA []byte) (int, error) + func (m *MapCacheOptions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MapCacheOptions) Reset() + func (m *MapCacheOptions) Size() (n int) + func (m *MapCacheOptions) String() string + func (m *MapCacheOptions) Unmarshal(dAtA []byte) error + func (m *MapCacheOptions) XXX_DiscardUnknown() + func (m *MapCacheOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MapCacheOptions) XXX_Merge(src proto.Message) + func (m *MapCacheOptions) XXX_Size() int + func (m *MapCacheOptions) XXX_Unmarshal(b []byte) error + type MapCacheStrategy int32 + const MapCacheStrategy_NEAR + const MapCacheStrategy_READ_THROUGH + const MapCacheStrategy_READ_THROUGH_WRITE_THROUGH + const MapCacheStrategy_WRITE_THROUGH + func (MapCacheStrategy) EnumDescriptor() ([]byte, []int) + func (x MapCacheStrategy) String() string + type MapClient interface + Clear func(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error) + Entries func(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (Map_EntriesClient, error) + Events func(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (Map_EventsClient, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) + Remove func(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) + Size func(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error) + func NewMapClient(cc *grpc.ClientConn) MapClient + type MapServer interface + Clear func(context.Context, *ClearRequest) (*ClearResponse, error) + Entries func(*EntriesRequest, Map_EntriesServer) error + Events func(*EventsRequest, Map_EventsServer) error + Get func(context.Context, *GetRequest) (*GetResponse, error) + Put func(context.Context, *PutRequest) (*PutResponse, error) + Remove func(context.Context, *RemoveRequest) (*RemoveResponse, error) + Size func(context.Context, *SizeRequest) (*SizeResponse, error) + type MapSessionClient interface + CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) + OpenSession func(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) + func NewMapSessionClient(cc *grpc.ClientConn) MapSessionClient + type MapSessionOptions struct + Cache MapCacheOptions + func (*MapSessionOptions) Descriptor() ([]byte, []int) + func (*MapSessionOptions) ProtoMessage() + func (m *MapSessionOptions) GetCache() MapCacheOptions + func (m *MapSessionOptions) Marshal() (dAtA []byte, err error) + func (m *MapSessionOptions) MarshalTo(dAtA []byte) (int, error) + func (m *MapSessionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MapSessionOptions) Reset() + func (m *MapSessionOptions) Size() (n int) + func (m *MapSessionOptions) String() string + func (m *MapSessionOptions) Unmarshal(dAtA []byte) error + func (m *MapSessionOptions) XXX_DiscardUnknown() + func (m *MapSessionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MapSessionOptions) XXX_Merge(src proto.Message) + func (m *MapSessionOptions) XXX_Size() int + func (m *MapSessionOptions) XXX_Unmarshal(b []byte) error + type MapSessionServer interface + CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) + OpenSession func(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) + type Map_EntriesClient interface + Recv func() (*EntriesResponse, error) + type Map_EntriesServer interface + Send func(*EntriesResponse) error + type Map_EventsClient interface + Recv func() (*EventsResponse, error) + type Map_EventsServer interface + Send func(*EventsResponse) error + type OpenSessionRequest struct + Options MapSessionOptions + PrimitiveID github_com_atomix_atomix_api_go_atomix_primitive.ID + func (*OpenSessionRequest) Descriptor() ([]byte, []int) + func (*OpenSessionRequest) ProtoMessage() + func (m *OpenSessionRequest) GetOptions() MapSessionOptions + func (m *OpenSessionRequest) GetPrimitiveID() github_com_atomix_atomix_api_go_atomix_primitive.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 (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 struct + SessionID github_com_atomix_atomix_api_go_atomix_primitive.SessionID + func (*OpenSessionResponse) Descriptor() ([]byte, []int) + func (*OpenSessionResponse) ProtoMessage() + func (m *OpenSessionResponse) GetSessionID() github_com_atomix_atomix_api_go_atomix_primitive.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 (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 Precondition struct + Precondition isPrecondition_Precondition + func (*Precondition) Descriptor() ([]byte, []int) + func (*Precondition) ProtoMessage() + func (*Precondition) XXX_OneofWrappers() []interface{} + func (m *Precondition) GetMetadata() *meta.ObjectMeta + func (m *Precondition) GetPrecondition() isPrecondition_Precondition + func (m *Precondition) Marshal() (dAtA []byte, err error) + func (m *Precondition) MarshalTo(dAtA []byte) (int, error) + func (m *Precondition) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Precondition) Reset() + func (m *Precondition) Size() (n int) + func (m *Precondition) String() string + func (m *Precondition) Unmarshal(dAtA []byte) error + func (m *Precondition) XXX_DiscardUnknown() + func (m *Precondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Precondition) XXX_Merge(src proto.Message) + func (m *Precondition) XXX_Size() int + func (m *Precondition) XXX_Unmarshal(b []byte) error + type Precondition_Metadata struct + Metadata *meta.ObjectMeta + func (m *Precondition_Metadata) MarshalTo(dAtA []byte) (int, error) + func (m *Precondition_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Precondition_Metadata) Size() (n int) + type PutRequest struct + Entry Entry + Preconditions []Precondition + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) GetEntry() Entry + func (m *PutRequest) GetPreconditions() []Precondition + func (m *PutRequest) Marshal() (dAtA []byte, err error) + func (m *PutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutRequest) Reset() + func (m *PutRequest) Size() (n int) + func (m *PutRequest) String() string + func (m *PutRequest) Unmarshal(dAtA []byte) error + func (m *PutRequest) XXX_DiscardUnknown() + func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutRequest) XXX_Merge(src proto.Message) + func (m *PutRequest) XXX_Size() int + func (m *PutRequest) XXX_Unmarshal(b []byte) error + type PutResponse struct + Entry Entry + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) GetEntry() Entry + func (m *PutResponse) Marshal() (dAtA []byte, err error) + func (m *PutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(dAtA []byte) error + func (m *PutResponse) XXX_DiscardUnknown() + func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutResponse) XXX_Merge(src proto.Message) + func (m *PutResponse) XXX_Size() int + func (m *PutResponse) XXX_Unmarshal(b []byte) error + type RemoveRequest struct + Key Key + Preconditions []Precondition + func (*RemoveRequest) Descriptor() ([]byte, []int) + func (*RemoveRequest) ProtoMessage() + func (m *RemoveRequest) GetKey() Key + func (m *RemoveRequest) GetPreconditions() []Precondition + 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 (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 struct + Entry Entry + func (*RemoveResponse) Descriptor() ([]byte, []int) + func (*RemoveResponse) ProtoMessage() + func (m *RemoveResponse) GetEntry() Entry + 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 (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 SizeRequest struct + func (*SizeRequest) Descriptor() ([]byte, []int) + func (*SizeRequest) ProtoMessage() + 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 (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 struct + Size_ uint32 + func (*SizeResponse) Descriptor() ([]byte, []int) + func (*SizeResponse) ProtoMessage() + 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 (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 UnimplementedMapServer struct + func (*UnimplementedMapServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error) + func (*UnimplementedMapServer) Entries(req *EntriesRequest, srv Map_EntriesServer) error + func (*UnimplementedMapServer) Events(req *EventsRequest, srv Map_EventsServer) error + func (*UnimplementedMapServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedMapServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error) + func (*UnimplementedMapServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error) + func (*UnimplementedMapServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error) + type UnimplementedMapSessionServer struct + func (*UnimplementedMapSessionServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error) + func (*UnimplementedMapSessionServer) OpenSession(ctx context.Context, req *OpenSessionRequest) (*OpenSessionResponse, error) + type Value struct + TTL *time.Duration + Value []byte + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (m *Value) GetTTL() *time.Duration + func (m *Value) GetValue() []byte + func (m *Value) Marshal() (dAtA []byte, err error) + func (m *Value) MarshalTo(dAtA []byte) (int, error) + func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Value) Reset() + func (m *Value) Size() (n int) + func (m *Value) String() string + func (m *Value) Unmarshal(dAtA []byte) error + func (m *Value) XXX_DiscardUnknown() + func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Value) XXX_Merge(src proto.Message) + func (m *Value) XXX_Size() int + func (m *Value) XXX_Unmarshal(b []byte) error