Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowMetaStoragepb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMetaStoragepb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMetaStoragepb = fmt.Errorf("proto: unexpected end of group") + var ErrorType_name = map[int32]string + var ErrorType_value = map[string]int32 + var Event_EventType_name = map[int32]string + var Event_EventType_value = map[string]int32 + func RegisterMetaStorageServer(s *grpc.Server, srv MetaStorageServer) + type Error struct + Message string + Type ErrorType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMessage() string + func (m *Error) GetType() ErrorType + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type ErrorType int32 + const ErrorType_DATA_COMPACTED + const ErrorType_OK + const ErrorType_UNKNOWN + func (ErrorType) EnumDescriptor() ([]byte, []int) + func (x ErrorType) String() string + type Event struct + Kv *KeyValue + PrevKv *KeyValue + Type Event_EventType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetKv() *KeyValue + func (m *Event) GetPrevKv() *KeyValue + func (m *Event) GetType() Event_EventType + func (m *Event) Marshal() (dAtA []byte, err error) + func (m *Event) MarshalTo(dAtA []byte) (int, error) + func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) String() string + func (m *Event) Unmarshal(dAtA []byte) error + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type Event_EventType int32 + const Event_DELETE + const Event_PUT + func (Event_EventType) EnumDescriptor() ([]byte, []int) + func (x Event_EventType) String() string + type GetRequest struct + Header *RequestHeader + Key []byte + Limit int64 + RangeEnd []byte + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetHeader() *RequestHeader + func (m *GetRequest) GetKey() []byte + func (m *GetRequest) GetLimit() int64 + func (m *GetRequest) GetRangeEnd() []byte + func (m *GetRequest) GetRevision() int64 + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) Unmarshal(dAtA []byte) error + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Count int64 + Header *ResponseHeader + Kvs []*KeyValue + More bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetCount() int64 + func (m *GetResponse) GetHeader() *ResponseHeader + func (m *GetResponse) GetKvs() []*KeyValue + func (m *GetResponse) GetMore() bool + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) Unmarshal(dAtA []byte) error + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type KeyValue struct + CreateRevision int64 + Key []byte + Lease int64 + ModRevision int64 + Value []byte + Version int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (m *KeyValue) GetCreateRevision() int64 + func (m *KeyValue) GetKey() []byte + func (m *KeyValue) GetLease() int64 + func (m *KeyValue) GetModRevision() int64 + func (m *KeyValue) GetValue() []byte + func (m *KeyValue) GetVersion() int64 + func (m *KeyValue) Marshal() (dAtA []byte, err error) + func (m *KeyValue) MarshalTo(dAtA []byte) (int, error) + func (m *KeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KeyValue) Reset() + func (m *KeyValue) Size() (n int) + func (m *KeyValue) String() string + func (m *KeyValue) Unmarshal(dAtA []byte) error + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + type MetaStorageClient interface + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) + Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (MetaStorage_WatchClient, error) + func NewMetaStorageClient(cc *grpc.ClientConn) MetaStorageClient + type MetaStorageServer interface + Get func(context.Context, *GetRequest) (*GetResponse, error) + Put func(context.Context, *PutRequest) (*PutResponse, error) + Watch func(*WatchRequest, MetaStorage_WatchServer) error + type MetaStorage_WatchClient interface + Recv func() (*WatchResponse, error) + type MetaStorage_WatchServer interface + Send func(*WatchResponse) error + type PutRequest struct + Header *RequestHeader + Key []byte + Lease int64 + PrevKv bool + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) GetHeader() *RequestHeader + func (m *PutRequest) GetKey() []byte + func (m *PutRequest) GetLease() int64 + func (m *PutRequest) GetPrevKv() bool + func (m *PutRequest) GetValue() []byte + func (m *PutRequest) Marshal() (dAtA []byte, err error) + func (m *PutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutRequest) Reset() + func (m *PutRequest) Size() (n int) + func (m *PutRequest) String() string + func (m *PutRequest) Unmarshal(dAtA []byte) error + func (m *PutRequest) XXX_DiscardUnknown() + func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutRequest) XXX_Merge(src proto.Message) + func (m *PutRequest) XXX_Size() int + func (m *PutRequest) XXX_Unmarshal(b []byte) error + type PutResponse struct + Header *ResponseHeader + PrevKv *KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) GetHeader() *ResponseHeader + func (m *PutResponse) GetPrevKv() *KeyValue + func (m *PutResponse) Marshal() (dAtA []byte, err error) + func (m *PutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(dAtA []byte) error + func (m *PutResponse) XXX_DiscardUnknown() + func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutResponse) XXX_Merge(src proto.Message) + func (m *PutResponse) XXX_Size() int + func (m *PutResponse) XXX_Unmarshal(b []byte) error + type RequestHeader struct + ClusterId uint64 + Source string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RequestHeader) Descriptor() ([]byte, []int) + func (*RequestHeader) ProtoMessage() + func (m *RequestHeader) GetClusterId() uint64 + func (m *RequestHeader) GetSource() string + func (m *RequestHeader) Marshal() (dAtA []byte, err error) + func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestHeader) Reset() + func (m *RequestHeader) Size() (n int) + func (m *RequestHeader) String() string + func (m *RequestHeader) Unmarshal(dAtA []byte) error + func (m *RequestHeader) XXX_DiscardUnknown() + func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestHeader) XXX_Merge(src proto.Message) + func (m *RequestHeader) XXX_Size() int + func (m *RequestHeader) XXX_Unmarshal(b []byte) error + type ResponseHeader struct + ClusterId uint64 + Error *Error + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) GetClusterId() uint64 + func (m *ResponseHeader) GetError() *Error + func (m *ResponseHeader) GetRevision() int64 + func (m *ResponseHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) Unmarshal(dAtA []byte) error + func (m *ResponseHeader) XXX_DiscardUnknown() + func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseHeader) XXX_Merge(src proto.Message) + func (m *ResponseHeader) XXX_Size() int + func (m *ResponseHeader) XXX_Unmarshal(b []byte) error + type UnimplementedMetaStorageServer struct + func (*UnimplementedMetaStorageServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedMetaStorageServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error) + func (*UnimplementedMetaStorageServer) Watch(req *WatchRequest, srv MetaStorage_WatchServer) error + type WatchRequest struct + Header *RequestHeader + Key []byte + PrevKv bool + RangeEnd []byte + StartRevision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (m *WatchRequest) GetHeader() *RequestHeader + func (m *WatchRequest) GetKey() []byte + func (m *WatchRequest) GetPrevKv() bool + func (m *WatchRequest) GetRangeEnd() []byte + func (m *WatchRequest) GetStartRevision() int64 + func (m *WatchRequest) Marshal() (dAtA []byte, err error) + func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WatchRequest) Reset() + func (m *WatchRequest) Size() (n int) + func (m *WatchRequest) String() string + func (m *WatchRequest) Unmarshal(dAtA []byte) error + func (m *WatchRequest) XXX_DiscardUnknown() + func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchRequest) XXX_Merge(src proto.Message) + func (m *WatchRequest) XXX_Size() int + func (m *WatchRequest) XXX_Unmarshal(b []byte) error + type WatchResponse struct + CompactRevision int64 + Events []*Event + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchResponse) Descriptor() ([]byte, []int) + func (*WatchResponse) ProtoMessage() + func (m *WatchResponse) GetCompactRevision() int64 + func (m *WatchResponse) GetEvents() []*Event + func (m *WatchResponse) GetHeader() *ResponseHeader + func (m *WatchResponse) Marshal() (dAtA []byte, err error) + func (m *WatchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WatchResponse) Reset() + func (m *WatchResponse) Size() (n int) + func (m *WatchResponse) String() string + func (m *WatchResponse) Unmarshal(dAtA []byte) error + func (m *WatchResponse) XXX_DiscardUnknown() + func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchResponse) XXX_Merge(src proto.Message) + func (m *WatchResponse) XXX_Size() int + func (m *WatchResponse) XXX_Unmarshal(b []byte) error