kvccpb

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 5, 2021 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_kvcc_proto protoreflect.FileDescriptor

Functions

func RegisterKVCCServer 

func RegisterKVCCServer(s *grpc.Server, srv KVCCServer)

Types

type KVCCClient 

type KVCCClient interface {
	Get(ctx context.Context, in *KVCCGetRequest, opts ...grpc.CallOption) (*KVCCGetResponse, error)
	Set(ctx context.Context, in *KVCCSetRequest, opts ...grpc.CallOption) (*KVCCSetResponse, error)
	UpdateMeta(ctx context.Context, in *KVCCUpdateMetaRequest, opts ...grpc.CallOption) (*KVCCUpdateMetaResponse, error)
	RollbackKey(ctx context.Context, in *KVCCRollbackKeyRequest, opts ...grpc.CallOption) (*KVCCRollbackKeyResponse, error)
	RemoveTxnRecord(ctx context.Context, in *KVCCRemoveTxnRecordRequest, opts ...grpc.CallOption) (*KVCCRemoveTxnRecordResponse, error)
}

KVCCClient is the client API for KVCC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKVCCClient 

func NewKVCCClient(cc grpc.ClientConnInterface) KVCCClient

type KVCCGetRequest 

type KVCCGetRequest struct {
	Key string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Opt *KVCCReadOption `protobuf:"bytes,2,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCGetRequest) Descriptor deprecated 

func (*KVCCGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use KVCCGetRequest.ProtoReflect.Descriptor instead.

func (*KVCCGetRequest) GetKey 

func (x *KVCCGetRequest) GetKey() string

func (*KVCCGetRequest) GetOpt 

func (x *KVCCGetRequest) GetOpt() *KVCCReadOption

func (*KVCCGetRequest) ProtoMessage 

func (*KVCCGetRequest) ProtoMessage()

func (*KVCCGetRequest) ProtoReflect 

func (x *KVCCGetRequest) ProtoReflect() protoreflect.Message

func (*KVCCGetRequest) Reset 

func (x *KVCCGetRequest) Reset()

func (*KVCCGetRequest) String 

func (x *KVCCGetRequest) String() string

type KVCCGetResponse 

type KVCCGetResponse struct {
	V   *commonpb.ValueCC `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"`
	Err *commonpb.Error   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCGetResponse) Descriptor deprecated 

