X-Git-Url: http://git.osdn.net/view?p=bytom%2Fvapor.git;a=blobdiff_plain;f=vendor%2Fgithub.com%2Fgo-kit%2Fkit%2Fsd%2Fendpointer_test.go;fp=vendor%2Fgithub.com%2Fgo-kit%2Fkit%2Fsd%2Fendpointer_test.go;h=0000000000000000000000000000000000000000;hp=671178f69d77233a2b7807645503a397a136723f;hb=f6ec2b987c394f065e527bcdf5942d1f9f0dad66;hpb=bcb18f4ce26ec40aefb2b84107274b6aa9efabfd

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
index 671178f6..00000000
--- 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
-}