Playing around with badger subscription

dgraph-badger-subscription-poc.go

package main

import (
	"context"
	"fmt"
	"log"

	badger "github.com/dgraph-io/badger/v2"
	"github.com/dgraph-io/badger/v2/pb"
)

func main() {
	log.Println("starting")

	db, err := badger.Open(badger.DefaultOptions("../../dgraph-tutorial/p"))
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()
	// Your code here…

	ctx := context.Background()

	ch := make(chan struct{})

	handleSubscription := func(kvl *pb.KVList) error {
		panic("AAAAAAAHHH")
		for _, kv := range kvl.GetKv() {
			fmt.Println(string(kv.GetKey()), string(kv.GetValue()))
		}
		ch <- struct{}{}
		return nil
	}

	err = db.Subscribe(ctx, handleSubscription, []byte{})

	if err != nil {
		fmt.Println(err)
	}

	log.Println("opened?")
	<-ch
}