Versions in this module Expand all Collapse all v1 v1.8.4 Feb 22, 2022 v1.8.3 Feb 22, 2022 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)
Go to main page