rpcdb

package
v1.10.10 Latest Latest
Warning

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

Go to latest
Published: Jul 12, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Database_Has_FullMethodName                           = "/rpcdb.Database/Has"
	Database_Get_FullMethodName                           = "/rpcdb.Database/Get"
	Database_Put_FullMethodName                           = "/rpcdb.Database/Put"
	Database_Delete_FullMethodName                        = "/rpcdb.Database/Delete"
	Database_Compact_FullMethodName                       = "/rpcdb.Database/Compact"
	Database_Close_FullMethodName                         = "/rpcdb.Database/Close"
	Database_HealthCheck_FullMethodName                   = "/rpcdb.Database/HealthCheck"
	Database_WriteBatch_FullMethodName                    = "/rpcdb.Database/WriteBatch"
	Database_NewIteratorWithStartAndPrefix_FullMethodName = "/rpcdb.Database/NewIteratorWithStartAndPrefix"
	Database_IteratorNext_FullMethodName                  = "/rpcdb.Database/IteratorNext"
	Database_IteratorError_FullMethodName                 = "/rpcdb.Database/IteratorError"
	Database_IteratorRelease_FullMethodName               = "/rpcdb.Database/IteratorRelease"
)

Variables

View Source
var (
	Error_name = map[int32]string{
		0: "ERROR_UNSPECIFIED",
		1: "ERROR_CLOSED",
		2: "ERROR_NOT_FOUND",
	}
	Error_value = map[string]int32{
		"ERROR_UNSPECIFIED": 0,
		"ERROR_CLOSED":      1,
		"ERROR_NOT_FOUND":   2,
	}
)

Enum value maps for Error.

View Source
var Database_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpcdb.Database",
	HandlerType: (*DatabaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Has",
			Handler:    _Database_Has_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Database_Get_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _Database_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Database_Delete_Handler,
		},
		{
			MethodName: "Compact",
			Handler:    _Database_Compact_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Database_Close_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _Database_HealthCheck_Handler,
		},
		{
			MethodName: "WriteBatch",
			Handler:    _Database_WriteBatch_Handler,
		},
		{
			MethodName: "NewIteratorWithStartAndPrefix",
			Handler:    _Database_NewIteratorWithStartAndPrefix_Handler,
		},
		{
			MethodName: "IteratorNext",
			Handler:    _Database_IteratorNext_Handler,
		},
		{
			MethodName: "IteratorError",
			Handler:    _Database_IteratorError_Handler,
		},
		{
			MethodName: "IteratorRelease",
			Handler:    _Database_IteratorRelease_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpcdb/rpcdb.proto",
}

Database_ServiceDesc is the grpc.ServiceDesc for Database service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_rpcdb_rpcdb_proto protoreflect.FileDescriptor

Functions

func RegisterDatabaseServer

func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)

Types

type CloseRequest

type CloseRequest struct {
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect

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

func (*CloseRequest) Reset

func (x *CloseRequest) Reset()

func (*CloseRequest) String

func (x *CloseRequest) String() string

type CloseResponse

type CloseResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponse) Descriptor deprecated

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) GetErr

func (x *CloseResponse) GetErr() Error

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect

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

func (*CloseResponse) Reset

func (x *CloseResponse) Reset()

func (*CloseResponse) String

func (x *CloseResponse) String() string

type CompactRequest

