tiwatch

tiwatch

Watch API at scale, using TiDB as backend

Usage

package main

import (
	"flag"
	"math/rand"
	"time"

	"github.com/c4pt0r/log"
	"github.com/c4pt0r/tiwatch"
)

var (
	watchOnly = flag.Bool("watch-only", false, "watch only")
)

func main() {
	flag.Parse()
	dsn := "root:@tcp(localhost:4000)/test"
	w := tiwatch.New(dsn, "default")
	err := w.Init()
	if err != nil {
		panic(err)
	}

	ch := w.Watch("hello")

	if !*watchOnly {
		go func() {
			for {
				log.I("SEND")
				w.Set("hello", time.Now().String())
				time.Sleep(time.Second)

				if rand.Intn(2) == 0 {
					log.I("DEL")
					w.Delete("hello")
				}
			}
		}()
	}
	for {
		select {
		case m := <-ch:
			log.Infof("RECV: %s", m)
		}
	}
}