Versions in this module Expand all Collapse all v1 v1.1.1 Dec 18, 2024 Changes in this version + type DatabaseClient struct + func NewClient(client rpcdbpb.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) HealthCheck(ctx context.Context) (interface{}, 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 + type DatabaseServer struct + func NewServer(db database.Database) *DatabaseServer + func (db *DatabaseServer) Close(context.Context, *rpcdbpb.CloseRequest) (*rpcdbpb.CloseResponse, error) + func (db *DatabaseServer) Compact(_ context.Context, req *rpcdbpb.CompactRequest) (*rpcdbpb.CompactResponse, error) + func (db *DatabaseServer) Delete(_ context.Context, req *rpcdbpb.DeleteRequest) (*rpcdbpb.DeleteResponse, error) + func (db *DatabaseServer) Get(_ context.Context, req *rpcdbpb.GetRequest) (*rpcdbpb.GetResponse, error) + func (db *DatabaseServer) Has(_ context.Context, req *rpcdbpb.HasRequest) (*rpcdbpb.HasResponse, error) + func (db *DatabaseServer) HealthCheck(ctx context.Context, _ *emptypb.Empty) (*rpcdbpb.HealthCheckResponse, error) + func (db *DatabaseServer) IteratorError(_ context.Context, req *rpcdbpb.IteratorErrorRequest) (*rpcdbpb.IteratorErrorResponse, error) + func (db *DatabaseServer) IteratorNext(_ context.Context, req *rpcdbpb.IteratorNextRequest) (*rpcdbpb.IteratorNextResponse, error) + func (db *DatabaseServer) IteratorRelease(_ context.Context, req *rpcdbpb.IteratorReleaseRequest) (*rpcdbpb.IteratorReleaseResponse, error) + func (db *DatabaseServer) NewIteratorWithStartAndPrefix(_ context.Context, req *rpcdbpb.NewIteratorWithStartAndPrefixRequest) (*rpcdbpb.NewIteratorWithStartAndPrefixResponse, error) + func (db *DatabaseServer) Put(_ context.Context, req *rpcdbpb.PutRequest) (*rpcdbpb.PutResponse, error) + func (db *DatabaseServer) WriteBatch(_ context.Context, req *rpcdbpb.WriteBatchRequest) (*rpcdbpb.WriteBatchResponse, error)
Go to main page