Versions in this module Expand all Collapse all v1 v1.12.2 Mar 3, 2025 Changes in this version + const Database_Close_FullMethodName + const Database_Compact_FullMethodName + const Database_Delete_FullMethodName + const Database_Get_FullMethodName + const Database_Has_FullMethodName + const Database_HealthCheck_FullMethodName + const Database_IteratorError_FullMethodName + const Database_IteratorNext_FullMethodName + const Database_IteratorRelease_FullMethodName + const Database_NewIteratorWithStartAndPrefix_FullMethodName + const Database_Put_FullMethodName + const Database_WriteBatch_FullMethodName + var Database_ServiceDesc = grpc.ServiceDesc + var Error_name = map[int32]string + var Error_value = map[string]int32 + var File_rpcdb_rpcdb_proto protoreflect.FileDescriptor + func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer) + type CloseRequest struct + func (*CloseRequest) Descriptor() ([]byte, []int) + func (*CloseRequest) ProtoMessage() + func (x *CloseRequest) ProtoReflect() protoreflect.Message + func (x *CloseRequest) Reset() + func (x *CloseRequest) String() string + type CloseResponse struct + Err Error + func (*CloseResponse) Descriptor() ([]byte, []int) + func (*CloseResponse) ProtoMessage() + func (x *CloseResponse) GetErr() Error + func (x *CloseResponse) ProtoReflect() protoreflect.Message + func (x *CloseResponse) Reset() + func (x *CloseResponse) String() string + type CompactRequest struct + Limit []byte + Start []byte + func (*CompactRequest) Descriptor() ([]byte, []int) + func (*CompactRequest) ProtoMessage() + func (x *CompactRequest) GetLimit() []byte + func (x *CompactRequest) GetStart() []byte + func (x *CompactRequest) ProtoReflect() protoreflect.Message + func (x *CompactRequest) Reset() + func (x *CompactRequest) String() string + type CompactResponse struct + Err Error + func (*CompactResponse) Descriptor() ([]byte, []int) + func (*CompactResponse) ProtoMessage() + func (x *CompactResponse) GetErr() Error + func (x *CompactResponse) ProtoReflect() protoreflect.Message + func (x *CompactResponse) Reset() + func (x *CompactResponse) String() string + type DatabaseClient interface + Close func(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) + Compact func(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Has func(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasResponse, error) + HealthCheck func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error) + IteratorError func(ctx context.Context, in *IteratorErrorRequest, opts ...grpc.CallOption) (*IteratorErrorResponse, error) + IteratorNext func(ctx context.Context, in *IteratorNextRequest, opts ...grpc.CallOption) (*IteratorNextResponse, error) + IteratorRelease func(ctx context.Context, in *IteratorReleaseRequest, opts ...grpc.CallOption) (*IteratorReleaseResponse, error) + NewIteratorWithStartAndPrefix func(ctx context.Context, in *NewIteratorWithStartAndPrefixRequest, ...) (*NewIteratorWithStartAndPrefixResponse, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) + WriteBatch func(ctx context.Context, in *WriteBatchRequest, opts ...grpc.CallOption) (*WriteBatchResponse, error) + func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient + type DatabaseServer interface + Close func(context.Context, *CloseRequest) (*CloseResponse, error) + Compact func(context.Context, *CompactRequest) (*CompactResponse, error) + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + Has func(context.Context, *HasRequest) (*HasResponse, error) + HealthCheck func(context.Context, *emptypb.Empty) (*HealthCheckResponse, error) + IteratorError func(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error) + IteratorNext func(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error) + IteratorRelease func(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error) + NewIteratorWithStartAndPrefix func(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error) + Put func(context.Context, *PutRequest) (*PutResponse, error) + WriteBatch func(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error) + type DeleteRequest struct + Key []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (x *DeleteRequest) GetKey() []byte + func (x *DeleteRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRequest) Reset() + func (x *DeleteRequest) String() string + type DeleteResponse struct + Err Error + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (x *DeleteResponse) GetErr() Error + func (x *DeleteResponse) ProtoReflect() protoreflect.Message + func (x *DeleteResponse) Reset() + func (x *DeleteResponse) String() string + type Error int32 + const Error_ERROR_CLOSED + const Error_ERROR_NOT_FOUND + const Error_ERROR_UNSPECIFIED + func (Error) Descriptor() protoreflect.EnumDescriptor + func (Error) EnumDescriptor() ([]byte, []int) + func (Error) Type() protoreflect.EnumType + func (x Error) Enum() *Error + func (x Error) Number() protoreflect.EnumNumber + func (x Error) String() string + type GetRequest struct + Key []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetKey() []byte + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetResponse struct + Err Error + Value []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetErr() Error + func (x *GetResponse) GetValue() []byte + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type HasRequest struct + Key []byte + func (*HasRequest) Descriptor() ([]byte, []int) + func (*HasRequest) ProtoMessage() + func (x *HasRequest) GetKey() []byte + func (x *HasRequest) ProtoReflect() protoreflect.Message + func (x *HasRequest) Reset() + func (x *HasRequest) String() string + type HasResponse struct + Err Error + Has bool + func (*HasResponse) Descriptor() ([]byte, []int) + func (*HasResponse) ProtoMessage() + func (x *HasResponse) GetErr() Error + func (x *HasResponse) GetHas() bool + func (x *HasResponse) ProtoReflect() protoreflect.Message + func (x *HasResponse) Reset() + func (x *HasResponse) String() string + type HealthCheckResponse struct + Details []byte + func (*HealthCheckResponse) Descriptor() ([]byte, []int) + func (*HealthCheckResponse) ProtoMessage() + func (x *HealthCheckResponse) GetDetails() []byte + func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message + func (x *HealthCheckResponse) Reset() + func (x *HealthCheckResponse) String() string + type IteratorErrorRequest struct + Id uint64 + func (*IteratorErrorRequest) Descriptor() ([]byte, []int) + func (*IteratorErrorRequest) ProtoMessage() + func (x *IteratorErrorRequest) GetId() uint64 + func (x *IteratorErrorRequest) ProtoReflect() protoreflect.Message + func (x *IteratorErrorRequest) Reset() + func (x *IteratorErrorRequest) String() string + type IteratorErrorResponse struct + Err Error + func (*IteratorErrorResponse) Descriptor() ([]byte, []int) + func (*IteratorErrorResponse) ProtoMessage() + func (x *IteratorErrorResponse) GetErr() Error + func (x *IteratorErrorResponse) ProtoReflect() protoreflect.Message + func (x *IteratorErrorResponse) Reset() + func (x *IteratorErrorResponse) String() string + type IteratorNextRequest struct + Id uint64 + func (*IteratorNextRequest) Descriptor() ([]byte, []int) + func (*IteratorNextRequest) ProtoMessage() + func (x *IteratorNextRequest) GetId() uint64 + func (x *IteratorNextRequest) ProtoReflect() protoreflect.Message + func (x *IteratorNextRequest) Reset() + func (x *IteratorNextRequest) String() string + type IteratorNextResponse struct + Data []*PutRequest + func (*IteratorNextResponse) Descriptor() ([]byte, []int) + func (*IteratorNextResponse) ProtoMessage() + func (x *IteratorNextResponse) GetData() []*PutRequest + func (x *IteratorNextResponse) ProtoReflect() protoreflect.Message + func (x *IteratorNextResponse) Reset() + func (x *IteratorNextResponse) String() string + type IteratorReleaseRequest struct + Id uint64 + func (*IteratorReleaseRequest) Descriptor() ([]byte, []int) + func (*IteratorReleaseRequest) ProtoMessage() + func (x *IteratorReleaseRequest) GetId() uint64 + func (x *IteratorReleaseRequest) ProtoReflect() protoreflect.Message + func (x *IteratorReleaseRequest) Reset() + func (x *IteratorReleaseRequest) String() string + type IteratorReleaseResponse struct + Err Error + func (*IteratorReleaseResponse) Descriptor() ([]byte, []int) + func (*IteratorReleaseResponse) ProtoMessage() + func (x *IteratorReleaseResponse) GetErr() Error + func (x *IteratorReleaseResponse) ProtoReflect() protoreflect.Message + func (x *IteratorReleaseResponse) Reset() + func (x *IteratorReleaseResponse) String() string + type NewIteratorRequest struct + func (*NewIteratorRequest) Descriptor() ([]byte, []int) + func (*NewIteratorRequest) ProtoMessage() + func (x *NewIteratorRequest) ProtoReflect() protoreflect.Message + func (x *NewIteratorRequest) Reset() + func (x *NewIteratorRequest) String() string + type NewIteratorWithStartAndPrefixRequest struct + Prefix []byte + Start []byte + func (*NewIteratorWithStartAndPrefixRequest) Descriptor() ([]byte, []int) + func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage() + func (x *NewIteratorWithStartAndPrefixRequest) GetPrefix() []byte + func (x *NewIteratorWithStartAndPrefixRequest) GetStart() []byte + func (x *NewIteratorWithStartAndPrefixRequest) ProtoReflect() protoreflect.Message + func (x *NewIteratorWithStartAndPrefixRequest) Reset() + func (x *NewIteratorWithStartAndPrefixRequest) String() string + type NewIteratorWithStartAndPrefixResponse struct + Id uint64 + func (*NewIteratorWithStartAndPrefixResponse) Descriptor() ([]byte, []int) + func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage() + func (x *NewIteratorWithStartAndPrefixResponse) GetId() uint64 + func (x *NewIteratorWithStartAndPrefixResponse) ProtoReflect() protoreflect.Message + func (x *NewIteratorWithStartAndPrefixResponse) Reset() + func (x *NewIteratorWithStartAndPrefixResponse) String() string + type PutRequest struct + Key []byte + Value []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (x *PutRequest) GetKey() []byte + func (x *PutRequest) GetValue() []byte + func (x *PutRequest) ProtoReflect() protoreflect.Message + func (x *PutRequest) Reset() + func (x *PutRequest) String() string + type PutResponse struct + Err Error + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (x *PutResponse) GetErr() Error + func (x *PutResponse) ProtoReflect() protoreflect.Message + func (x *PutResponse) Reset() + func (x *PutResponse) String() string + type UnimplementedDatabaseServer struct + func (UnimplementedDatabaseServer) Close(context.Context, *CloseRequest) (*CloseResponse, error) + func (UnimplementedDatabaseServer) Compact(context.Context, *CompactRequest) (*CompactResponse, error) + func (UnimplementedDatabaseServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) + func (UnimplementedDatabaseServer) Get(context.Context, *GetRequest) (*GetResponse, error) + func (UnimplementedDatabaseServer) Has(context.Context, *HasRequest) (*HasResponse, error) + func (UnimplementedDatabaseServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error) + func (UnimplementedDatabaseServer) IteratorError(context.Context, *IteratorErrorRequest) (*IteratorErrorResponse, error) + func (UnimplementedDatabaseServer) IteratorNext(context.Context, *IteratorNextRequest) (*IteratorNextResponse, error) + func (UnimplementedDatabaseServer) IteratorRelease(context.Context, *IteratorReleaseRequest) (*IteratorReleaseResponse, error) + func (UnimplementedDatabaseServer) NewIteratorWithStartAndPrefix(context.Context, *NewIteratorWithStartAndPrefixRequest) (*NewIteratorWithStartAndPrefixResponse, error) + func (UnimplementedDatabaseServer) Put(context.Context, *PutRequest) (*PutResponse, error) + func (UnimplementedDatabaseServer) WriteBatch(context.Context, *WriteBatchRequest) (*WriteBatchResponse, error) + type UnsafeDatabaseServer interface + type WriteBatchRequest struct + Deletes []*DeleteRequest + Puts []*PutRequest + func (*WriteBatchRequest) Descriptor() ([]byte, []int) + func (*WriteBatchRequest) ProtoMessage() + func (x *WriteBatchRequest) GetDeletes() []*DeleteRequest + func (x *WriteBatchRequest) GetPuts() []*PutRequest + func (x *WriteBatchRequest) ProtoReflect() protoreflect.Message + func (x *WriteBatchRequest) Reset() + func (x *WriteBatchRequest) String() string + type WriteBatchResponse struct + Err Error + func (*WriteBatchResponse) Descriptor() ([]byte, []int) + func (*WriteBatchResponse) ProtoMessage() + func (x *WriteBatchResponse) GetErr() Error + func (x *WriteBatchResponse) ProtoReflect() protoreflect.Message + func (x *WriteBatchResponse) Reset() + func (x *WriteBatchResponse) String() string
Go to main page