type CompactRequest struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit []byte `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactRequest) Descriptor deprecated

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

Deprecated: Use CompactRequest.ProtoReflect.Descriptor instead.

func (*CompactRequest) GetLimit

func (x *CompactRequest) GetLimit() []byte

func (*CompactRequest) GetStart

func (x *CompactRequest) GetStart() []byte

func (*CompactRequest) ProtoMessage

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) ProtoReflect

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

func (*CompactRequest) Reset

func (x *CompactRequest) Reset()

func (*CompactRequest) String

func (x *CompactRequest) String() string

type CompactResponse

type CompactResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactResponse) Descriptor deprecated

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

Deprecated: Use CompactResponse.ProtoReflect.Descriptor instead.

func (*CompactResponse) GetErr

func (x *CompactResponse) GetErr() Error

func (*CompactResponse) ProtoMessage

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) ProtoReflect

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

func (*CompactResponse) Reset

func (x *CompactResponse) Reset()

func (*CompactResponse) String

func (x *CompactResponse) String() string

type DatabaseClient

DatabaseClient is the client API for Database service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatabaseClient

func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

type DatabaseServer

DatabaseServer is the server API for Database service. All implementations must embed UnimplementedDatabaseServer for forward compatibility

type DeleteRequest

type DeleteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey

func (x *DeleteRequest) GetKey() []byte

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type DeleteResponse

type DeleteResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetErr

func (x *DeleteResponse) GetErr() Error

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

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

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String

func (x *DeleteResponse) String() string

type Error

type Error int32
const (
	// ERROR_UNSPECIFIED is used to indicate that no error occurred.
	Error_ERROR_UNSPECIFIED Error = 0
	Error_ERROR_CLOSED      Error = 1
	Error_ERROR_NOT_FOUND   Error = 2
)

func (Error) Descriptor

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated

func (Error) EnumDescriptor() ([]byte, []int)

Deprecated: Use Error.Descriptor instead.

func (Error) Number

func (x Error) Number() protoreflect.EnumNumber

func (Error) String

func (x Error) String() string

func (Error) Type

func (Error) Type() protoreflect.EnumType

type GetRequest

type GetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey

func (x *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Err   Error  `protobuf:"varint,2,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetErr

func (x *GetResponse) GetErr() Error

func (*GetResponse) GetValue

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type HasRequest

type HasRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*HasRequest) Descriptor deprecated

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

Deprecated: Use HasRequest.ProtoReflect.Descriptor instead.

func (*HasRequest) GetKey

func (x *HasRequest) GetKey() []byte

func (*HasRequest) ProtoMessage

func (*HasRequest) ProtoMessage()

func (*HasRequest) ProtoReflect

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

func (*HasRequest) Reset

func (x *HasRequest) Reset()

func (*HasRequest) String

func (x *HasRequest) String() string

type HasResponse

