kvpb

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: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_sp_kv_proto protoreflect.FileDescriptor

Functions

func RegisterKVServer 

func RegisterKVServer(s *grpc.Server, srv KVServer)

Types

type KVClient 

type KVClient interface {
	Get(ctx context.Context, in *KVGetRequest, opts ...grpc.CallOption) (*KVGetResponse, error)
	Set(ctx context.Context, in *KVSetRequest, opts ...grpc.CallOption) (*KVSetResponse, error)
	UpdateMeta(ctx context.Context, in *KVUpdateMetaRequest, opts ...grpc.CallOption) (*KVUpdateMetaResponse, error)
	RollbackKey(ctx context.Context, in *KVRollbackKeyRequest, opts ...grpc.CallOption) (*KVRollbackKeyResponse, error)
	RemoveTxnRecord(ctx context.Context, in *KVRemoveTxnRecordRequest, opts ...grpc.CallOption) (*KVRemoveTxnRecordResponse, error)
}

KVClient is the client API for KV service.

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

func NewKVClient 

func NewKVClient(cc grpc.ClientConnInterface) KVClient

type KVGetRequest 

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

func (*KVGetRequest) Descriptor deprecated 

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

Deprecated: Use KVGetRequest.ProtoReflect.Descriptor instead.

func (*KVGetRequest) GetKey 

func (x *KVGetRequest) GetKey() string

func (*KVGetRequest) GetOpt 

func (x *KVGetRequest) GetOpt() *KVReadOption

func (*KVGetRequest) ProtoMessage 

func (*KVGetRequest) ProtoMessage()

func (*KVGetRequest) ProtoReflect 

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

func (*KVGetRequest) Reset 

func (x *KVGetRequest) Reset()

func (*KVGetRequest) String 

func (x *KVGetRequest) String() string

type KVGetResponse 

type KVGetResponse struct {
	V   *commonpb.Value `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 (*KVGetResponse) Descriptor deprecated 

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

Deprecated: Use KVGetResponse.ProtoReflect.Descriptor instead.

func (*KVGetResponse) GetErr 

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

func (*KVGetResponse) GetV 

func (x *KVGetResponse) GetV() *commonpb.Value

func (*KVGetResponse) ProtoMessage 

func (*KVGetResponse) ProtoMessage()

func (*KVGetResponse) ProtoReflect 

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

func (*KVGetResponse) Reset 

func (x *KVGetResponse) Reset()

func (*KVGetResponse) String 

func (x *KVGetResponse) String() string

type KVReadOption 

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

func (*KVReadOption) Descriptor deprecated 

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

Deprecated: Use KVReadOption.ProtoReflect.Descriptor instead.

func (*KVReadOption) GetFlag 

func (x *KVReadOption) GetFlag() uint32

func (*KVReadOption) GetFlagSafe 

func (x *KVReadOption) GetFlagSafe() uint8

func (*KVReadOption) GetVersion 

func (x *KVReadOption) GetVersion() uint64

func (*KVReadOption) ProtoMessage 

func (*KVReadOption) ProtoMessage()

func (*KVReadOption) ProtoReflect 

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

func (*KVReadOption) Reset 

func (x *KVReadOption) Reset()

func (*KVReadOption) SetFlagSafe 

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

func (*KVReadOption) String 

func (x *KVReadOption) String() string

type KVRemoveTxnRecordRequest 

type KVRemoveTxnRecordRequest struct {
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*KVRemoveTxnRecordRequest) Descriptor deprecated 

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

Deprecated: Use KVRemoveTxnRecordRequest.ProtoReflect.Descriptor instead.

func (*KVRemoveTxnRecordRequest) GetVersion 

func (x *KVRemoveTxnRecordRequest) GetVersion() uint64

func (*KVRemoveTxnRecordRequest) ProtoMessage 

func (*KVRemoveTxnRecordRequest) ProtoMessage()

func (*KVRemoveTxnRecordRequest) ProtoReflect 

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

func (*KVRemoveTxnRecordRequest) Reset 

func (x *KVRemoveTxnRecordRequest) Reset()

func (*KVRemoveTxnRecordRequest) String 

func (x *KVRemoveTxnRecordRequest) String() string

type KVRemoveTxnRecordResponse 

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

func (*KVRemoveTxnRecordResponse) Descriptor deprecated 

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

Deprecated: Use KVRemoveTxnRecordResponse.ProtoReflect.Descriptor instead.

func (*KVRemoveTxnRecordResponse) GetErr 

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

func (*KVRemoveTxnRecordResponse) ProtoMessage 

func (*KVRemoveTxnRecordResponse) ProtoMessage()

func (*KVRemoveTxnRecordResponse) ProtoReflect 

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

func (*KVRemoveTxnRecordResponse) Reset 

func (x *KVRemoveTxnRecordResponse) Reset()

func (*KVRemoveTxnRecordResponse) String 

func (x *KVRemoveTxnRecordResponse) String() string

type KVRollbackKeyRequest 

type KVRollbackKeyRequest 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"`
	// contains filtered or unexported fields
}

