modify ci

[bytom/vapor.git] / vendor / github.com / go-kit / kit / sd / endpointer_test.go

diff --git a/vendor/github.com/go-kit/kit/sd/endpointer_test.go b/vendor/github.com/go-kit/kit/sd/endpointer_test.go
deleted file mode 100644 (file)
index 671178f..0000000
--- a/vendor/github.com/go-kit/kit/sd/endpointer_test.go
+++ /dev/null
@@ -1,85 +0,0 @@
-package sd_test
-
-import (
-       "io"
-       "testing"
-       "time"
-
-       "github.com/go-kit/kit/endpoint"
-       "github.com/go-kit/kit/log"
-       "github.com/go-kit/kit/sd"
-       "github.com/go-kit/kit/sd/internal/instance"
-)
-
-func TestDefaultEndpointer(t *testing.T) {
-       var (
-               ca = make(closer)
-               cb = make(closer)
-               c  = map[string]io.Closer{"a": ca, "b": cb}
-               f  = func(instance string) (endpoint.Endpoint, io.Closer, error) {
-                       return endpoint.Nop, c[instance], nil
-               }
-               instancer = &mockInstancer{instance.NewCache()}
-       )
-       // set initial state
-       instancer.Update(sd.Event{Instances: []string{"a", "b"}})
-
-       endpointer := sd.NewEndpointer(instancer, f, log.NewNopLogger(), sd.InvalidateOnError(time.Minute))
-
-       var (
-               endpoints []endpoint.Endpoint
-               err       error
-       )
-       if !within(time.Second, func() bool {
-               endpoints, err = endpointer.Endpoints()
-               return err == nil && len(endpoints) == 2
-       }) {
-               t.Errorf("wanted 2 endpoints, got %d (%v)", len(endpoints), err)
-       }
-
-       instancer.Update(sd.Event{Instances: []string{}})
-
-       select {
-       case <-ca:
-               t.Logf("endpoint a closed, good")
-       case <-time.After(time.Millisecond):
-               t.Errorf("didn't close the deleted instance in time")
-       }
-
-       select {
-       case <-cb:
-               t.Logf("endpoint b closed, good")
-       case <-time.After(time.Millisecond):
-               t.Errorf("didn't close the deleted instance in time")
-       }
-
-       if endpoints, err := endpointer.Endpoints(); err != nil {
-               t.Errorf("unepected error %v", err)
-       } else if want, have := 0, len(endpoints); want != have {
-               t.Errorf("want %d, have %d", want, have)
-       }
-
-       endpointer.Close()
-
-       instancer.Update(sd.Event{Instances: []string{"a"}})
-       // TODO verify that on Close the endpointer fully disconnects from the instancer.
-       // Unfortunately, because we use instance.Cache, this test cannot be in the sd package,
-       // and therefore does not have access to the endpointer's private members.
-}
-
-type mockInstancer struct{ *instance.Cache }
-
-type closer chan struct{}
-
-func (c closer) Close() error { close(c); return nil }
-
-func within(d time.Duration, f func() bool) bool {
-       deadline := time.Now().Add(d)
-       for time.Now().Before(deadline) {
-               if f() {
-                       return true
-               }
-               time.Sleep(d / 10)
-       }
-       return false
-}