Versions in this module Expand all Collapse all v1 v1.0.0 Apr 5, 2021 Changes in this version + var File_kvcc_proto protoreflect.FileDescriptor + func RegisterKVCCServer(s *grpc.Server, srv KVCCServer) + type KVCCClient interface + Get func(ctx context.Context, in *KVCCGetRequest, opts ...grpc.CallOption) (*KVCCGetResponse, error) + RemoveTxnRecord func(ctx context.Context, in *KVCCRemoveTxnRecordRequest, opts ...grpc.CallOption) (*KVCCRemoveTxnRecordResponse, error) + RollbackKey func(ctx context.Context, in *KVCCRollbackKeyRequest, opts ...grpc.CallOption) (*KVCCRollbackKeyResponse, error) + Set func(ctx context.Context, in *KVCCSetRequest, opts ...grpc.CallOption) (*KVCCSetResponse, error) + UpdateMeta func(ctx context.Context, in *KVCCUpdateMetaRequest, opts ...grpc.CallOption) (*KVCCUpdateMetaResponse, error) + func NewKVCCClient(cc grpc.ClientConnInterface) KVCCClient + type KVCCGetRequest struct + Key string + Opt *KVCCReadOption + func (*KVCCGetRequest) Descriptor() ([]byte, []int) + func (*KVCCGetRequest) ProtoMessage() + func (x *KVCCGetRequest) GetKey() string + func (x *KVCCGetRequest) GetOpt() *KVCCReadOption + func (x *KVCCGetRequest) ProtoReflect() protoreflect.Message + func (x *KVCCGetRequest) Reset() + func (x *KVCCGetRequest) String() string + type KVCCGetResponse struct + Err *commonpb.Error + V *commonpb.ValueCC + func (*KVCCGetResponse) Descriptor() ([]byte, []int) + func (*KVCCGetResponse) ProtoMessage() + func (x *KVCCGetResponse) GetErr() *commonpb.Error + func (x *KVCCGetResponse) GetV() *commonpb.ValueCC + func (x *KVCCGetResponse) ProtoReflect() protoreflect.Message + func (x *KVCCGetResponse) Reset() + func (x *KVCCGetResponse) String() string + type KVCCReadOption struct + ExactVersion uint64 + Flag uint32 + MinAllowedSnapshotVersion uint64 + ReaderVersion uint64 + func (*KVCCReadOption) Descriptor() ([]byte, []int) + func (*KVCCReadOption) ProtoMessage() + func (x *KVCCReadOption) GetExactVersion() uint64 + func (x *KVCCReadOption) GetFlag() uint32 + func (x *KVCCReadOption) GetFlagSafe() uint8 + func (x *KVCCReadOption) GetMinAllowedSnapshotVersion() uint64 + func (x *KVCCReadOption) GetReaderVersion() uint64 + func (x *KVCCReadOption) ProtoReflect() protoreflect.Message + func (x *KVCCReadOption) Reset() + func (x *KVCCReadOption) SetFlagSafe(opt uint8) *KVCCReadOption + func (x *KVCCReadOption) String() string + type KVCCRemoveTxnRecordOption struct + Flag uint32 + func (*KVCCRemoveTxnRecordOption) Descriptor() ([]byte, []int) + func (*KVCCRemoveTxnRecordOption) ProtoMessage() + func (x *KVCCRemoveTxnRecordOption) GetFlag() uint32 + func (x *KVCCRemoveTxnRecordOption) ProtoReflect() protoreflect.Message + func (x *KVCCRemoveTxnRecordOption) Reset() + func (x *KVCCRemoveTxnRecordOption) String() string + type KVCCRemoveTxnRecordRequest struct + Opt *KVCCRemoveTxnRecordOption + Version uint64 + func (*KVCCRemoveTxnRecordRequest) Descriptor() ([]byte, []int) + func (*KVCCRemoveTxnRecordRequest) ProtoMessage() + func (x *KVCCRemoveTxnRecordRequest) GetOpt() *KVCCRemoveTxnRecordOption + func (x *KVCCRemoveTxnRecordRequest) GetVersion() uint64 + func (x *KVCCRemoveTxnRecordRequest) ProtoReflect() protoreflect.Message + func (x *KVCCRemoveTxnRecordRequest) Reset() + func (x *KVCCRemoveTxnRecordRequest) String() string + type KVCCRemoveTxnRecordResponse struct + Err *commonpb.Error + func (*KVCCRemoveTxnRecordResponse) Descriptor() ([]byte, []int) + func (*KVCCRemoveTxnRecordResponse) ProtoMessage() + func (x *KVCCRemoveTxnRecordResponse) GetErr() *commonpb.Error + func (x *KVCCRemoveTxnRecordResponse) ProtoReflect() protoreflect.Message + func (x *KVCCRemoveTxnRecordResponse) Reset() + func (x *KVCCRemoveTxnRecordResponse) String() string + type KVCCRollbackKeyOption struct + Flag uint32 + func (*KVCCRollbackKeyOption) Descriptor() ([]byte, []int) + func (*KVCCRollbackKeyOption) ProtoMessage() + func (x *KVCCRollbackKeyOption) GetFlag() uint32 + func (x *KVCCRollbackKeyOption) ProtoReflect() protoreflect.Message + func (x *KVCCRollbackKeyOption) Reset() + func (x *KVCCRollbackKeyOption) String() string + type KVCCRollbackKeyRequest struct + Key string + Opt *KVCCRollbackKeyOption + Version uint64 + func (*KVCCRollbackKeyRequest) Descriptor() ([]byte, []int) + func (*KVCCRollbackKeyRequest) ProtoMessage() + func (x *KVCCRollbackKeyRequest) GetKey() string + func (x *KVCCRollbackKeyRequest) GetOpt() *KVCCRollbackKeyOption + func (x *KVCCRollbackKeyRequest) GetVersion() uint64 + func (x *KVCCRollbackKeyRequest) ProtoReflect() protoreflect.Message + func (x *KVCCRollbackKeyRequest) Reset() + func (x *KVCCRollbackKeyRequest) String() string + type KVCCRollbackKeyResponse struct + Err *commonpb.Error + func (*KVCCRollbackKeyResponse) Descriptor() ([]byte, []int) + func (*KVCCRollbackKeyResponse) ProtoMessage() + func (x *KVCCRollbackKeyResponse) GetErr() *commonpb.Error + func (x *KVCCRollbackKeyResponse) ProtoReflect() protoreflect.Message + func (x *KVCCRollbackKeyResponse) Reset() + func (x *KVCCRollbackKeyResponse) String() string + type KVCCServer interface + Get func(context.Context, *KVCCGetRequest) (*KVCCGetResponse, error) + RemoveTxnRecord func(context.Context, *KVCCRemoveTxnRecordRequest) (*KVCCRemoveTxnRecordResponse, error) + RollbackKey func(context.Context, *KVCCRollbackKeyRequest) (*KVCCRollbackKeyResponse, error) + Set func(context.Context, *KVCCSetRequest) (*KVCCSetResponse, error) + UpdateMeta func(context.Context, *KVCCUpdateMetaRequest) (*KVCCUpdateMetaResponse, error) + type KVCCSetRequest struct + Key string + Opt *KVCCWriteOption + Value *commonpb.Value + func (*KVCCSetRequest) Descriptor() ([]byte, []int) + func (*KVCCSetRequest) ProtoMessage() + func (x *KVCCSetRequest) GetKey() string + func (x *KVCCSetRequest) GetOpt() *KVCCWriteOption + func (x *KVCCSetRequest) GetValue() *commonpb.Value + func (x *KVCCSetRequest) ProtoReflect() protoreflect.Message + func (x *KVCCSetRequest) Reset() + func (x *KVCCSetRequest) String() string + func (x *KVCCSetRequest) Validate() error + type KVCCSetResponse struct + Err *commonpb.Error + func (*KVCCSetResponse) Descriptor() ([]byte, []int) + func (*KVCCSetResponse) ProtoMessage() + func (x *KVCCSetResponse) GetErr() *commonpb.Error + func (x *KVCCSetResponse) ProtoReflect() protoreflect.Message + func (x *KVCCSetResponse) Reset() + func (x *KVCCSetResponse) String() string + type KVCCUpdateMetaOption struct + Flag uint32 + func (*KVCCUpdateMetaOption) Descriptor() ([]byte, []int) + func (*KVCCUpdateMetaOption) ProtoMessage() + func (x *KVCCUpdateMetaOption) GetFlag() uint32 + func (x *KVCCUpdateMetaOption) ProtoReflect() protoreflect.Message + func (x *KVCCUpdateMetaOption) Reset() + func (x *KVCCUpdateMetaOption) String() string + type KVCCUpdateMetaRequest struct + Key string + Opt *KVCCUpdateMetaOption + Version uint64 + func (*KVCCUpdateMetaRequest) Descriptor() ([]byte, []int) + func (*KVCCUpdateMetaRequest) ProtoMessage() + func (x *KVCCUpdateMetaRequest) GetKey() string + func (x *KVCCUpdateMetaRequest) GetOpt() *KVCCUpdateMetaOption + func (x *KVCCUpdateMetaRequest) GetVersion() uint64 + func (x *KVCCUpdateMetaRequest) ProtoReflect() protoreflect.Message + func (x *KVCCUpdateMetaRequest) Reset() + func (x *KVCCUpdateMetaRequest) String() string + type KVCCUpdateMetaResponse struct + Err *commonpb.Error + func (*KVCCUpdateMetaResponse) Descriptor() ([]byte, []int) + func (*KVCCUpdateMetaResponse) ProtoMessage() + func (x *KVCCUpdateMetaResponse) GetErr() *commonpb.Error + func (x *KVCCUpdateMetaResponse) ProtoReflect() protoreflect.Message + func (x *KVCCUpdateMetaResponse) Reset() + func (x *KVCCUpdateMetaResponse) String() string + type KVCCWriteOption struct + Flag uint32 + func (*KVCCWriteOption) Descriptor() ([]byte, []int) + func (*KVCCWriteOption) ProtoMessage() + func (x *KVCCWriteOption) GetFlag() uint32 + func (x *KVCCWriteOption) GetFlagSafe() uint8 + func (x *KVCCWriteOption) ProtoReflect() protoreflect.Message + func (x *KVCCWriteOption) Reset() + func (x *KVCCWriteOption) SetFlagSafe(opt uint8) *KVCCWriteOption + func (x *KVCCWriteOption) String() string + func (x *KVCCWriteOption) Validate() error + type UnimplementedKVCCServer struct + func (*UnimplementedKVCCServer) Get(context.Context, *KVCCGetRequest) (*KVCCGetResponse, error) + func (*UnimplementedKVCCServer) RemoveTxnRecord(context.Context, *KVCCRemoveTxnRecordRequest) (*KVCCRemoveTxnRecordResponse, error) + func (*UnimplementedKVCCServer) RollbackKey(context.Context, *KVCCRollbackKeyRequest) (*KVCCRollbackKeyResponse, error) + func (*UnimplementedKVCCServer) Set(context.Context, *KVCCSetRequest) (*KVCCSetResponse, error) + func (*UnimplementedKVCCServer) UpdateMeta(context.Context, *KVCCUpdateMetaRequest) (*KVCCUpdateMetaResponse, error)
Go to main page