func (*KVRollbackKeyRequest) Descriptor deprecated 

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

Deprecated: Use KVRollbackKeyRequest.ProtoReflect.Descriptor instead.

func (*KVRollbackKeyRequest) GetKey 

func (x *KVRollbackKeyRequest) GetKey() string

func (*KVRollbackKeyRequest) GetVersion 

func (x *KVRollbackKeyRequest) GetVersion() uint64

func (*KVRollbackKeyRequest) ProtoMessage 

func (*KVRollbackKeyRequest) ProtoMessage()

func (*KVRollbackKeyRequest) ProtoReflect 

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

func (*KVRollbackKeyRequest) Reset 

func (x *KVRollbackKeyRequest) Reset()

func (*KVRollbackKeyRequest) String 

func (x *KVRollbackKeyRequest) String() string

type KVRollbackKeyResponse 

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

func (*KVRollbackKeyResponse) Descriptor deprecated 

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

Deprecated: Use KVRollbackKeyResponse.ProtoReflect.Descriptor instead.

func (*KVRollbackKeyResponse) GetErr 

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

func (*KVRollbackKeyResponse) ProtoMessage 

func (*KVRollbackKeyResponse) ProtoMessage()

func (*KVRollbackKeyResponse) ProtoReflect 

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

func (*KVRollbackKeyResponse) Reset 

func (x *KVRollbackKeyResponse) Reset()

func (*KVRollbackKeyResponse) String 

func (x *KVRollbackKeyResponse) String() string

type KVServer 

type KVServer interface {
	Get(context.Context, *KVGetRequest) (*KVGetResponse, error)
	Set(context.Context, *KVSetRequest) (*KVSetResponse, error)
	UpdateMeta(context.Context, *KVUpdateMetaRequest) (*KVUpdateMetaResponse, error)
	RollbackKey(context.Context, *KVRollbackKeyRequest) (*KVRollbackKeyResponse, error)
	RemoveTxnRecord(context.Context, *KVRemoveTxnRecordRequest) (*KVRemoveTxnRecordResponse, error)
}

KVServer is the server API for KV service.

type KVSetRequest 

type KVSetRequest 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   *KVWriteOption  `protobuf:"bytes,3,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVSetRequest) Descriptor deprecated 

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

Deprecated: Use KVSetRequest.ProtoReflect.Descriptor instead.

func (*KVSetRequest) GetKey 

func (x *KVSetRequest) GetKey() string

func (*KVSetRequest) GetOpt 

func (x *KVSetRequest) GetOpt() *KVWriteOption

func (*KVSetRequest) GetValue 

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

func (*KVSetRequest) ProtoMessage 

func (*KVSetRequest) ProtoMessage()

func (*KVSetRequest) ProtoReflect 

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

func (*KVSetRequest) Reset 

func (x *KVSetRequest) Reset()

func (*KVSetRequest) String 

func (x *KVSetRequest) String() string

func (*KVSetRequest) Validate 

func (x *KVSetRequest) Validate() error

type KVSetResponse 

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

func (*KVSetResponse) Descriptor deprecated 

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

Deprecated: Use KVSetResponse.ProtoReflect.Descriptor instead.

func (*KVSetResponse) GetErr 

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

func (*KVSetResponse) ProtoMessage 

func (*KVSetResponse) ProtoMessage()

func (*KVSetResponse) ProtoReflect 

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

func (*KVSetResponse) Reset 

func (x *KVSetResponse) Reset()

func (*KVSetResponse) String 

func (x *KVSetResponse) String() string

type KVUpdateMetaOption 

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

func (*KVUpdateMetaOption) Descriptor deprecated 

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

Deprecated: Use KVUpdateMetaOption.ProtoReflect.Descriptor instead.

func (*KVUpdateMetaOption) GetFlag 

func (x *KVUpdateMetaOption) GetFlag() uint32

func (*KVUpdateMetaOption) ProtoMessage 

func (*KVUpdateMetaOption) ProtoMessage()

func (*KVUpdateMetaOption) ProtoReflect 

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

func (*KVUpdateMetaOption) Reset 

func (x *KVUpdateMetaOption) Reset()

func (*KVUpdateMetaOption) String 

func (x *KVUpdateMetaOption) String() string

type KVUpdateMetaRequest 

type KVUpdateMetaRequest 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     *KVUpdateMetaOption `protobuf:"bytes,3,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*KVUpdateMetaRequest) Descriptor deprecated 

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

