rpcdb

Jul 20, 2025

Changes in this version

+ var ErrEnumToError = map[rpcdbpb.Error]error

+ var ErrorToErrEnum = map[error]rpcdbpb.Error

+ func ErrorToRPCError(err error) error

type DatabaseClient

+ func (db *DatabaseClient) HealthCheck(ctx context.Context) (interface{}, error)

type DatabaseServer

+ func (db *DatabaseServer) HealthCheck(ctx context.Context, _ *emptypb.Empty) (*rpcdbpb.HealthCheckResponse, error)

Apr 19, 2020

Changes in this version

+ type DatabaseClient struct

+ func NewClient(client rpcdbproto.DatabaseClient) *DatabaseClient

+ func (db *DatabaseClient) Close() error

+ func (db *DatabaseClient) Compact(start, limit []byte) error

+ func (db *DatabaseClient) Delete(key []byte) error

+ func (db *DatabaseClient) Get(key []byte) ([]byte, error)

+ func (db *DatabaseClient) Has(key []byte) (bool, error)

+ func (db *DatabaseClient) NewBatch() database.Batch

+ func (db *DatabaseClient) NewIterator() database.Iterator

+ func (db *DatabaseClient) NewIteratorWithPrefix(prefix []byte) database.Iterator

+ func (db *DatabaseClient) NewIteratorWithStart(start []byte) database.Iterator

+ func (db *DatabaseClient) NewIteratorWithStartAndPrefix(start, prefix []byte) database.Iterator

+ func (db *DatabaseClient) Put(key, value []byte) error

+ func (db *DatabaseClient) Stat(property string) (string, error)

+ type DatabaseServer struct

+ func NewServer(db database.Database) *DatabaseServer

+ func (db *DatabaseServer) Close(_ context.Context, _ *rpcdbproto.CloseRequest) (*rpcdbproto.CloseResponse, error)

+ func (db *DatabaseServer) Compact(_ context.Context, req *rpcdbproto.CompactRequest) (*rpcdbproto.CompactResponse, error)

+ func (db *DatabaseServer) Delete(_ context.Context, req *rpcdbproto.DeleteRequest) (*rpcdbproto.DeleteResponse, error)

+ func (db *DatabaseServer) Get(_ context.Context, req *rpcdbproto.GetRequest) (*rpcdbproto.GetResponse, error)

+ func (db *DatabaseServer) Has(_ context.Context, req *rpcdbproto.HasRequest) (*rpcdbproto.HasResponse, error)

+ func (db *DatabaseServer) IteratorError(_ context.Context, req *rpcdbproto.IteratorErrorRequest) (*rpcdbproto.IteratorErrorResponse, error)

+ func (db *DatabaseServer) IteratorNext(_ context.Context, req *rpcdbproto.IteratorNextRequest) (*rpcdbproto.IteratorNextResponse, error)

+ func (db *DatabaseServer) IteratorRelease(_ context.Context, req *rpcdbproto.IteratorReleaseRequest) (*rpcdbproto.IteratorReleaseResponse, error)

+ func (db *DatabaseServer) NewIteratorWithStartAndPrefix(_ context.Context, req *rpcdbproto.NewIteratorWithStartAndPrefixRequest) (*rpcdbproto.NewIteratorWithStartAndPrefixResponse, error)

+ func (db *DatabaseServer) Put(_ context.Context, req *rpcdbproto.PutRequest) (*rpcdbproto.PutResponse, error)

+ func (db *DatabaseServer) Stat(_ context.Context, req *rpcdbproto.StatRequest) (*rpcdbproto.StatResponse, error)

+ func (db *DatabaseServer) WriteBatch(_ context.Context, req *rpcdbproto.WriteBatchRequest) (*rpcdbproto.WriteBatchResponse, error)