Versions in this module Expand all Collapse all v1 v1.8.14 Dec 22, 2022 v1.8.13 Dec 22, 2022 v1.8.12 Dec 21, 2022 v1.8.11 Dec 21, 2022 v1.8.10 Dec 14, 2022 v1.8.9 Dec 13, 2022 v1.8.8 Dec 13, 2022 v1.8.7 Dec 13, 2022 v1.8.6 Dec 6, 2022 v0 v0.1.0 Dec 4, 2022 Changes in this version + var Database_ServiceDesc = grpc.ServiceDesc + 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 uint32 + func (*CloseResponse) Descriptor() ([]byte, []int) + func (*CloseResponse) ProtoMessage() + func (x *CloseResponse) GetErr() uint32 + 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 uint32 + func (*CompactResponse) Descriptor() ([]byte, []int) + func (*CompactResponse) ProtoMessage() + func (x *CompactResponse) GetErr() uint32 + 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 uint32 + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (x *DeleteResponse) GetErr() uint32 + func (x *DeleteResponse) ProtoReflect() protoreflect.Message + func (x *DeleteResponse) Reset() + func (x *DeleteResponse) 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 uint32 + Value []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (x *GetResponse) GetErr() uint32 + 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 uint32 + Has bool + func (*HasResponse) Descriptor() ([]byte, []int) + func (*HasResponse) ProtoMessage() + func (x *HasResponse) GetErr() uint32 + 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 uint32 + func (*IteratorErrorResponse) Descriptor() ([]byte, []int) + func (*IteratorErrorResponse) ProtoMessage() + func (x *IteratorErrorResponse) GetErr() uint32 + 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 uint32 + func (*IteratorReleaseResponse) Descriptor() ([]byte, []int) + func (*IteratorReleaseResponse) ProtoMessage() + func (x *IteratorReleaseResponse) GetErr() uint32 + 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 uint32 + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (x *PutResponse) GetErr() uint32 + 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 + Continues bool + Deletes []*DeleteRequest + Id int64 + Puts []*PutRequest + func (*WriteBatchRequest) Descriptor() ([]byte, []int) + func (*WriteBatchRequest) ProtoMessage() + func (x *WriteBatchRequest) GetContinues() bool + func (x *WriteBatchRequest) GetDeletes() []*DeleteRequest + func (x *WriteBatchRequest) GetId() int64 + func (x *WriteBatchRequest) GetPuts() []*PutRequest + func (x *WriteBatchRequest) ProtoReflect() protoreflect.Message + func (x *WriteBatchRequest) Reset() + func (x *WriteBatchRequest) String() string + type WriteBatchResponse struct + Err uint32 + func (*WriteBatchResponse) Descriptor() ([]byte, []int) + func (*WriteBatchResponse) ProtoMessage() + func (x *WriteBatchResponse) GetErr() uint32 + func (x *WriteBatchResponse) ProtoReflect() protoreflect.Message + func (x *WriteBatchResponse) Reset() + func (x *WriteBatchResponse) String() string
Go to main page