Deprecated: Use KVUpdateMetaRequest.ProtoReflect.Descriptor instead.

func (*KVUpdateMetaRequest) GetKey 

func (x *KVUpdateMetaRequest) GetKey() string

func (*KVUpdateMetaRequest) GetOpt 

func (x *KVUpdateMetaRequest) GetOpt() *KVUpdateMetaOption

func (*KVUpdateMetaRequest) GetVersion 

func (x *KVUpdateMetaRequest) GetVersion() uint64

func (*KVUpdateMetaRequest) ProtoMessage 

func (*KVUpdateMetaRequest) ProtoMessage()

func (*KVUpdateMetaRequest) ProtoReflect 

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

func (*KVUpdateMetaRequest) Reset 

func (x *KVUpdateMetaRequest) Reset()

func (*KVUpdateMetaRequest) String 

func (x *KVUpdateMetaRequest) String() string

type KVUpdateMetaResponse 

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

func (*KVUpdateMetaResponse) Descriptor deprecated 

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

Deprecated: Use KVUpdateMetaResponse.ProtoReflect.Descriptor instead.

func (*KVUpdateMetaResponse) GetErr 

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

func (*KVUpdateMetaResponse) ProtoMessage 

func (*KVUpdateMetaResponse) ProtoMessage()

func (*KVUpdateMetaResponse) ProtoReflect 

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

func (*KVUpdateMetaResponse) Reset 

func (x *KVUpdateMetaResponse) Reset()

func (*KVUpdateMetaResponse) String 

func (x *KVUpdateMetaResponse) String() string

type KVWriteOption 

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

func (*KVWriteOption) Descriptor deprecated 

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

Deprecated: Use KVWriteOption.ProtoReflect.Descriptor instead.

func (*KVWriteOption) GetFlag 

func (x *KVWriteOption) GetFlag() uint32

func (*KVWriteOption) GetFlagSafe 

func (x *KVWriteOption) GetFlagSafe() uint8

func (*KVWriteOption) ProtoMessage 

func (*KVWriteOption) ProtoMessage()

func (*KVWriteOption) ProtoReflect 

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

func (*KVWriteOption) Reset 

func (x *KVWriteOption) Reset()

func (*KVWriteOption) SetFlagSafe 

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

func (*KVWriteOption) String 

func (x *KVWriteOption) String() string

func (*KVWriteOption) Validate 

func (x *KVWriteOption) Validate() error

type UnimplementedKVServer 

type UnimplementedKVServer struct {
}

UnimplementedKVServer can be embedded to have forward compatible implementations.

func (*UnimplementedKVServer) Get 

func (*UnimplementedKVServer) Get(context.Context, *KVGetRequest) (*KVGetResponse, error)

func (*UnimplementedKVServer) RemoveTxnRecord 

func (*UnimplementedKVServer) RemoveTxnRecord(context.Context, *KVRemoveTxnRecordRequest) (*KVRemoveTxnRecordResponse, error)

func (*UnimplementedKVServer) RollbackKey 

func (*UnimplementedKVServer) RollbackKey(context.Context, *KVRollbackKeyRequest) (*KVRollbackKeyResponse, error)

func (*UnimplementedKVServer) Set 

func (*UnimplementedKVServer) Set(context.Context, *KVSetRequest) (*KVSetResponse, error)

func (*UnimplementedKVServer) UpdateMeta 

func (*UnimplementedKVServer) UpdateMeta(context.Context, *KVUpdateMetaRequest) (*KVUpdateMetaResponse, 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.