Versions in this module Expand all Collapse all v0 v0.8.0 Nov 21, 2021 v0.7.0 Nov 19, 2021 v0.6.1 Nov 13, 2021 v0.6.0 Nov 3, 2021 v0.5.0 Nov 2, 2021 v0.4.10 Mar 4, 2022 v0.4.9 Aug 3, 2021 v0.4.8 Jun 30, 2021 v0.4.7 Jun 29, 2021 v0.4.6 Jun 21, 2021 v0.4.5 May 29, 2021 v0.4.4 May 18, 2021 v0.4.3 May 16, 2021 v0.4.2 May 16, 2021 v0.4.1 May 15, 2021 v0.4.0 Apr 29, 2021 Changes in this version + var ErrIntOverflowMap = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMap = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMap = fmt.Errorf("proto: unexpected end of group") + var Event_Type_name = map[int32]string + var Event_Type_value = map[string]int32 + func RegisterMapServiceServer(s *grpc.Server, srv MapServiceServer) + type ClearRequest struct + Headers primitive.RequestHeaders + func (*ClearRequest) Descriptor() ([]byte, []int) + func (*ClearRequest) ProtoMessage() + func (m *ClearRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + func (*ClearResponse) Descriptor() ([]byte, []int) + func (*ClearResponse) ProtoMessage() + func (m *ClearResponse) GetHeaders() primitive.ResponseHeaders + 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 EntriesRequest struct + Headers primitive.RequestHeaders + func (*EntriesRequest) Descriptor() ([]byte, []int) + func (*EntriesRequest) ProtoMessage() + func (m *EntriesRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + func (*EntriesResponse) Descriptor() ([]byte, []int) + func (*EntriesResponse) ProtoMessage() + func (m *EntriesResponse) GetEntry() Entry + func (m *EntriesResponse) GetHeaders() primitive.ResponseHeaders + 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 + Headers primitive.RequestHeaders + Key string + Replay bool + func (*EventsRequest) Descriptor() ([]byte, []int) + func (*EventsRequest) ProtoMessage() + func (m *EventsRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + func (*EventsResponse) Descriptor() ([]byte, []int) + func (*EventsResponse) ProtoMessage() + func (m *EventsResponse) GetEvent() Event + func (m *EventsResponse) GetHeaders() primitive.ResponseHeaders + 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 + Headers primitive.RequestHeaders + Key string + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetEntry() Entry + func (m *GetResponse) GetHeaders() primitive.ResponseHeaders + 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 MapServiceClient interface + Clear func(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error) + Entries func(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (MapService_EntriesClient, error) + Events func(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (MapService_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 NewMapServiceClient(cc *grpc.ClientConn) MapServiceClient + type MapServiceServer interface + Clear func(context.Context, *ClearRequest) (*ClearResponse, error) + Entries func(*EntriesRequest, MapService_EntriesServer) error + Events func(*EventsRequest, MapService_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 MapService_EntriesClient interface + Recv func() (*EntriesResponse, error) + type MapService_EntriesServer interface + Send func(*EntriesResponse) error + type MapService_EventsClient interface + Recv func() (*EventsResponse, error) + type MapService_EventsServer interface + Send func(*EventsResponse) 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 + Headers primitive.RequestHeaders + Preconditions []Precondition + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) GetEntry() Entry + func (m *PutRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) GetEntry() Entry + func (m *PutResponse) GetHeaders() primitive.ResponseHeaders + 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 + Headers primitive.RequestHeaders + Key Key + Preconditions []Precondition + func (*RemoveRequest) Descriptor() ([]byte, []int) + func (*RemoveRequest) ProtoMessage() + func (m *RemoveRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + func (*RemoveResponse) Descriptor() ([]byte, []int) + func (*RemoveResponse) ProtoMessage() + func (m *RemoveResponse) GetEntry() Entry + func (m *RemoveResponse) GetHeaders() primitive.ResponseHeaders + 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 + Headers primitive.RequestHeaders + func (*SizeRequest) Descriptor() ([]byte, []int) + func (*SizeRequest) ProtoMessage() + func (m *SizeRequest) GetHeaders() primitive.RequestHeaders + 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 + Headers primitive.ResponseHeaders + Size_ uint32 + func (*SizeResponse) Descriptor() ([]byte, []int) + func (*SizeResponse) ProtoMessage() + func (m *SizeResponse) GetHeaders() primitive.ResponseHeaders + 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 UnimplementedMapServiceServer struct + func (*UnimplementedMapServiceServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error) + func (*UnimplementedMapServiceServer) Entries(req *EntriesRequest, srv MapService_EntriesServer) error + func (*UnimplementedMapServiceServer) Events(req *EventsRequest, srv MapService_EventsServer) error + func (*UnimplementedMapServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedMapServiceServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error) + func (*UnimplementedMapServiceServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error) + func (*UnimplementedMapServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, 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