123 lines
2 KiB
Go
123 lines
2 KiB
Go
package watch
|
|
|
|
import (
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/armon/consul-api"
|
|
)
|
|
|
|
var consulAddr string
|
|
|
|
func init() {
|
|
consulAddr = os.Getenv("CONSUL_ADDR")
|
|
}
|
|
|
|
func TestKeyWatch(t *testing.T) {
|
|
if consulAddr == "" {
|
|
t.Skip()
|
|
}
|
|
plan := mustParse(t, "type:key key:foo/bar/baz")
|
|
invoke := 0
|
|
plan.Handler = func(idx uint64, raw interface{}) {
|
|
if invoke == 0 {
|
|
if raw == nil {
|
|
return
|
|
}
|
|
v, ok := raw.(*consulapi.KVPair)
|
|
if !ok || v == nil || string(v.Value) != "test" {
|
|
t.Fatalf("Bad: %#v", raw)
|
|
}
|
|
invoke++
|
|
}
|
|
}
|
|
|
|
go func() {
|
|
defer plan.Stop()
|
|
time.Sleep(20 * time.Millisecond)
|
|
|
|
kv := plan.client.KV()
|
|
pair := &consulapi.KVPair{
|
|
Key: "foo/bar/baz",
|
|
Value: []byte("test"),
|
|
}
|
|
_, err := kv.Put(pair, nil)
|
|
if err != nil {
|
|
t.Fatalf("err: %v", err)
|
|
}
|
|
|
|
// Wait for the query to run
|
|
time.Sleep(20 * time.Millisecond)
|
|
plan.Stop()
|
|
|
|
// Delete the key
|
|
_, err = kv.Delete("foo/bar/baz", nil)
|
|
if err != nil {
|
|
t.Fatalf("err: %v", err)
|
|
}
|
|
}()
|
|
|
|
err := plan.Run(consulAddr)
|
|
if err != nil {
|
|
t.Fatalf("err: %v", err)
|
|
}
|
|
|
|
if invoke == 0 {
|
|
t.Fatalf("bad: %v", invoke)
|
|
}
|
|
}
|
|
|
|
func TestKeyPrefixWatch(t *testing.T) {
|
|
if consulAddr == "" {
|
|
t.Skip()
|
|
}
|
|
plan := mustParse(t, "type:keyprefix prefix:foo/")
|
|
invoke := 0
|
|
plan.Handler = func(idx uint64, raw interface{}) {
|
|
if invoke == 0 {
|
|
if raw == nil {
|
|
return
|
|
}
|
|
v, ok := raw.(consulapi.KVPairs)
|
|
if !ok || v == nil || string(v[0].Key) != "foo/bar" {
|
|
t.Fatalf("Bad: %#v", raw)
|
|
}
|
|
invoke++
|
|
}
|
|
}
|
|
|
|
go func() {
|
|
defer plan.Stop()
|
|
time.Sleep(20 * time.Millisecond)
|
|
|
|
kv := plan.client.KV()
|
|
pair := &consulapi.KVPair{
|
|
Key: "foo/bar",
|
|
}
|
|
_, err := kv.Put(pair, nil)
|
|
if err != nil {
|
|
t.Fatalf("err: %v", err)
|
|
}
|
|
|
|
// Wait for the query to run
|
|
time.Sleep(20 * time.Millisecond)
|
|
plan.Stop()
|
|
|
|
// Delete the key
|
|
_, err = kv.Delete("foo/bar", nil)
|
|
if err != nil {
|
|
t.Fatalf("err: %v", err)
|
|
}
|
|
}()
|
|
|
|
err := plan.Run(consulAddr)
|
|
if err != nil {
|
|
t.Fatalf("err: %v", err)
|
|
}
|
|
|
|
if invoke == 0 {
|
|
t.Fatalf("bad: %v", invoke)
|
|
}
|
|
}
|