Documentation
¶
Index ¶
- Variables
- func RegisterMapServiceServer(s *grpc.Server, srv MapServiceServer)
- type ClearRequest
- func (*ClearRequest) Descriptor() ([]byte, []int)
- 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 (*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) 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 (*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 EntriesRequest
- func (*EntriesRequest) Descriptor() ([]byte, []int)
- 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 (*EntriesRequest) ProtoMessage()
- 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
- func (*EntriesResponse) Descriptor() ([]byte, []int)
- 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 (*EntriesResponse) ProtoMessage()
- 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
- func (*Entry) Descriptor() ([]byte, []int)
- 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 (*Entry) ProtoMessage()
- 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
- func (*Event) Descriptor() ([]byte, []int)
- 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 (*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) 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 (*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) 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 (*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 GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- 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 (*GetRequest) ProtoMessage()
- 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
- func (*GetResponse) Descriptor() ([]byte, []int)
- 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 (*GetResponse) ProtoMessage()
- 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
- func (*Key) Descriptor() ([]byte, []int)
- 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 (*Key) ProtoMessage()
- 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
- type MapServiceServer
- type MapService_EntriesClient
- type MapService_EntriesServer
- type MapService_EventsClient
- type MapService_EventsServer
- type Precondition
- func (*Precondition) Descriptor() ([]byte, []int)
- 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 (*Precondition) ProtoMessage()
- 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 (*Precondition) XXX_OneofWrappers() []interface{}
- func (m *Precondition) XXX_Size() int
- func (m *Precondition) XXX_Unmarshal(b []byte) error
- type Precondition_Metadata
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)
- 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 (*PutRequest) ProtoMessage()
- 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
- func (*PutResponse) Descriptor() ([]byte, []int)
- 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 (*PutResponse) ProtoMessage()
- 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
- func (*RemoveRequest) Descriptor() ([]byte, []int)
- 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 (*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) 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 (*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 SizeRequest
- func (*SizeRequest) Descriptor() ([]byte, []int)
- 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 (*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) 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 (*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 UnimplementedMapServiceServer
- 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
- func (*Value) Descriptor() ([]byte, []int)
- 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 (*Value) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMap = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMap = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMap = fmt.Errorf("proto: unexpected end of group") )
View Source
var Event_Type_name = map[int32]string{
0: "NONE",
1: "INSERT",
2: "UPDATE",
3: "REMOVE",
4: "REPLAY",
}
View Source
var Event_Type_value = map[string]int32{
"NONE": 0,
"INSERT": 1,
"UPDATE": 2,
"REMOVE": 3,
"REPLAY": 4,
}
Functions ¶
func RegisterMapServiceServer ¶
func RegisterMapServiceServer(s *grpc.Server, srv MapServiceServer)
Types ¶
type ClearRequest ¶
type ClearRequest struct {
Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}
func (*ClearRequest) Descriptor ¶
func (*ClearRequest) Descriptor() ([]byte, []int)
func (*ClearRequest) GetHeaders ¶
func (m *ClearRequest) GetHeaders() primitive.RequestHeaders
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 {
Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}
func (*ClearResponse) Descriptor ¶
func (*ClearResponse) Descriptor() ([]byte, []int)
func (*ClearResponse) GetHeaders ¶
func (m *ClearResponse) GetHeaders() primitive.ResponseHeaders
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 EntriesRequest ¶
type EntriesRequest struct {
Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}
func (*EntriesRequest) Descriptor ¶
func (*EntriesRequest) Descriptor() ([]byte, []int)
func (*EntriesRequest) GetHeaders ¶
func (m *EntriesRequest) GetHeaders() primitive.RequestHeaders
func (*EntriesRequest) Marshal ¶
func (m *EntriesRequest) Marshal() (dAtA []byte, err error)
func (*EntriesRequest) MarshalToSizedBuffer ¶
func (m *EntriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EntriesRequest) ProtoMessage ¶
func (*EntriesRequest) ProtoMessage()
func (*EntriesRequest) Reset ¶
func (m *EntriesRequest) Reset()
func (*EntriesRequest) Size ¶
func (m *EntriesRequest) Size() (n int)
func (*EntriesRequest) String ¶
func (m *EntriesRequest) String() string
func (*EntriesRequest) Unmarshal ¶
func (m *EntriesRequest) Unmarshal(dAtA []byte) error
func (*EntriesRequest) XXX_DiscardUnknown ¶
func (m *EntriesRequest) XXX_DiscardUnknown()
func (*EntriesRequest) XXX_Marshal ¶
func (m *EntriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EntriesRequest) XXX_Merge ¶
func (m *EntriesRequest) XXX_Merge(src proto.Message)
func (*EntriesRequest) XXX_Size ¶
func (m *EntriesRequest) XXX_Size() int
func (*EntriesRequest) XXX_Unmarshal ¶
func (m *EntriesRequest) XXX_Unmarshal(b []byte) error
type EntriesResponse ¶
type EntriesResponse struct { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` }
func (*EntriesResponse) Descriptor ¶
func (*EntriesResponse) Descriptor() ([]byte, []int)
func (*EntriesResponse) GetEntry ¶
func (m *EntriesResponse) GetEntry() Entry
func (*EntriesResponse) GetHeaders ¶
func (m *EntriesResponse) GetHeaders() primitive.ResponseHeaders
func (*EntriesResponse) Marshal ¶
func (m *EntriesResponse) Marshal() (dAtA []byte, err error)
func (*EntriesResponse) MarshalToSizedBuffer ¶
func (m *EntriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EntriesResponse) ProtoMessage ¶
func (*EntriesResponse) ProtoMessage()
func (*EntriesResponse) Reset ¶
func (m *EntriesResponse) Reset()
func (*EntriesResponse) Size ¶
func (m *EntriesResponse) Size() (n int)
func (*EntriesResponse) String ¶
func (m *EntriesResponse) String() string
func (*EntriesResponse) Unmarshal ¶
func (m *EntriesResponse) Unmarshal(dAtA []byte) error
func (*EntriesResponse) XXX_DiscardUnknown ¶
func (m *EntriesResponse) XXX_DiscardUnknown()
func (*EntriesResponse) XXX_Marshal ¶
func (m *EntriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EntriesResponse) XXX_Merge ¶
func (m *EntriesResponse) XXX_Merge(src proto.Message)
func (*EntriesResponse) XXX_Size ¶
func (m *EntriesResponse) XXX_Size() int
func (*EntriesResponse) XXX_Unmarshal ¶
func (m *EntriesResponse) XXX_Unmarshal(b []byte) error
type Entry ¶
type Entry struct { Key Key `protobuf:"bytes,1,opt,name=key,proto3" json:"key"` Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*Entry) Descriptor ¶
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) XXX_DiscardUnknown ¶
func (m *Entry) XXX_DiscardUnknown()
func (*Entry) XXX_Marshal ¶
func (*Entry) XXX_Unmarshal ¶
type Event ¶
type Event struct { Type Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.primitive.map.Event_Type" json:"type,omitempty"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` }
func (*Event) Descriptor ¶
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_INSERT Event_Type = 1 Event_UPDATE Event_Type = 2 Event_REMOVE Event_Type = 3 Event_REPLAY Event_Type = 4 )
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 { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Replay bool `protobuf:"varint,3,opt,name=replay,proto3" json:"replay,omitempty"` }
func (*EventsRequest) Descriptor ¶
func (*EventsRequest) Descriptor() ([]byte, []int)
func (*EventsRequest) GetHeaders ¶
func (m *EventsRequest) GetHeaders() primitive.RequestHeaders
func (*EventsRequest) GetKey ¶
func (m *EventsRequest) GetKey() string
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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` 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) GetHeaders ¶
func (m *EventsResponse) GetHeaders() primitive.ResponseHeaders
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 GetRequest ¶
type GetRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetHeaders ¶
func (m *GetRequest) GetHeaders() primitive.RequestHeaders
func (*GetRequest) GetKey ¶
func (m *GetRequest) GetKey() string
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetEntry ¶
func (m *GetResponse) GetEntry() Entry
func (*GetResponse) GetHeaders ¶
func (m *GetResponse) GetHeaders() primitive.ResponseHeaders
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) MarshalToSizedBuffer ¶
func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type Key ¶
type Key struct { meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` }
func (*Key) Descriptor ¶
func (*Key) ProtoMessage ¶
func (*Key) ProtoMessage()
func (*Key) XXX_DiscardUnknown ¶
func (m *Key) XXX_DiscardUnknown()
func (*Key) XXX_Unmarshal ¶
type MapServiceClient ¶
type MapServiceClient interface { // Size returns the size of the map Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error) // Put puts an entry into the map Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) // Get gets the entry for a key Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) // Remove removes an entry from the map Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) // Clear removes all entries from the map Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error) // Events listens for change events Events(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (MapService_EventsClient, error) // Entries lists all entries in the map Entries(ctx context.Context, in *EntriesRequest, opts ...grpc.CallOption) (MapService_EntriesClient, error) }
MapServiceClient is the client API for MapService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMapServiceClient ¶
func NewMapServiceClient(cc *grpc.ClientConn) MapServiceClient
type MapServiceServer ¶
type MapServiceServer interface { // Size returns the size of the map Size(context.Context, *SizeRequest) (*SizeResponse, error) // Put puts an entry into the map Put(context.Context, *PutRequest) (*PutResponse, error) // Get gets the entry for a key Get(context.Context, *GetRequest) (*GetResponse, error) // Remove removes an entry from the map Remove(context.Context, *RemoveRequest) (*RemoveResponse, error) // Clear removes all entries from the map Clear(context.Context, *ClearRequest) (*ClearResponse, error) // Events listens for change events Events(*EventsRequest, MapService_EventsServer) error // Entries lists all entries in the map Entries(*EntriesRequest, MapService_EntriesServer) error }
MapServiceServer is the server API for MapService service.
type MapService_EntriesClient ¶
type MapService_EntriesClient interface { Recv() (*EntriesResponse, error) grpc.ClientStream }
type MapService_EntriesServer ¶
type MapService_EntriesServer interface { Send(*EntriesResponse) error grpc.ServerStream }
type MapService_EventsClient ¶
type MapService_EventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type MapService_EventsServer ¶
type MapService_EventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
type Precondition ¶
type Precondition struct { // Types that are valid to be assigned to Precondition: // *Precondition_Metadata Precondition isPrecondition_Precondition `protobuf_oneof:"precondition"` }
func (*Precondition) Descriptor ¶
func (*Precondition) Descriptor() ([]byte, []int)
func (*Precondition) GetMetadata ¶
func (m *Precondition) GetMetadata() *meta.ObjectMeta
func (*Precondition) GetPrecondition ¶
func (m *Precondition) GetPrecondition() isPrecondition_Precondition
func (*Precondition) Marshal ¶
func (m *Precondition) Marshal() (dAtA []byte, err error)
func (*Precondition) MarshalToSizedBuffer ¶
func (m *Precondition) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Precondition) ProtoMessage ¶
func (*Precondition) ProtoMessage()
func (*Precondition) Reset ¶
func (m *Precondition) Reset()
func (*Precondition) Size ¶
func (m *Precondition) Size() (n int)
func (*Precondition) String ¶
func (m *Precondition) String() string
func (*Precondition) Unmarshal ¶
func (m *Precondition) Unmarshal(dAtA []byte) error
func (*Precondition) XXX_DiscardUnknown ¶
func (m *Precondition) XXX_DiscardUnknown()
func (*Precondition) XXX_Marshal ¶
func (m *Precondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Precondition) XXX_Merge ¶
func (m *Precondition) XXX_Merge(src proto.Message)
func (*Precondition) XXX_OneofWrappers ¶
func (*Precondition) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Precondition) XXX_Size ¶
func (m *Precondition) XXX_Size() int
func (*Precondition) XXX_Unmarshal ¶
func (m *Precondition) XXX_Unmarshal(b []byte) error
type Precondition_Metadata ¶
type Precondition_Metadata struct {
Metadata *meta.ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}
func (*Precondition_Metadata) MarshalTo ¶
func (m *Precondition_Metadata) MarshalTo(dAtA []byte) (int, error)
func (*Precondition_Metadata) MarshalToSizedBuffer ¶
func (m *Precondition_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Precondition_Metadata) Size ¶
func (m *Precondition_Metadata) Size() (n int)
type PutRequest ¶
type PutRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"` }
func (*PutRequest) Descriptor ¶
func (*PutRequest) Descriptor() ([]byte, []int)
func (*PutRequest) GetEntry ¶
func (m *PutRequest) GetEntry() Entry
func (*PutRequest) GetHeaders ¶
func (m *PutRequest) GetHeaders() primitive.RequestHeaders
func (*PutRequest) GetPreconditions ¶
func (m *PutRequest) GetPreconditions() []Precondition
func (*PutRequest) Marshal ¶
func (m *PutRequest) Marshal() (dAtA []byte, err error)
func (*PutRequest) MarshalToSizedBuffer ¶
func (m *PutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) Reset ¶
func (m *PutRequest) Reset()
func (*PutRequest) Size ¶
func (m *PutRequest) Size() (n int)
func (*PutRequest) String ¶
func (m *PutRequest) String() string
func (*PutRequest) Unmarshal ¶
func (m *PutRequest) Unmarshal(dAtA []byte) error
func (*PutRequest) XXX_DiscardUnknown ¶
func (m *PutRequest) XXX_DiscardUnknown()
func (*PutRequest) XXX_Marshal ¶
func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutRequest) XXX_Merge ¶
func (m *PutRequest) XXX_Merge(src proto.Message)
func (*PutRequest) XXX_Size ¶
func (m *PutRequest) XXX_Size() int
func (*PutRequest) XXX_Unmarshal ¶
func (m *PutRequest) XXX_Unmarshal(b []byte) error
type PutResponse ¶
type PutResponse struct { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` }
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) GetEntry ¶
func (m *PutResponse) GetEntry() Entry
func (*PutResponse) GetHeaders ¶
func (m *PutResponse) GetHeaders() primitive.ResponseHeaders
func (*PutResponse) Marshal ¶
func (m *PutResponse) Marshal() (dAtA []byte, err error)
func (*PutResponse) MarshalToSizedBuffer ¶
func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶
func (m *PutResponse) Reset()
func (*PutResponse) Size ¶
func (m *PutResponse) Size() (n int)
func (*PutResponse) String ¶
func (m *PutResponse) String() string
func (*PutResponse) Unmarshal ¶
func (m *PutResponse) Unmarshal(dAtA []byte) error
func (*PutResponse) XXX_DiscardUnknown ¶
func (m *PutResponse) XXX_DiscardUnknown()
func (*PutResponse) XXX_Marshal ¶
func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PutResponse) XXX_Merge ¶
func (m *PutResponse) XXX_Merge(src proto.Message)
func (*PutResponse) XXX_Size ¶
func (m *PutResponse) XXX_Size() int
func (*PutResponse) XXX_Unmarshal ¶
func (m *PutResponse) XXX_Unmarshal(b []byte) error
type RemoveRequest ¶
type RemoveRequest struct { Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Key Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key"` Preconditions []Precondition `protobuf:"bytes,3,rep,name=preconditions,proto3" json:"preconditions"` }
func (*RemoveRequest) Descriptor ¶
func (*RemoveRequest) Descriptor() ([]byte, []int)
func (*RemoveRequest) GetHeaders ¶
func (m *RemoveRequest) GetHeaders() primitive.RequestHeaders
func (*RemoveRequest) GetKey ¶
func (m *RemoveRequest) GetKey() Key
func (*RemoveRequest) GetPreconditions ¶
func (m *RemoveRequest) GetPreconditions() []Precondition
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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Entry Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry"` }
func (*RemoveResponse) Descriptor ¶
func (*RemoveResponse) Descriptor() ([]byte, []int)
func (*RemoveResponse) GetEntry ¶
func (m *RemoveResponse) GetEntry() Entry
func (*RemoveResponse) GetHeaders ¶
func (m *RemoveResponse) GetHeaders() primitive.ResponseHeaders
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 SizeRequest ¶
type SizeRequest struct {
Headers primitive.RequestHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"`
}
func (*SizeRequest) Descriptor ¶
func (*SizeRequest) Descriptor() ([]byte, []int)
func (*SizeRequest) GetHeaders ¶
func (m *SizeRequest) GetHeaders() primitive.RequestHeaders
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 { Headers primitive.ResponseHeaders `protobuf:"bytes,1,opt,name=headers,proto3" json:"headers"` Size_ uint32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` }
func (*SizeResponse) Descriptor ¶
func (*SizeResponse) Descriptor() ([]byte, []int)
func (*SizeResponse) GetHeaders ¶
func (m *SizeResponse) GetHeaders() primitive.ResponseHeaders
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 UnimplementedMapServiceServer ¶
type UnimplementedMapServiceServer struct { }
UnimplementedMapServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMapServiceServer) Clear ¶
func (*UnimplementedMapServiceServer) Clear(ctx context.Context, req *ClearRequest) (*ClearResponse, error)
func (*UnimplementedMapServiceServer) Entries ¶
func (*UnimplementedMapServiceServer) Entries(req *EntriesRequest, srv MapService_EntriesServer) error
func (*UnimplementedMapServiceServer) Events ¶
func (*UnimplementedMapServiceServer) Events(req *EventsRequest, srv MapService_EventsServer) error
func (*UnimplementedMapServiceServer) Get ¶
func (*UnimplementedMapServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedMapServiceServer) Put ¶
func (*UnimplementedMapServiceServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)
func (*UnimplementedMapServiceServer) Remove ¶
func (*UnimplementedMapServiceServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)
func (*UnimplementedMapServiceServer) Size ¶
func (*UnimplementedMapServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
type Value ¶
type Value struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` TTL *time.Duration `protobuf:"bytes,2,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"` }
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) XXX_DiscardUnknown ¶
func (m *Value) XXX_DiscardUnknown()
func (*Value) XXX_Marshal ¶
func (*Value) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.