clientv3/integration/util.go
func mustWaitPinReady(t *testing.T, cli *clientv3.Client) {
	// TODO: decrease timeout after balancer rewrite!!!
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	_, err := cli.Get(ctx, "foo")
	cancel()
	if err != nil {
		t.Fatal(err)
	}
}
func mustWaitPinReady(t *testing.T, cli *clientv3.Client) {
	// TODO: decrease timeout after balancer rewrite!!!
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	_, err := cli.Get(ctx, "foo")
	cancel()
	if err != nil {
		t.Fatal(err)
	}
}
func mustWaitPinReady ( t * testing . T , cli * clientv3 . Client ) { // TODO: decrease timeout after balancer rewrite!!! ctx , cancel := context . WithTimeout ( context . Background ( ) , 10 * time . Second ) _ , err := cli . Get ( ctx , " " ) cancel ( ) if err != nil { t . Fatal ( err ) } }
// mustWaitPinReady waits up to 3-second until connection is up (pin endpoint).
// Fatal on time-out.
mustWaitPinReady waits up to 3 - second until connection is up ( pin endpoint ) . Fatal on time - out .