Documentation ¶
Index ¶
- Variables
- func RegisterMapServiceServer(s *grpc.Server, srv MapServiceServer)
- type ClearRequest
- func (*ClearRequest) Descriptor() ([]byte, []int)
- func (m *ClearRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- 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 CloseRequest
- func (*CloseRequest) Descriptor() ([]byte, []int)
- func (m *CloseRequest) GetDelete() bool
- func (m *CloseRequest) GetHeader() *headers.RequestHeader
- func (m *CloseRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseRequest) ProtoMessage()
- func (m *CloseRequest) Reset()
- func (m *CloseRequest) Size() (n int)
- func (m *CloseRequest) String() string
- func (m *CloseRequest) Unmarshal(dAtA []byte) error
- func (m *CloseRequest) XXX_DiscardUnknown()
- func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseRequest) XXX_Merge(src proto.Message)
- func (m *CloseRequest) XXX_Size() int
- func (m *CloseRequest) XXX_Unmarshal(b []byte) error
- type CloseResponse
- func (*CloseResponse) Descriptor() ([]byte, []int)
- func (m *CloseResponse) GetHeader() *headers.ResponseHeader
- func (m *CloseResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResponse) ProtoMessage()
- func (m *CloseResponse) Reset()
- func (m *CloseResponse) Size() (n int)
- func (m *CloseResponse) String() string
- func (m *CloseResponse) Unmarshal(dAtA []byte) error
- func (m *CloseResponse) XXX_DiscardUnknown()
- func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResponse) XXX_Merge(src proto.Message)
- func (m *CloseResponse) XXX_Size() int
- func (m *CloseResponse) XXX_Unmarshal(b []byte) error
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetHeader() *headers.RequestHeader
- func (m *CreateRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) Size() (n int)
- func (m *CreateRequest) String() string
- func (m *CreateRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetHeader() *headers.ResponseHeader
- func (m *CreateResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) Size() (n int)
- func (m *CreateResponse) String() string
- func (m *CreateResponse) Unmarshal(dAtA []byte) error
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type EntriesRequest
- func (*EntriesRequest) Descriptor() ([]byte, []int)
- func (m *EntriesRequest) GetHeader() *headers.RequestHeader
- 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) GetCreated() time.Time
- func (m *EntriesResponse) GetHeader() *headers.ResponseHeader
- func (m *EntriesResponse) GetKey() string
- func (m *EntriesResponse) GetUpdated() time.Time
- func (m *EntriesResponse) GetValue() []byte
- func (m *EntriesResponse) GetVersion() uint64
- 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 EventRequest
- func (*EventRequest) Descriptor() ([]byte, []int)
- func (m *EventRequest) GetHeader() *headers.RequestHeader
- func (m *EventRequest) GetKey() string
- func (m *EventRequest) GetReplay() bool
- func (m *EventRequest) Marshal() (dAtA []byte, err error)
- func (m *EventRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *EventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventRequest) ProtoMessage()
- func (m *EventRequest) Reset()
- func (m *EventRequest) Size() (n int)
- func (m *EventRequest) String() string
- func (m *EventRequest) Unmarshal(dAtA []byte) error
- func (m *EventRequest) XXX_DiscardUnknown()
- func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventRequest) XXX_Merge(src proto.Message)
- func (m *EventRequest) XXX_Size() int
- func (m *EventRequest) XXX_Unmarshal(b []byte) error
- type EventResponse
- func (*EventResponse) Descriptor() ([]byte, []int)
- func (m *EventResponse) GetCreated() time.Time
- func (m *EventResponse) GetHeader() *headers.ResponseHeader
- func (m *EventResponse) GetKey() string
- func (m *EventResponse) GetType() EventResponse_Type
- func (m *EventResponse) GetUpdated() time.Time
- func (m *EventResponse) GetValue() []byte
- func (m *EventResponse) GetVersion() uint64
- func (m *EventResponse) Marshal() (dAtA []byte, err error)
- func (m *EventResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventResponse) ProtoMessage()
- func (m *EventResponse) Reset()
- func (m *EventResponse) Size() (n int)
- func (m *EventResponse) String() string
- func (m *EventResponse) Unmarshal(dAtA []byte) error
- func (m *EventResponse) XXX_DiscardUnknown()
- func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventResponse) XXX_Merge(src proto.Message)
- func (m *EventResponse) XXX_Size() int
- func (m *EventResponse) XXX_Unmarshal(b []byte) error
- type EventResponse_Type
- type ExistsRequest
- func (*ExistsRequest) Descriptor() ([]byte, []int)
- func (m *ExistsRequest) GetHeader() *headers.RequestHeader
- func (m *ExistsRequest) GetKey() string
- func (m *ExistsRequest) Marshal() (dAtA []byte, err error)
- func (m *ExistsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExistsRequest) ProtoMessage()
- func (m *ExistsRequest) Reset()
- func (m *ExistsRequest) Size() (n int)
- func (m *ExistsRequest) String() string
- func (m *ExistsRequest) Unmarshal(dAtA []byte) error
- func (m *ExistsRequest) XXX_DiscardUnknown()
- func (m *ExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExistsRequest) XXX_Merge(src proto.Message)
- func (m *ExistsRequest) XXX_Size() int
- func (m *ExistsRequest) XXX_Unmarshal(b []byte) error
- type ExistsResponse
- func (*ExistsResponse) Descriptor() ([]byte, []int)
- func (m *ExistsResponse) GetContainsKey() bool
- func (m *ExistsResponse) GetHeader() *headers.ResponseHeader
- func (m *ExistsResponse) Marshal() (dAtA []byte, err error)
- func (m *ExistsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExistsResponse) ProtoMessage()
- func (m *ExistsResponse) Reset()
- func (m *ExistsResponse) Size() (n int)
- func (m *ExistsResponse) String() string
- func (m *ExistsResponse) Unmarshal(dAtA []byte) error
- func (m *ExistsResponse) XXX_DiscardUnknown()
- func (m *ExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExistsResponse) XXX_Merge(src proto.Message)
- func (m *ExistsResponse) XXX_Size() int
- func (m *ExistsResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetHeader() *headers.RequestHeader
- 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) GetCreated() time.Time
- func (m *GetResponse) GetHeader() *headers.ResponseHeader
- func (m *GetResponse) GetUpdated() time.Time
- func (m *GetResponse) GetValue() []byte
- func (m *GetResponse) GetVersion() uint64
- 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 MapServiceClient
- type MapServiceServer
- type MapService_EntriesClient
- type MapService_EntriesServer
- type MapService_EventsClient
- type MapService_EventsServer
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)
- func (m *PutRequest) GetHeader() *headers.RequestHeader
- func (m *PutRequest) GetIfEmpty() bool
- func (m *PutRequest) GetKey() string
- func (m *PutRequest) GetTTL() *time.Duration
- func (m *PutRequest) GetValue() []byte
- func (m *PutRequest) GetVersion() uint64
- 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) GetCreated() time.Time
- func (m *PutResponse) GetHeader() *headers.ResponseHeader
- func (m *PutResponse) GetPreviousValue() []byte
- func (m *PutResponse) GetPreviousVersion() uint64
- func (m *PutResponse) GetStatus() ResponseStatus
- func (m *PutResponse) GetUpdated() time.Time
- 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) GetCreated() time.Time
- func (m *RemoveRequest) GetHeader() *headers.RequestHeader
- func (m *RemoveRequest) GetKey() string
- func (m *RemoveRequest) GetUpdated() time.Time
- func (m *RemoveRequest) GetValue() []byte
- func (m *RemoveRequest) GetVersion() uint64
- 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) GetHeader() *headers.ResponseHeader
- func (m *RemoveResponse) GetPreviousValue() []byte
- func (m *RemoveResponse) GetPreviousVersion() uint64
- func (m *RemoveResponse) GetStatus() ResponseStatus
- 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 ReplaceRequest
- func (*ReplaceRequest) Descriptor() ([]byte, []int)
- func (m *ReplaceRequest) GetHeader() *headers.RequestHeader
- func (m *ReplaceRequest) GetKey() string
- func (m *ReplaceRequest) GetNewValue() []byte
- func (m *ReplaceRequest) GetPreviousValue() []byte
- func (m *ReplaceRequest) GetPreviousVersion() uint64
- func (m *ReplaceRequest) GetTTL() *time.Duration
- func (m *ReplaceRequest) Marshal() (dAtA []byte, err error)
- func (m *ReplaceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplaceRequest) ProtoMessage()
- func (m *ReplaceRequest) Reset()
- func (m *ReplaceRequest) Size() (n int)
- func (m *ReplaceRequest) String() string
- func (m *ReplaceRequest) Unmarshal(dAtA []byte) error
- func (m *ReplaceRequest) XXX_DiscardUnknown()
- func (m *ReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplaceRequest) XXX_Merge(src proto.Message)
- func (m *ReplaceRequest) XXX_Size() int
- func (m *ReplaceRequest) XXX_Unmarshal(b []byte) error
- type ReplaceResponse
- func (*ReplaceResponse) Descriptor() ([]byte, []int)
- func (m *ReplaceResponse) GetCreated() time.Time
- func (m *ReplaceResponse) GetHeader() *headers.ResponseHeader
- func (m *ReplaceResponse) GetPreviousValue() []byte
- func (m *ReplaceResponse) GetPreviousVersion() uint64
- func (m *ReplaceResponse) GetStatus() ResponseStatus
- func (m *ReplaceResponse) GetUpdated() time.Time
- func (m *ReplaceResponse) Marshal() (dAtA []byte, err error)
- func (m *ReplaceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplaceResponse) ProtoMessage()
- func (m *ReplaceResponse) Reset()
- func (m *ReplaceResponse) Size() (n int)
- func (m *ReplaceResponse) String() string
- func (m *ReplaceResponse) Unmarshal(dAtA []byte) error
- func (m *ReplaceResponse) XXX_DiscardUnknown()
- func (m *ReplaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplaceResponse) XXX_Merge(src proto.Message)
- func (m *ReplaceResponse) XXX_Size() int
- func (m *ReplaceResponse) XXX_Unmarshal(b []byte) error
- type ResponseStatus
- type SizeRequest
- func (*SizeRequest) Descriptor() ([]byte, []int)
- func (m *SizeRequest) GetHeader() *headers.RequestHeader
- 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) GetHeader() *headers.ResponseHeader
- 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) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
- func (*UnimplementedMapServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
- func (*UnimplementedMapServiceServer) Entries(req *EntriesRequest, srv MapService_EntriesServer) error
- func (*UnimplementedMapServiceServer) Events(req *EventRequest, srv MapService_EventsServer) error
- func (*UnimplementedMapServiceServer) Exists(ctx context.Context, req *ExistsRequest) (*ExistsResponse, 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) Replace(ctx context.Context, req *ReplaceRequest) (*ReplaceResponse, error)
- func (*UnimplementedMapServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, 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 EventResponse_Type_name = map[int32]string{
0: "NONE",
1: "INSERTED",
2: "UPDATED",
3: "REMOVED",
}
View Source
var EventResponse_Type_value = map[string]int32{
"NONE": 0,
"INSERTED": 1,
"UPDATED": 2,
"REMOVED": 3,
}
View Source
var ResponseStatus_name = map[int32]string{
0: "OK",
1: "NOOP",
2: "WRITE_LOCK",
3: "PRECONDITION_FAILED",
}
View Source
var ResponseStatus_value = map[string]int32{
"OK": 0,
"NOOP": 1,
"WRITE_LOCK": 2,
"PRECONDITION_FAILED": 3,
}
Functions ¶
func RegisterMapServiceServer ¶
func RegisterMapServiceServer(s *grpc.Server, srv MapServiceServer)
Types ¶
type ClearRequest ¶
type ClearRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*ClearRequest) Descriptor ¶
func (*ClearRequest) Descriptor() ([]byte, []int)
func (*ClearRequest) GetHeader ¶
func (m *ClearRequest) GetHeader() *headers.RequestHeader
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 {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*ClearResponse) Descriptor ¶
func (*ClearResponse) Descriptor() ([]byte, []int)
func (*ClearResponse) GetHeader ¶
func (m *ClearResponse) GetHeader() *headers.ResponseHeader
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 CloseRequest ¶
type CloseRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Delete bool `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"` }
func (*CloseRequest) Descriptor ¶
func (*CloseRequest) Descriptor() ([]byte, []int)
func (*CloseRequest) GetDelete ¶
func (m *CloseRequest) GetDelete() bool
func (*CloseRequest) GetHeader ¶
func (m *CloseRequest) GetHeader() *headers.RequestHeader
func (*CloseRequest) Marshal ¶
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (*CloseRequest) MarshalToSizedBuffer ¶
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) Size ¶
func (m *CloseRequest) Size() (n int)
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
func (*CloseRequest) Unmarshal ¶
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (*CloseRequest) XXX_DiscardUnknown ¶
func (m *CloseRequest) XXX_DiscardUnknown()
func (*CloseRequest) XXX_Marshal ¶
func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseRequest) XXX_Merge ¶
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (*CloseRequest) XXX_Size ¶
func (m *CloseRequest) XXX_Size() int
func (*CloseRequest) XXX_Unmarshal ¶
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse ¶
type CloseResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CloseResponse) Descriptor ¶
func (*CloseResponse) Descriptor() ([]byte, []int)
func (*CloseResponse) GetHeader ¶
func (m *CloseResponse) GetHeader() *headers.ResponseHeader
func (*CloseResponse) Marshal ¶
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (*CloseResponse) MarshalToSizedBuffer ¶
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) Size ¶
func (m *CloseResponse) Size() (n int)
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
func (*CloseResponse) Unmarshal ¶
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (*CloseResponse) XXX_DiscardUnknown ¶
func (m *CloseResponse) XXX_DiscardUnknown()
func (*CloseResponse) XXX_Marshal ¶
func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseResponse) XXX_Merge ¶
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (*CloseResponse) XXX_Size ¶
func (m *CloseResponse) XXX_Size() int
func (*CloseResponse) XXX_Unmarshal ¶
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type CreateRequest ¶
type CreateRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetHeader ¶
func (m *CreateRequest) GetHeader() *headers.RequestHeader
func (*CreateRequest) Marshal ¶
func (m *CreateRequest) Marshal() (dAtA []byte, err error)
func (*CreateRequest) MarshalToSizedBuffer ¶
func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) Size ¶
func (m *CreateRequest) Size() (n int)
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) Unmarshal ¶
func (m *CreateRequest) Unmarshal(dAtA []byte) error
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct {
Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetHeader ¶
func (m *CreateResponse) GetHeader() *headers.ResponseHeader
func (*CreateResponse) Marshal ¶
func (m *CreateResponse) Marshal() (dAtA []byte, err error)
func (*CreateResponse) MarshalToSizedBuffer ¶
func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) Size ¶
func (m *CreateResponse) Size() (n int)
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) Unmarshal ¶
func (m *CreateResponse) Unmarshal(dAtA []byte) error
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type EntriesRequest ¶
type EntriesRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*EntriesRequest) Descriptor ¶
func (*EntriesRequest) Descriptor() ([]byte, []int)
func (*EntriesRequest) GetHeader ¶
func (m *EntriesRequest) GetHeader() *headers.RequestHeader
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` Created time.Time `protobuf:"bytes,5,opt,name=created,proto3,stdtime" json:"created"` Updated time.Time `protobuf:"bytes,6,opt,name=updated,proto3,stdtime" json:"updated"` }
func (*EntriesResponse) Descriptor ¶
func (*EntriesResponse) Descriptor() ([]byte, []int)
func (*EntriesResponse) GetCreated ¶
func (m *EntriesResponse) GetCreated() time.Time
func (*EntriesResponse) GetHeader ¶
func (m *EntriesResponse) GetHeader() *headers.ResponseHeader
func (*EntriesResponse) GetKey ¶
func (m *EntriesResponse) GetKey() string
func (*EntriesResponse) GetUpdated ¶
func (m *EntriesResponse) GetUpdated() time.Time
func (*EntriesResponse) GetValue ¶
func (m *EntriesResponse) GetValue() []byte
func (*EntriesResponse) GetVersion ¶
func (m *EntriesResponse) GetVersion() uint64
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 EventRequest ¶
type EventRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Replay bool `protobuf:"varint,2,opt,name=replay,proto3" json:"replay,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` }
func (*EventRequest) Descriptor ¶
func (*EventRequest) Descriptor() ([]byte, []int)
func (*EventRequest) GetHeader ¶
func (m *EventRequest) GetHeader() *headers.RequestHeader
func (*EventRequest) GetKey ¶
func (m *EventRequest) GetKey() string
func (*EventRequest) GetReplay ¶
func (m *EventRequest) GetReplay() bool
func (*EventRequest) Marshal ¶
func (m *EventRequest) Marshal() (dAtA []byte, err error)
func (*EventRequest) MarshalToSizedBuffer ¶
func (m *EventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventRequest) ProtoMessage ¶
func (*EventRequest) ProtoMessage()
func (*EventRequest) Reset ¶
func (m *EventRequest) Reset()
func (*EventRequest) Size ¶
func (m *EventRequest) Size() (n int)
func (*EventRequest) String ¶
func (m *EventRequest) String() string
func (*EventRequest) Unmarshal ¶
func (m *EventRequest) Unmarshal(dAtA []byte) error
func (*EventRequest) XXX_DiscardUnknown ¶
func (m *EventRequest) XXX_DiscardUnknown()
func (*EventRequest) XXX_Marshal ¶
func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventRequest) XXX_Merge ¶
func (m *EventRequest) XXX_Merge(src proto.Message)
func (*EventRequest) XXX_Size ¶
func (m *EventRequest) XXX_Size() int
func (*EventRequest) XXX_Unmarshal ¶
func (m *EventRequest) XXX_Unmarshal(b []byte) error
type EventResponse ¶
type EventResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Type EventResponse_Type `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.map.EventResponse_Type" json:"type,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"` Created time.Time `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"` Updated time.Time `protobuf:"bytes,7,opt,name=updated,proto3,stdtime" json:"updated"` }
func (*EventResponse) Descriptor ¶
func (*EventResponse) Descriptor() ([]byte, []int)
func (*EventResponse) GetCreated ¶
func (m *EventResponse) GetCreated() time.Time
func (*EventResponse) GetHeader ¶
func (m *EventResponse) GetHeader() *headers.ResponseHeader
func (*EventResponse) GetKey ¶
func (m *EventResponse) GetKey() string
func (*EventResponse) GetType ¶
func (m *EventResponse) GetType() EventResponse_Type
func (*EventResponse) GetUpdated ¶
func (m *EventResponse) GetUpdated() time.Time
func (*EventResponse) GetValue ¶
func (m *EventResponse) GetValue() []byte
func (*EventResponse) GetVersion ¶
func (m *EventResponse) GetVersion() uint64
func (*EventResponse) Marshal ¶
func (m *EventResponse) Marshal() (dAtA []byte, err error)
func (*EventResponse) MarshalToSizedBuffer ¶
func (m *EventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventResponse) ProtoMessage ¶
func (*EventResponse) ProtoMessage()
func (*EventResponse) Reset ¶
func (m *EventResponse) Reset()
func (*EventResponse) Size ¶
func (m *EventResponse) Size() (n int)
func (*EventResponse) String ¶
func (m *EventResponse) String() string
func (*EventResponse) Unmarshal ¶
func (m *EventResponse) Unmarshal(dAtA []byte) error
func (*EventResponse) XXX_DiscardUnknown ¶
func (m *EventResponse) XXX_DiscardUnknown()
func (*EventResponse) XXX_Marshal ¶
func (m *EventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventResponse) XXX_Merge ¶
func (m *EventResponse) XXX_Merge(src proto.Message)
func (*EventResponse) XXX_Size ¶
func (m *EventResponse) XXX_Size() int
func (*EventResponse) XXX_Unmarshal ¶
func (m *EventResponse) XXX_Unmarshal(b []byte) error
type EventResponse_Type ¶
type EventResponse_Type int32
const ( EventResponse_NONE EventResponse_Type = 0 EventResponse_INSERTED EventResponse_Type = 1 EventResponse_UPDATED EventResponse_Type = 2 EventResponse_REMOVED EventResponse_Type = 3 )
func (EventResponse_Type) EnumDescriptor ¶
func (EventResponse_Type) EnumDescriptor() ([]byte, []int)
func (EventResponse_Type) String ¶
func (x EventResponse_Type) String() string
type ExistsRequest ¶
type ExistsRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` }
func (*ExistsRequest) Descriptor ¶
func (*ExistsRequest) Descriptor() ([]byte, []int)
func (*ExistsRequest) GetHeader ¶
func (m *ExistsRequest) GetHeader() *headers.RequestHeader
func (*ExistsRequest) GetKey ¶
func (m *ExistsRequest) GetKey() string
func (*ExistsRequest) Marshal ¶
func (m *ExistsRequest) Marshal() (dAtA []byte, err error)
func (*ExistsRequest) MarshalToSizedBuffer ¶
func (m *ExistsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExistsRequest) ProtoMessage ¶
func (*ExistsRequest) ProtoMessage()
func (*ExistsRequest) Reset ¶
func (m *ExistsRequest) Reset()
func (*ExistsRequest) Size ¶
func (m *ExistsRequest) Size() (n int)
func (*ExistsRequest) String ¶
func (m *ExistsRequest) String() string
func (*ExistsRequest) Unmarshal ¶
func (m *ExistsRequest) Unmarshal(dAtA []byte) error
func (*ExistsRequest) XXX_DiscardUnknown ¶
func (m *ExistsRequest) XXX_DiscardUnknown()
func (*ExistsRequest) XXX_Marshal ¶
func (m *ExistsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExistsRequest) XXX_Merge ¶
func (m *ExistsRequest) XXX_Merge(src proto.Message)
func (*ExistsRequest) XXX_Size ¶
func (m *ExistsRequest) XXX_Size() int
func (*ExistsRequest) XXX_Unmarshal ¶
func (m *ExistsRequest) XXX_Unmarshal(b []byte) error
type ExistsResponse ¶
type ExistsResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ContainsKey bool `protobuf:"varint,2,opt,name=contains_key,json=containsKey,proto3" json:"contains_key,omitempty"` }
func (*ExistsResponse) Descriptor ¶
func (*ExistsResponse) Descriptor() ([]byte, []int)
func (*ExistsResponse) GetContainsKey ¶
func (m *ExistsResponse) GetContainsKey() bool
func (*ExistsResponse) GetHeader ¶
func (m *ExistsResponse) GetHeader() *headers.ResponseHeader
func (*ExistsResponse) Marshal ¶
func (m *ExistsResponse) Marshal() (dAtA []byte, err error)
func (*ExistsResponse) MarshalToSizedBuffer ¶
func (m *ExistsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExistsResponse) ProtoMessage ¶
func (*ExistsResponse) ProtoMessage()
func (*ExistsResponse) Reset ¶
func (m *ExistsResponse) Reset()
func (*ExistsResponse) Size ¶
func (m *ExistsResponse) Size() (n int)
func (*ExistsResponse) String ¶
func (m *ExistsResponse) String() string
func (*ExistsResponse) Unmarshal ¶
func (m *ExistsResponse) Unmarshal(dAtA []byte) error
func (*ExistsResponse) XXX_DiscardUnknown ¶
func (m *ExistsResponse) XXX_DiscardUnknown()
func (*ExistsResponse) XXX_Marshal ¶
func (m *ExistsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExistsResponse) XXX_Merge ¶
func (m *ExistsResponse) XXX_Merge(src proto.Message)
func (*ExistsResponse) XXX_Size ¶
func (m *ExistsResponse) XXX_Size() int
func (*ExistsResponse) XXX_Unmarshal ¶
func (m *ExistsResponse) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetHeader ¶
func (m *GetRequest) GetHeader() *headers.RequestHeader
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` Updated time.Time `protobuf:"bytes,5,opt,name=updated,proto3,stdtime" json:"updated"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetCreated ¶
func (m *GetResponse) GetCreated() time.Time
func (*GetResponse) GetHeader ¶
func (m *GetResponse) GetHeader() *headers.ResponseHeader
func (*GetResponse) GetUpdated ¶
func (m *GetResponse) GetUpdated() time.Time
func (*GetResponse) GetValue ¶
func (m *GetResponse) GetValue() []byte
func (*GetResponse) GetVersion ¶
func (m *GetResponse) GetVersion() uint64
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 MapServiceClient ¶
type MapServiceClient interface { // Create creates an indexed map Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) // Close closes an indexed map Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) // Size returns the size of the map Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error) // Exists checks whether a key exists in the map Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error) // Put puts an entry into the map Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) // Replace performs a check-and-set operation on an entry in the map Replace(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*ReplaceResponse, 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 *EventRequest, 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 { // Create creates an indexed map Create(context.Context, *CreateRequest) (*CreateResponse, error) // Close closes an indexed map Close(context.Context, *CloseRequest) (*CloseResponse, error) // Size returns the size of the map Size(context.Context, *SizeRequest) (*SizeResponse, error) // Exists checks whether a key exists in the map Exists(context.Context, *ExistsRequest) (*ExistsResponse, error) // Put puts an entry into the map Put(context.Context, *PutRequest) (*PutResponse, error) // Replace performs a check-and-set operation on an entry in the map Replace(context.Context, *ReplaceRequest) (*ReplaceResponse, 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(*EventRequest, 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() (*EventResponse, error) grpc.ClientStream }
type MapService_EventsServer ¶
type MapService_EventsServer interface { Send(*EventResponse) error grpc.ServerStream }
type PutRequest ¶
type PutRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` IfEmpty bool `protobuf:"varint,6,opt,name=if_empty,json=ifEmpty,proto3" json:"if_empty,omitempty"` TTL *time.Duration `protobuf:"bytes,5,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"` }
func (*PutRequest) Descriptor ¶
func (*PutRequest) Descriptor() ([]byte, []int)
func (*PutRequest) GetHeader ¶
func (m *PutRequest) GetHeader() *headers.RequestHeader
func (*PutRequest) GetIfEmpty ¶ added in v0.3.1
func (m *PutRequest) GetIfEmpty() bool
func (*PutRequest) GetKey ¶
func (m *PutRequest) GetKey() string
func (*PutRequest) GetTTL ¶
func (m *PutRequest) GetTTL() *time.Duration
func (*PutRequest) GetValue ¶
func (m *PutRequest) GetValue() []byte
func (*PutRequest) GetVersion ¶
func (m *PutRequest) GetVersion() uint64
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Status ResponseStatus `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.map.ResponseStatus" json:"status,omitempty"` Created time.Time `protobuf:"bytes,3,opt,name=created,proto3,stdtime" json:"created"` Updated time.Time `protobuf:"bytes,4,opt,name=updated,proto3,stdtime" json:"updated"` PreviousValue []byte `protobuf:"bytes,5,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` PreviousVersion uint64 `protobuf:"varint,6,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` }
func (*PutResponse) Descriptor ¶
func (*PutResponse) Descriptor() ([]byte, []int)
func (*PutResponse) GetCreated ¶
func (m *PutResponse) GetCreated() time.Time
func (*PutResponse) GetHeader ¶
func (m *PutResponse) GetHeader() *headers.ResponseHeader
func (*PutResponse) GetPreviousValue ¶
func (m *PutResponse) GetPreviousValue() []byte
func (*PutResponse) GetPreviousVersion ¶
func (m *PutResponse) GetPreviousVersion() uint64
func (*PutResponse) GetStatus ¶
func (m *PutResponse) GetStatus() ResponseStatus
func (*PutResponse) GetUpdated ¶
func (m *PutResponse) GetUpdated() time.Time
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 { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Version uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` Created time.Time `protobuf:"bytes,5,opt,name=created,proto3,stdtime" json:"created"` Updated time.Time `protobuf:"bytes,6,opt,name=updated,proto3,stdtime" json:"updated"` }
func (*RemoveRequest) Descriptor ¶
func (*RemoveRequest) Descriptor() ([]byte, []int)
func (*RemoveRequest) GetCreated ¶
func (m *RemoveRequest) GetCreated() time.Time
func (*RemoveRequest) GetHeader ¶
func (m *RemoveRequest) GetHeader() *headers.RequestHeader
func (*RemoveRequest) GetKey ¶
func (m *RemoveRequest) GetKey() string
func (*RemoveRequest) GetUpdated ¶
func (m *RemoveRequest) GetUpdated() time.Time
func (*RemoveRequest) GetValue ¶
func (m *RemoveRequest) GetValue() []byte
func (*RemoveRequest) GetVersion ¶
func (m *RemoveRequest) GetVersion() uint64
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Status ResponseStatus `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.map.ResponseStatus" json:"status,omitempty"` PreviousValue []byte `protobuf:"bytes,3,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` PreviousVersion uint64 `protobuf:"varint,4,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` }
func (*RemoveResponse) Descriptor ¶
func (*RemoveResponse) Descriptor() ([]byte, []int)
func (*RemoveResponse) GetHeader ¶
func (m *RemoveResponse) GetHeader() *headers.ResponseHeader
func (*RemoveResponse) GetPreviousValue ¶
func (m *RemoveResponse) GetPreviousValue() []byte
func (*RemoveResponse) GetPreviousVersion ¶
func (m *RemoveResponse) GetPreviousVersion() uint64
func (*RemoveResponse) GetStatus ¶
func (m *RemoveResponse) GetStatus() ResponseStatus
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 ReplaceRequest ¶
type ReplaceRequest struct { Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` PreviousValue []byte `protobuf:"bytes,3,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` PreviousVersion uint64 `protobuf:"varint,4,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` NewValue []byte `protobuf:"bytes,5,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"` TTL *time.Duration `protobuf:"bytes,6,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"` }
func (*ReplaceRequest) Descriptor ¶
func (*ReplaceRequest) Descriptor() ([]byte, []int)
func (*ReplaceRequest) GetHeader ¶
func (m *ReplaceRequest) GetHeader() *headers.RequestHeader
func (*ReplaceRequest) GetKey ¶
func (m *ReplaceRequest) GetKey() string
func (*ReplaceRequest) GetNewValue ¶
func (m *ReplaceRequest) GetNewValue() []byte
func (*ReplaceRequest) GetPreviousValue ¶
func (m *ReplaceRequest) GetPreviousValue() []byte
func (*ReplaceRequest) GetPreviousVersion ¶
func (m *ReplaceRequest) GetPreviousVersion() uint64
func (*ReplaceRequest) GetTTL ¶
func (m *ReplaceRequest) GetTTL() *time.Duration
func (*ReplaceRequest) Marshal ¶
func (m *ReplaceRequest) Marshal() (dAtA []byte, err error)
func (*ReplaceRequest) MarshalToSizedBuffer ¶
func (m *ReplaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplaceRequest) ProtoMessage ¶
func (*ReplaceRequest) ProtoMessage()
func (*ReplaceRequest) Reset ¶
func (m *ReplaceRequest) Reset()
func (*ReplaceRequest) Size ¶
func (m *ReplaceRequest) Size() (n int)
func (*ReplaceRequest) String ¶
func (m *ReplaceRequest) String() string
func (*ReplaceRequest) Unmarshal ¶
func (m *ReplaceRequest) Unmarshal(dAtA []byte) error
func (*ReplaceRequest) XXX_DiscardUnknown ¶
func (m *ReplaceRequest) XXX_DiscardUnknown()
func (*ReplaceRequest) XXX_Marshal ¶
func (m *ReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplaceRequest) XXX_Merge ¶
func (m *ReplaceRequest) XXX_Merge(src proto.Message)
func (*ReplaceRequest) XXX_Size ¶
func (m *ReplaceRequest) XXX_Size() int
func (*ReplaceRequest) XXX_Unmarshal ¶
func (m *ReplaceRequest) XXX_Unmarshal(b []byte) error
type ReplaceResponse ¶
type ReplaceResponse struct { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Status ResponseStatus `protobuf:"varint,2,opt,name=status,proto3,enum=atomix.map.ResponseStatus" json:"status,omitempty"` Created time.Time `protobuf:"bytes,3,opt,name=created,proto3,stdtime" json:"created"` Updated time.Time `protobuf:"bytes,4,opt,name=updated,proto3,stdtime" json:"updated"` PreviousValue []byte `protobuf:"bytes,5,opt,name=previous_value,json=previousValue,proto3" json:"previous_value,omitempty"` PreviousVersion uint64 `protobuf:"varint,6,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` }
func (*ReplaceResponse) Descriptor ¶
func (*ReplaceResponse) Descriptor() ([]byte, []int)
func (*ReplaceResponse) GetCreated ¶
func (m *ReplaceResponse) GetCreated() time.Time
func (*ReplaceResponse) GetHeader ¶
func (m *ReplaceResponse) GetHeader() *headers.ResponseHeader
func (*ReplaceResponse) GetPreviousValue ¶
func (m *ReplaceResponse) GetPreviousValue() []byte
func (*ReplaceResponse) GetPreviousVersion ¶
func (m *ReplaceResponse) GetPreviousVersion() uint64
func (*ReplaceResponse) GetStatus ¶
func (m *ReplaceResponse) GetStatus() ResponseStatus
func (*ReplaceResponse) GetUpdated ¶
func (m *ReplaceResponse) GetUpdated() time.Time
func (*ReplaceResponse) Marshal ¶
func (m *ReplaceResponse) Marshal() (dAtA []byte, err error)
func (*ReplaceResponse) MarshalToSizedBuffer ¶
func (m *ReplaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplaceResponse) ProtoMessage ¶
func (*ReplaceResponse) ProtoMessage()
func (*ReplaceResponse) Reset ¶
func (m *ReplaceResponse) Reset()
func (*ReplaceResponse) Size ¶
func (m *ReplaceResponse) Size() (n int)
func (*ReplaceResponse) String ¶
func (m *ReplaceResponse) String() string
func (*ReplaceResponse) Unmarshal ¶
func (m *ReplaceResponse) Unmarshal(dAtA []byte) error
func (*ReplaceResponse) XXX_DiscardUnknown ¶
func (m *ReplaceResponse) XXX_DiscardUnknown()
func (*ReplaceResponse) XXX_Marshal ¶
func (m *ReplaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplaceResponse) XXX_Merge ¶
func (m *ReplaceResponse) XXX_Merge(src proto.Message)
func (*ReplaceResponse) XXX_Size ¶
func (m *ReplaceResponse) XXX_Size() int
func (*ReplaceResponse) XXX_Unmarshal ¶
func (m *ReplaceResponse) XXX_Unmarshal(b []byte) error
type ResponseStatus ¶
type ResponseStatus int32
const ( ResponseStatus_OK ResponseStatus = 0 ResponseStatus_NOOP ResponseStatus = 1 ResponseStatus_WRITE_LOCK ResponseStatus = 2 ResponseStatus_PRECONDITION_FAILED ResponseStatus = 3 )
func (ResponseStatus) EnumDescriptor ¶
func (ResponseStatus) EnumDescriptor() ([]byte, []int)
func (ResponseStatus) String ¶
func (x ResponseStatus) String() string
type SizeRequest ¶
type SizeRequest struct {
Header *headers.RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
}
func (*SizeRequest) Descriptor ¶
func (*SizeRequest) Descriptor() ([]byte, []int)
func (*SizeRequest) GetHeader ¶
func (m *SizeRequest) GetHeader() *headers.RequestHeader
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 { Header *headers.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Size_ uint32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` }
func (*SizeResponse) Descriptor ¶
func (*SizeResponse) Descriptor() ([]byte, []int)
func (*SizeResponse) GetHeader ¶
func (m *SizeResponse) GetHeader() *headers.ResponseHeader
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) Close ¶
func (*UnimplementedMapServiceServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
func (*UnimplementedMapServiceServer) Create ¶
func (*UnimplementedMapServiceServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
func (*UnimplementedMapServiceServer) Entries ¶
func (*UnimplementedMapServiceServer) Entries(req *EntriesRequest, srv MapService_EntriesServer) error
func (*UnimplementedMapServiceServer) Events ¶
func (*UnimplementedMapServiceServer) Events(req *EventRequest, srv MapService_EventsServer) error
func (*UnimplementedMapServiceServer) Exists ¶
func (*UnimplementedMapServiceServer) Exists(ctx context.Context, req *ExistsRequest) (*ExistsResponse, 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) Replace ¶
func (*UnimplementedMapServiceServer) Replace(ctx context.Context, req *ReplaceRequest) (*ReplaceResponse, error)
func (*UnimplementedMapServiceServer) Size ¶
func (*UnimplementedMapServiceServer) Size(ctx context.Context, req *SizeRequest) (*SizeResponse, error)
Click to show internal directories.
Click to hide internal directories.