func (*KVCCGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use KVCCGetResponse.ProtoReflect.Descriptor instead.

func (*KVCCGetResponse) GetErr 

func (x *KVCCGetResponse) GetErr() *commonpb.Error

func (*KVCCGetResponse) GetV 

func (x *KVCCGetResponse) GetV() *commonpb.ValueCC

func (*KVCCGetResponse) ProtoMessage 

func (*KVCCGetResponse) ProtoMessage()

func (*KVCCGetResponse) ProtoReflect 

func (x *KVCCGetResponse) ProtoReflect() protoreflect.Message

func (*KVCCGetResponse) Reset 

func (x *KVCCGetResponse) Reset()

func (*KVCCGetResponse) String 

func (x *KVCCGetResponse) String() string

type KVCCReadOption 

type KVCCReadOption struct {
	ReaderVersion             uint64 `protobuf:"varint,1,opt,name=reader_version,json=readerVersion,proto3" json:"reader_version,omitempty"`
	Flag                      uint32 `protobuf:"varint,2,opt,name=flag,proto3" json:"flag,omitempty"`
	ExactVersion              uint64 `protobuf:"varint,3,opt,name=exact_version,json=exactVersion,proto3" json:"exact_version,omitempty"`
	MinAllowedSnapshotVersion uint64 `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KVCCReadOption) Descriptor deprecated 

func (*KVCCReadOption) Descriptor() ([]byte, []int)

Deprecated: Use KVCCReadOption.ProtoReflect.Descriptor instead.

func (*KVCCReadOption) GetExactVersion 

func (x *KVCCReadOption) GetExactVersion() uint64

func (*KVCCReadOption) GetFlag 

func (x *KVCCReadOption) GetFlag() uint32

func (*KVCCReadOption) GetFlagSafe 

func (x *KVCCReadOption) GetFlagSafe() uint8

func (*KVCCReadOption) GetMinAllowedSnapshotVersion 

func (x *KVCCReadOption) GetMinAllowedSnapshotVersion() uint64

func (*KVCCReadOption) GetReaderVersion 

func (x *KVCCReadOption) GetReaderVersion() uint64

func (*KVCCReadOption) ProtoMessage 

func (*KVCCReadOption) ProtoMessage()

func (*KVCCReadOption) ProtoReflect 

func (x *KVCCReadOption) ProtoReflect() protoreflect.Message

func (*KVCCReadOption) Reset 

func (x *KVCCReadOption) Reset()

func (*KVCCReadOption) SetFlagSafe 

func (x *KVCCReadOption) SetFlagSafe(opt uint8) *KVCCReadOption

func (*KVCCReadOption) String 

func (x *KVCCReadOption) String() string

type KVCCRemoveTxnRecordOption 

type KVCCRemoveTxnRecordOption struct {
	Flag uint32 `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCRemoveTxnRecordOption) Descriptor deprecated 

func (*KVCCRemoveTxnRecordOption) Descriptor() ([]byte, []int)

Deprecated: Use KVCCRemoveTxnRecordOption.ProtoReflect.Descriptor instead.

func (*KVCCRemoveTxnRecordOption) GetFlag 

func (x *KVCCRemoveTxnRecordOption) GetFlag() uint32

func (*KVCCRemoveTxnRecordOption) ProtoMessage 

func (*KVCCRemoveTxnRecordOption) ProtoMessage()

func (*KVCCRemoveTxnRecordOption) ProtoReflect 

func (x *KVCCRemoveTxnRecordOption) ProtoReflect() protoreflect.Message

func (*KVCCRemoveTxnRecordOption) Reset 

func (x *KVCCRemoveTxnRecordOption) Reset()

func (*KVCCRemoveTxnRecordOption) String 

func (x *KVCCRemoveTxnRecordOption) String() string

type KVCCRemoveTxnRecordRequest 

type KVCCRemoveTxnRecordRequest struct {
	Version uint64                     `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Opt     *KVCCRemoveTxnRecordOption `protobuf:"bytes,2,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCRemoveTxnRecordRequest) Descriptor deprecated 

func (*KVCCRemoveTxnRecordRequest) Descriptor() ([]byte, []int)

Deprecated: Use KVCCRemoveTxnRecordRequest.ProtoReflect.Descriptor instead.

func (*KVCCRemoveTxnRecordRequest) GetOpt 

func (x *KVCCRemoveTxnRecordRequest) GetOpt() *KVCCRemoveTxnRecordOption

func (*KVCCRemoveTxnRecordRequest) GetVersion 

func (x *KVCCRemoveTxnRecordRequest) GetVersion() uint64

func (*KVCCRemoveTxnRecordRequest) ProtoMessage 

func (*KVCCRemoveTxnRecordRequest) ProtoMessage()

func (*KVCCRemoveTxnRecordRequest) ProtoReflect 

func (x *KVCCRemoveTxnRecordRequest) ProtoReflect() protoreflect.Message

func (*KVCCRemoveTxnRecordRequest) Reset 

func (x *KVCCRemoveTxnRecordRequest) Reset()

func (*KVCCRemoveTxnRecordRequest) String 

func (x *KVCCRemoveTxnRecordRequest) String() string

type KVCCRemoveTxnRecordResponse 

type KVCCRemoveTxnRecordResponse struct {
	Err *commonpb.Error `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCRemoveTxnRecordResponse) Descriptor deprecated 

func (*KVCCRemoveTxnRecordResponse) Descriptor() ([]byte, []int)

Deprecated: Use KVCCRemoveTxnRecordResponse.ProtoReflect.Descriptor instead.

func (*KVCCRemoveTxnRecordResponse) GetErr 

func (x *KVCCRemoveTxnRecordResponse) GetErr() *commonpb.Error

func (*KVCCRemoveTxnRecordResponse) ProtoMessage 

func (*KVCCRemoveTxnRecordResponse) ProtoMessage()

func (*KVCCRemoveTxnRecordResponse) ProtoReflect 

func (x *KVCCRemoveTxnRecordResponse) ProtoReflect() protoreflect.Message

func (*KVCCRemoveTxnRecordResponse) Reset 

func (x *KVCCRemoveTxnRecordResponse) Reset()

func (*KVCCRemoveTxnRecordResponse) String 

func (x *KVCCRemoveTxnRecordResponse) String() string

type KVCCRollbackKeyOption 

type KVCCRollbackKeyOption struct {
	Flag uint32 `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCRollbackKeyOption) Descriptor deprecated 

func (*KVCCRollbackKeyOption) Descriptor() ([]byte, []int)

Deprecated: Use KVCCRollbackKeyOption.ProtoReflect.Descriptor instead.

func (*KVCCRollbackKeyOption) GetFlag 

func (x *KVCCRollbackKeyOption) GetFlag() uint32

func (*KVCCRollbackKeyOption) ProtoMessage 

func (*KVCCRollbackKeyOption) ProtoMessage()

func (*KVCCRollbackKeyOption) ProtoReflect 

func (x *KVCCRollbackKeyOption) ProtoReflect() protoreflect.Message

func (*KVCCRollbackKeyOption) Reset 

func (x *KVCCRollbackKeyOption) Reset()

func (*KVCCRollbackKeyOption) String 

func (x *KVCCRollbackKeyOption) String() string

type KVCCRollbackKeyRequest 

type KVCCRollbackKeyRequest struct {
	Key     string                 `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Version uint64                 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Opt     *KVCCRollbackKeyOption `protobuf:"bytes,3,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCRollbackKeyRequest) Descriptor deprecated 

func (*KVCCRollbackKeyRequest) Descriptor() ([]byte, []int)

Deprecated: Use KVCCRollbackKeyRequest.ProtoReflect.Descriptor instead.

func (*KVCCRollbackKeyRequest) GetKey 

func (x *KVCCRollbackKeyRequest) GetKey() string

func (*KVCCRollbackKeyRequest) GetOpt 

func (x *KVCCRollbackKeyRequest) GetOpt() *KVCCRollbackKeyOption

func (*KVCCRollbackKeyRequest) GetVersion 

func (x *KVCCRollbackKeyRequest) GetVersion() uint64

func (*KVCCRollbackKeyRequest) ProtoMessage 

func (*KVCCRollbackKeyRequest) ProtoMessage()

func (*KVCCRollbackKeyRequest) ProtoReflect 

func (x *KVCCRollbackKeyRequest) ProtoReflect() protoreflect.Message

func (*KVCCRollbackKeyRequest) Reset 

func (x *KVCCRollbackKeyRequest) Reset()

func (*KVCCRollbackKeyRequest) String 

func (x *KVCCRollbackKeyRequest) String() string

type KVCCRollbackKeyResponse 

type KVCCRollbackKeyResponse struct {
	Err *commonpb.Error `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCRollbackKeyResponse) Descriptor deprecated 

func (*KVCCRollbackKeyResponse) Descriptor() ([]byte, []int)

Deprecated: Use KVCCRollbackKeyResponse.ProtoReflect.Descriptor instead.

func (*KVCCRollbackKeyResponse) GetErr 

func (x *KVCCRollbackKeyResponse) GetErr() *commonpb.Error

func (*KVCCRollbackKeyResponse) ProtoMessage 

func (*KVCCRollbackKeyResponse) ProtoMessage()

func (*KVCCRollbackKeyResponse) ProtoReflect 

func (x *KVCCRollbackKeyResponse) ProtoReflect() protoreflect.Message

func (*KVCCRollbackKeyResponse) Reset 

func (x *KVCCRollbackKeyResponse) Reset()

func (*KVCCRollbackKeyResponse) String 

func (x *KVCCRollbackKeyResponse) String() string

type KVCCServer 

type KVCCServer interface {
	Get(context.Context, *KVCCGetRequest) (*KVCCGetResponse, error)
	Set(context.Context, *KVCCSetRequest) (*KVCCSetResponse, error)
	UpdateMeta(context.Context, *KVCCUpdateMetaRequest) (*KVCCUpdateMetaResponse, error)
	RollbackKey(context.Context, *KVCCRollbackKeyRequest) (*KVCCRollbackKeyResponse, error)
	RemoveTxnRecord(context.Context, *KVCCRemoveTxnRecordRequest) (*KVCCRemoveTxnRecordResponse, error)
}

KVCCServer is the server API for KVCC service.

type KVCCSetRequest 

type KVCCSetRequest struct {
	Key   string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *commonpb.Value  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Opt   *KVCCWriteOption `protobuf:"bytes,3,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCSetRequest) Descriptor deprecated 

func (*KVCCSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use KVCCSetRequest.ProtoReflect.Descriptor instead.

func (*KVCCSetRequest) GetKey 

func (x *KVCCSetRequest) GetKey() string

func (*KVCCSetRequest) GetOpt 

func (x *KVCCSetRequest) GetOpt() *KVCCWriteOption

func (*KVCCSetRequest) GetValue 

func (x *KVCCSetRequest) GetValue() *commonpb.Value

func (*KVCCSetRequest) ProtoMessage 

func (*KVCCSetRequest) ProtoMessage()

func (*KVCCSetRequest) ProtoReflect 

func (x *KVCCSetRequest) ProtoReflect() protoreflect.Message

func (*KVCCSetRequest) Reset 

func (x *KVCCSetRequest) Reset()

func (*KVCCSetRequest) String 

func (x *KVCCSetRequest) String() string

func (*KVCCSetRequest) Validate 

func (x *KVCCSetRequest) Validate() error

type KVCCSetResponse 

type KVCCSetResponse struct {
	Err *commonpb.Error `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCSetResponse) Descriptor deprecated 

func (*KVCCSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use KVCCSetResponse.ProtoReflect.Descriptor instead.

func (*KVCCSetResponse) GetErr 

func (x *KVCCSetResponse) GetErr() *commonpb.Error

func (*KVCCSetResponse) ProtoMessage 

func (*KVCCSetResponse) ProtoMessage()

func (*KVCCSetResponse) ProtoReflect 

func (x *KVCCSetResponse) ProtoReflect() protoreflect.Message

func (*KVCCSetResponse) Reset 

func (x *KVCCSetResponse) Reset()

func (*KVCCSetResponse) String 

func (x *KVCCSetResponse) String() string

type KVCCUpdateMetaOption 

type KVCCUpdateMetaOption struct {
	Flag uint32 `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCUpdateMetaOption) Descriptor deprecated 

func (*KVCCUpdateMetaOption) Descriptor() ([]byte, []int)

Deprecated: Use KVCCUpdateMetaOption.ProtoReflect.Descriptor instead.

func (*KVCCUpdateMetaOption) GetFlag 

func (x *KVCCUpdateMetaOption) GetFlag() uint32

func (*KVCCUpdateMetaOption) ProtoMessage 

func (*KVCCUpdateMetaOption) ProtoMessage()

func (*KVCCUpdateMetaOption) ProtoReflect 

func (x *KVCCUpdateMetaOption) ProtoReflect() protoreflect.Message

func (*KVCCUpdateMetaOption) Reset 

func (x *KVCCUpdateMetaOption) Reset()

func (*KVCCUpdateMetaOption) String 

func (x *KVCCUpdateMetaOption) String() string

type KVCCUpdateMetaRequest 

type KVCCUpdateMetaRequest struct {
	Key     string                `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Version uint64                `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Opt     *KVCCUpdateMetaOption `protobuf:"bytes,3,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCUpdateMetaRequest) Descriptor deprecated 

func (*KVCCUpdateMetaRequest) Descriptor() ([]byte, []int)

Deprecated: Use KVCCUpdateMetaRequest.ProtoReflect.Descriptor instead.

func (*KVCCUpdateMetaRequest) GetKey 

func (x *KVCCUpdateMetaRequest) GetKey() string

func (*KVCCUpdateMetaRequest) GetOpt 

func (x *KVCCUpdateMetaRequest) GetOpt() *KVCCUpdateMetaOption

func (*KVCCUpdateMetaRequest) GetVersion 

func (x *KVCCUpdateMetaRequest) GetVersion() uint64

func (*KVCCUpdateMetaRequest) ProtoMessage 

func (*KVCCUpdateMetaRequest) ProtoMessage()

func (*KVCCUpdateMetaRequest) ProtoReflect 

func (x *KVCCUpdateMetaRequest) ProtoReflect() protoreflect.Message

func (*KVCCUpdateMetaRequest) Reset 

func (x *KVCCUpdateMetaRequest) Reset()

func (*KVCCUpdateMetaRequest) String 

func (x *KVCCUpdateMetaRequest) String() string

type KVCCUpdateMetaResponse 

type KVCCUpdateMetaResponse struct {
	Err *commonpb.Error `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCUpdateMetaResponse) Descriptor deprecated 

func (*KVCCUpdateMetaResponse) Descriptor() ([]byte, []int)

Deprecated: Use KVCCUpdateMetaResponse.ProtoReflect.Descriptor instead.

func (*KVCCUpdateMetaResponse) GetErr 

func (x *KVCCUpdateMetaResponse) GetErr() *commonpb.Error

func (*KVCCUpdateMetaResponse) ProtoMessage 

func (*KVCCUpdateMetaResponse) ProtoMessage()

func (*KVCCUpdateMetaResponse) ProtoReflect 

func (x *KVCCUpdateMetaResponse) ProtoReflect() protoreflect.Message

func (*KVCCUpdateMetaResponse) Reset 

func (x *KVCCUpdateMetaResponse) Reset()

func (*KVCCUpdateMetaResponse) String 

func (x *KVCCUpdateMetaResponse) String() string

type KVCCWriteOption 

type KVCCWriteOption struct {
	Flag uint32 `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

func (*KVCCWriteOption) Descriptor deprecated 

func (*KVCCWriteOption) Descriptor() ([]byte, []int)

Deprecated: Use KVCCWriteOption.ProtoReflect.Descriptor instead.

func (*KVCCWriteOption) GetFlag 

func (x *KVCCWriteOption) GetFlag() uint32

func (*KVCCWriteOption) GetFlagSafe 

func (x *KVCCWriteOption) GetFlagSafe() uint8

func (*KVCCWriteOption) ProtoMessage 

func (*KVCCWriteOption) ProtoMessage()

func (*KVCCWriteOption) ProtoReflect 

func (x *KVCCWriteOption) ProtoReflect() protoreflect.Message

func (*KVCCWriteOption) Reset 

func (x *KVCCWriteOption) Reset()

func (*KVCCWriteOption) SetFlagSafe 

func (x *KVCCWriteOption) SetFlagSafe(opt uint8) *KVCCWriteOption

func (*KVCCWriteOption) String 

func (x *KVCCWriteOption) String() string

func (*KVCCWriteOption) Validate 

func (x *KVCCWriteOption) Validate() error

type UnimplementedKVCCServer 

type UnimplementedKVCCServer struct {
}

UnimplementedKVCCServer can be embedded to have forward compatible implementations.

func (*UnimplementedKVCCServer) Get 

func (*UnimplementedKVCCServer) Get(context.Context, *KVCCGetRequest) (*KVCCGetResponse, error)

func (*UnimplementedKVCCServer) RemoveTxnRecord 

func (*UnimplementedKVCCServer) RemoveTxnRecord(context.Context, *KVCCRemoveTxnRecordRequest) (*KVCCRemoveTxnRecordResponse, error)

func (*UnimplementedKVCCServer) RollbackKey 

func (*UnimplementedKVCCServer) RollbackKey(context.Context, *KVCCRollbackKeyRequest) (*KVCCRollbackKeyResponse, error)

func (*UnimplementedKVCCServer) Set 

func (*UnimplementedKVCCServer) Set(context.Context, *KVCCSetRequest) (*KVCCSetResponse, error)

func (*UnimplementedKVCCServer) UpdateMeta 

func (*UnimplementedKVCCServer) UpdateMeta(context.Context, *KVCCUpdateMetaRequest) (*KVCCUpdateMetaResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.