rpcdb

package
v0.0.5 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 

type DatabaseClient interface {
	Has(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	WriteBatch(ctx context.Context, in *WriteBatchRequest, opts ...grpc.CallOption) (*WriteBatchResponse, error)
	NewIteratorWithStartAndPrefix(ctx context.Context, in *NewIteratorWithStartAndPrefixRequest, opts ...grpc.CallOption) (*NewIteratorWithStartAndPrefixResponse, error)
	IteratorNext(ctx context.Context, in *IteratorNextRequest, opts ...grpc.CallOption) (*IteratorNextResponse, error)
	IteratorError(ctx context.Context, in *IteratorErrorRequest, opts ...grpc.CallOption) (*IteratorErrorResponse, error)
	IteratorRelease(ctx context.Context, in *IteratorReleaseRequest, opts ...grpc.CallOption) (*IteratorReleaseResponse, error)
}

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 

type DatabaseServer interface {
	Has(context.Context, *HasRequest) (*HasResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Compact(context.Context, *CompactRequest) (*CompactResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)
	WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error)
	NewIteratorWithStartAndPrefix(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error)
	IteratorNext(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error)
	IteratorError(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error)
	IteratorRelease(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error)
	// contains filtered or unexported methods
}

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 (x *NewIteratorWithStartAndPrefixRequest) GetStart() []byte

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage 

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage()

func (*NewIteratorWithStartAndPrefixRequest) ProtoReflect 

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

func (*NewIteratorWithStartAndPrefixRequest) Reset 

func (x *NewIteratorWithStartAndPrefixRequest) Reset()

func (*NewIteratorWithStartAndPrefixRequest) String 

func (x *NewIteratorWithStartAndPrefixRequest) String() 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 (x *NewIteratorWithStartAndPrefixResponse) GetId() uint64

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage 

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage()

func (*NewIteratorWithStartAndPrefixResponse) ProtoReflect 

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

func (*NewIteratorWithStartAndPrefixResponse) Reset 

func (x *NewIteratorWithStartAndPrefixResponse) Reset()

func (*NewIteratorWithStartAndPrefixResponse) String 

func (x *NewIteratorWithStartAndPrefixResponse) String() 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) Close(context.Context, *CloseRequest) (*CloseResponse, error)

func (UnimplementedDatabaseServer) Compact 

func (UnimplementedDatabaseServer) Compact(context.Context, *CompactRequest) (*CompactResponse, error)

func (UnimplementedDatabaseServer) Delete 

func (UnimplementedDatabaseServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedDatabaseServer) Get 

func (UnimplementedDatabaseServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedDatabaseServer) Has 

func (UnimplementedDatabaseServer) Has(context.Context, *HasRequest) (*HasResponse, error)

func (UnimplementedDatabaseServer) HealthCheck 

func (UnimplementedDatabaseServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)

func (UnimplementedDatabaseServer) IteratorError 

func (UnimplementedDatabaseServer) IteratorError(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error)

func (UnimplementedDatabaseServer) IteratorNext 

func (UnimplementedDatabaseServer) IteratorNext(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error)

func (UnimplementedDatabaseServer) IteratorRelease 

func (UnimplementedDatabaseServer) IteratorRelease(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error)

func (UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix 

func (UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error)

func (UnimplementedDatabaseServer) Put 

func (UnimplementedDatabaseServer) Put(context.Context, *PutRequest) (*PutResponse, error)

func (UnimplementedDatabaseServer) WriteBatch 

func (UnimplementedDatabaseServer) WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error)

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

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.