Method TestResolverReportError

resolver_balancer_ext_test.go:140–168

Tests the case where the resolver reports an error to the channel before reporting an update. Verifies that the channel eventually moves to TransientFailure and subsequent RPCs returns the error reported by the resolver to the user.

(t *testing.T)

// TransientFailure and subsequent RPCs returns the error reported by the
// resolver to the user.
func (s) TestResolverReportError(t *testing.T) {
	const resolverErr = "test resolver error"
	r := manual.NewBuilderWithScheme("whatever")
	r.BuildCallback = func(_ resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) {
		cc.ReportError(errors.New(resolverErr))
	}

	cc, err := grpc.NewClient(r.Scheme()+":///", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithResolvers(r))
	if err != nil {
		t.Fatalf("Error creating client: %v", err)
	}
	defer cc.Close()
	cc.Connect()

	ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout)
	defer cancel()
	testutils.AwaitState(ctx, t, cc, connectivity.TransientFailure)

	client := testgrpc.NewTestServiceClient(cc)
	for range 5 {
		_, err = client.EmptyCall(ctx, &testpb.Empty{})
		if code := status.Code(err); code != codes.Unavailable {
			t.Fatalf("EmptyCall() = %v, want %v", err, codes.Unavailable)
		}
		if err == nil || !strings.Contains(err.Error(), resolverErr) {
			t.Fatalf("EmptyCall() = %q, want %q", err, resolverErr)
		}
	}
}

// TestEnterIdleDuringResolverUpdateState tests a scenario that used to deadlock
// while calling UpdateState at the same time as the resolver being closed while