Versions in this module Expand all Collapse all v1 v1.0.0 Aug 4, 2023 Changes in this version + const MaxChannelSize + func NewClient(addr string) (pb.RemoteClient, error) + type Reader struct + func NewReader(config *utils.Config, dbPool *db.DBPool) (reader *Reader, err error) + func (r *Reader) Batch(ctx context.Context, req *pb.BatchRequest) (reply *pb.BatchReply, err error) + func (r *Reader) Close(ctx context.Context, req *pb.CloseRequest) (reply *pb.CloseReply, err error) + func (r *Reader) Compact(ctx context.Context, req *pb.CompactRequest) (reply *pb.CompactReply, err error) + func (r *Reader) Del(ctx context.Context, req *pb.DelRequest) (reply *pb.DelReply, err error) + func (r *Reader) Get(ctx context.Context, req *pb.GetRequest) (reply *pb.GetReply, err error) + func (r *Reader) Has(ctx context.Context, req *pb.HasRequest) (reply *pb.HasReply, err error) + func (r *Reader) Iter(req *pb.IterRequest, client pb.Remote_IterServer) (err error) + func (r *Reader) Open(ctx context.Context, req *pb.OpenRequest) (reply *pb.OpenReply, err error) + func (r *Reader) Put(ctx context.Context, req *pb.PutRequest) (reply *pb.PutReply, err error) + func (r *Reader) Snapshot(client pb.Remote_SnapshotServer) error + func (r *Reader) Start() (err error) + func (r *Reader) Stat(ctx context.Context, req *pb.StatRequest) (reply *pb.StatReply, err error) + func (r *Reader) Stats(ctx context.Context, req *pb.StatsRequest) (reply *pb.StatsReply, err error) + func (r *Reader) Stop() + func (r *Reader) Sync(req *pb.SyncRequest, client pb.Remote_SyncServer) error + type Remote struct + func OpenRemoteDB(addr string, dbType, path string, IsMetaDB bool) (db *Remote, err error) + func (r *Remote) Close() (err error) + func (r *Remote) Compact(start, limit []byte) (err error) + func (r *Remote) Delete(key []byte) (err error) + func (r *Remote) Get(key []byte) (val []byte, err error) + func (r *Remote) Has(key []byte) (bool, error) + func (r *Remote) NewBatch() db.Batch + func (r *Remote) NewBatchWithSize(size int) db.Batch + func (r *Remote) NewIterator(prefix []byte, start []byte) (iter db.Iterator) + func (r *Remote) NewIteratorWithRange(start, limit []byte) (iter db.Iterator, err error) + func (r *Remote) NewSnapshot() (snapshot db.Snapshot, err error) + func (r *Remote) Put(key []byte, value []byte) (err error) + func (r *Remote) Stat(property string) (stat string, err error) + func (r *Remote) Stats() (stats map[string]string, err error) + type RemoteBatch struct + func (r *RemoteBatch) Delete(key []byte) error + func (r *RemoteBatch) Dump() []byte + func (r *RemoteBatch) Load(data []byte) error + func (r *RemoteBatch) Put(key []byte, value []byte) error + func (r *RemoteBatch) Replay(w db.KeyValueWriter) error + func (r *RemoteBatch) Reset() + func (r *RemoteBatch) ValueSize() int + func (r *RemoteBatch) Write() error + type RemoteIterator struct + func (r *RemoteIterator) Error() error + func (r *RemoteIterator) Key() []byte + func (r *RemoteIterator) Next() bool + func (r *RemoteIterator) Release() + func (r *RemoteIterator) Value() []byte + type RemoteSnapshot struct + func (r *RemoteSnapshot) Get(key []byte) (val []byte, err error) + func (r *RemoteSnapshot) Has(key []byte) (has bool, err error) + func (r *RemoteSnapshot) Release() + type SyncClient struct + func NewSyncClient(client pb.RemoteClient) *SyncClient + func (r *SyncClient) Cancel() + func (r *SyncClient) SyncInit() error + func (r *SyncClient) SyncNext() (*pb.Block, error)