[unitdb] add query, ingestion and pubsub plugins for other clients to interact with Unitdb using rpc/grpc/grpc-web generic plugins

Author: unit-adm

db_internal.go

@@ -164,10 +164,10 @@ func (db *DB) close() error {
 	return err
 }
 
-// loadTopicHash loads topic and offset from window file.
+// loadTopicHash loads topic and offset from window blocks on stored on disk.
 func (db *DB) loadTrie() error {
 	r := newWindowReader(db.fs)
-	err := r.foreachWindowBlock(func(startSeq, topicHash uint64, off int64) (bool, error) {
+	err := r.blockIterator(func(startSeq, topicHash uint64, off int64) (bool, error) {
 		e, err := db.internal.reader.readEntry(startSeq)
 		if err != nil {
 			return true, err

db_sync.go

@@ -214,7 +214,7 @@ func (db *_SyncHandle) Sync() error {
 	// defer profile.Start().Stop()
 	var err1 error
 	timeRelease := db.internal.timeWindow.release()
-	err := db.internal.mem.ForEachBlock(func(timeID int64, seqs []uint64) (bool, error) {
+	err := db.internal.mem.BlockIterator(func(timeID int64, seqs []uint64) (bool, error) {
 		winEntries := make(map[uint64]_WindowEntries)
 		sort.Slice(seqs[:], func(i, j int) bool {
 			return seqs[i] < seqs[j]

db_test.go

@@ -158,7 +158,7 @@ func TestBatch(t *testing.T) {
 			}
 		}
 		var v, vals [][]byte
-		v, err = db.Get(NewQuery(append(topic, []byte("?last=1h")...)).WithContract(contract))
+		v, err = db.Get(NewQuery(append(topic, []byte("?last=1h")...)).WithContract(contract).WithLimit(int(n)))
 		if err != nil {
 			t.Fatal(err)
 		}

examples/db/adapter.go

@@ -10,7 +10,7 @@ import (
 
 func main() {
 	// Opening a database.
-	db, err := memdb.Open(memdb.WithLogFilePath("unitdb"))
+	db, err := memdb.Open(memdb.WithLogFilePath("example"))
 	if err != nil {
 		log.Fatal(err)
 		return