type HasResponse struct {
	Has bool  `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
	Err Error `protobuf:"varint,2,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*HasResponse) Descriptor deprecated

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

Deprecated: Use HasResponse.ProtoReflect.Descriptor instead.

func (*HasResponse) GetErr

func (x *HasResponse) GetErr() Error

func (*HasResponse) GetHas

func (x *HasResponse) GetHas() bool

func (*HasResponse) ProtoMessage

func (*HasResponse) ProtoMessage()

func (*HasResponse) ProtoReflect

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

func (*HasResponse) Reset

func (x *HasResponse) Reset()

func (*HasResponse) String

func (x *HasResponse) String() string

type HealthCheckResponse

type HealthCheckResponse struct {
	Details []byte `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetDetails

func (x *HealthCheckResponse) GetDetails() []byte

func (*HealthCheckResponse) ProtoMessage

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect

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

func (*HealthCheckResponse) Reset

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String

func (x *HealthCheckResponse) String() string

type IteratorErrorRequest

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

func (*IteratorErrorRequest) Descriptor deprecated

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

Deprecated: Use IteratorErrorRequest.ProtoReflect.Descriptor instead.

func (*IteratorErrorRequest) GetId

func (x *IteratorErrorRequest) GetId() uint64

func (*IteratorErrorRequest) ProtoMessage

func (*IteratorErrorRequest) ProtoMessage()

func (*IteratorErrorRequest) ProtoReflect

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

func (*IteratorErrorRequest) Reset

func (x *IteratorErrorRequest) Reset()

func (*IteratorErrorRequest) String

func (x *IteratorErrorRequest) String() string

type IteratorErrorResponse

type IteratorErrorResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorErrorResponse) Descriptor deprecated

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

Deprecated: Use IteratorErrorResponse.ProtoReflect.Descriptor instead.

func (*IteratorErrorResponse) GetErr

func (x *IteratorErrorResponse) GetErr() Error

func (*IteratorErrorResponse) ProtoMessage

func (*IteratorErrorResponse) ProtoMessage()

func (*IteratorErrorResponse) ProtoReflect

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

func (*IteratorErrorResponse) Reset

func (x *IteratorErrorResponse) Reset()

func (*IteratorErrorResponse) String

func (x *IteratorErrorResponse) String() string

type IteratorNextRequest

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

func (*IteratorNextRequest) Descriptor deprecated

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

Deprecated: Use IteratorNextRequest.ProtoReflect.Descriptor instead.

func (*IteratorNextRequest) GetId

func (x *IteratorNextRequest) GetId() uint64

func (*IteratorNextRequest) ProtoMessage

func (*IteratorNextRequest) ProtoMessage()

func (*IteratorNextRequest) ProtoReflect

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

func (*IteratorNextRequest) Reset

func (x *IteratorNextRequest) Reset()

func (*IteratorNextRequest) String

func (x *IteratorNextRequest) String() string

type IteratorNextResponse

type IteratorNextResponse struct {
	Data []*PutRequest `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorNextResponse) Descriptor deprecated

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

Deprecated: Use IteratorNextResponse.ProtoReflect.Descriptor instead.

func (*IteratorNextResponse) GetData

func (x *IteratorNextResponse) GetData() []*PutRequest

func (*IteratorNextResponse) ProtoMessage

func (*IteratorNextResponse) ProtoMessage()

func (*IteratorNextResponse) ProtoReflect

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

func (*IteratorNextResponse) Reset

func (x *IteratorNextResponse) Reset()

func (*IteratorNextResponse) String

func (x *IteratorNextResponse) String() string

type IteratorReleaseRequest

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

func (*IteratorReleaseRequest) Descriptor deprecated

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

Deprecated: Use IteratorReleaseRequest.ProtoReflect.Descriptor instead.

func (*IteratorReleaseRequest) GetId

func (x *IteratorReleaseRequest) GetId() uint64

func (*IteratorReleaseRequest) ProtoMessage

func (*IteratorReleaseRequest) ProtoMessage()

func (*IteratorReleaseRequest) ProtoReflect

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

func (*IteratorReleaseRequest) Reset

func (x *IteratorReleaseRequest) Reset()

func (*IteratorReleaseRequest) String

func (x *IteratorReleaseRequest) String() string

type IteratorReleaseResponse

type IteratorReleaseResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorReleaseResponse) Descriptor deprecated

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

Deprecated: Use IteratorReleaseResponse.ProtoReflect.Descriptor instead.

func (*IteratorReleaseResponse) GetErr

func (x *IteratorReleaseResponse) GetErr() Error

func (*IteratorReleaseResponse) ProtoMessage

func (*IteratorReleaseResponse) ProtoMessage()

func (*IteratorReleaseResponse) ProtoReflect

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

func (*IteratorReleaseResponse) Reset

func (x *IteratorReleaseResponse) Reset()

func (*IteratorReleaseResponse) String

func (x *IteratorReleaseResponse) String() string

type NewIteratorRequest

type NewIteratorRequest struct {
	// contains filtered or unexported fields
}

func (*NewIteratorRequest) Descriptor deprecated

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

Deprecated: Use NewIteratorRequest.ProtoReflect.Descriptor instead.

func (*NewIteratorRequest) ProtoMessage

func (*NewIteratorRequest) ProtoMessage()

func (*NewIteratorRequest) ProtoReflect

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

func (*NewIteratorRequest) Reset

func (x *NewIteratorRequest) Reset()

func (*NewIteratorRequest) String

func (x *NewIteratorRequest) String() string

type NewIteratorWithStartAndPrefixRequest

type NewIteratorWithStartAndPrefixRequest struct {
	Start  []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Prefix []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*NewIteratorWithStartAndPrefixRequest) Descriptor deprecated

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

Deprecated: Use NewIteratorWithStartAndPrefixRequest.ProtoReflect.Descriptor instead.

func (*NewIteratorWithStartAndPrefixRequest) GetPrefix

func (x *NewIteratorWithStartAndPrefixRequest) GetPrefix() []byte

func (*NewIteratorWithStartAndPrefixRequest) GetStart

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage()

func (*NewIteratorWithStartAndPrefixRequest) ProtoReflect

func (*NewIteratorWithStartAndPrefixRequest) Reset

func (*NewIteratorWithStartAndPrefixRequest) String

type NewIteratorWithStartAndPrefixResponse

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

func (*NewIteratorWithStartAndPrefixResponse) Descriptor deprecated

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

Deprecated: Use NewIteratorWithStartAndPrefixResponse.ProtoReflect.Descriptor instead.

func (*NewIteratorWithStartAndPrefixResponse) GetId

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage()

func (*NewIteratorWithStartAndPrefixResponse) ProtoReflect

func (*NewIteratorWithStartAndPrefixResponse) Reset

func (*NewIteratorWithStartAndPrefixResponse) String

type PutRequest

type PutRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetValue

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect

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

func (*PutRequest) Reset

func (x *PutRequest) Reset()

func (*PutRequest) String

func (x *PutRequest) String() string

type PutResponse

type PutResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetErr

func (x *PutResponse) GetErr() Error

func (*PutResponse) ProtoMessage

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect

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

func (*PutResponse) Reset

func (x *PutResponse) Reset()

func (*PutResponse) String

func (x *PutResponse) String() string

type UnimplementedDatabaseServer

type UnimplementedDatabaseServer struct {
}

UnimplementedDatabaseServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServer) Close

func (UnimplementedDatabaseServer) Compact

func (UnimplementedDatabaseServer) Delete

func (UnimplementedDatabaseServer) Get

func (UnimplementedDatabaseServer) Has

func (UnimplementedDatabaseServer) HealthCheck

func (UnimplementedDatabaseServer) IteratorError

func (UnimplementedDatabaseServer) IteratorNext

func (UnimplementedDatabaseServer) IteratorRelease

func (UnimplementedDatabaseServer) Put

func (UnimplementedDatabaseServer) WriteBatch

type UnsafeDatabaseServer

type UnsafeDatabaseServer interface {
	// contains filtered or unexported methods
}

UnsafeDatabaseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabaseServer will result in compilation errors.

type WriteBatchRequest

type WriteBatchRequest struct {
	Puts    []*PutRequest    `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	Deletes []*DeleteRequest `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBatchRequest) Descriptor deprecated

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

Deprecated: Use WriteBatchRequest.ProtoReflect.Descriptor instead.

func (*WriteBatchRequest) GetDeletes

func (x *WriteBatchRequest) GetDeletes() []*DeleteRequest

func (*WriteBatchRequest) GetPuts

func (x *WriteBatchRequest) GetPuts() []*PutRequest

func (*WriteBatchRequest) ProtoMessage

func (*WriteBatchRequest) ProtoMessage()

func (*WriteBatchRequest) ProtoReflect

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

func (*WriteBatchRequest) Reset

func (x *WriteBatchRequest) Reset()

func (*WriteBatchRequest) String

func (x *WriteBatchRequest) String() string

type WriteBatchResponse

type WriteBatchResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBatchResponse) Descriptor deprecated

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

Deprecated: Use WriteBatchResponse.ProtoReflect.Descriptor instead.

func (*WriteBatchResponse) GetErr

func (x *WriteBatchResponse) GetErr() Error

func (*WriteBatchResponse) ProtoMessage

func (*WriteBatchResponse) ProtoMessage()

func (*WriteBatchResponse) ProtoReflect

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

func (*WriteBatchResponse) Reset

func (x *WriteBatchResponse) Reset()

func (*WriteBatchResponse) String

func (x *WriteBatchResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL