Method TestNoRetry

test/retry_test.go:853–930

(t *testing.T)

}

func (s) TestNoRetry(t *testing.T) {
	scJSON := `{
	"methodConfig": [{
	  "name": [{"service": "grpc.testing.TestService"}],
	  "retryPolicy": {
		"MaxAttempts": 4,
		"InitialBackoff": ".01s",
		"MaxBackoff": ".01s",
		"BackoffMultiplier": 1.0,
		"RetryableStatusCodes": [ "UNAVAILABLE" ]
	  }
	}]}`
	tests := []struct {
		name     string
		dialOpts []grpc.DialOption
	}{
		{
			name: "disabled",
			dialOpts: []grpc.DialOption{
				grpc.WithDefaultServiceConfig(scJSON),
				grpc.WithDisableRetry(),
			},
		},
		{
			name:     "not_configured",
			dialOpts: []grpc.DialOption{},
		},
	}

	for _, tc := range tests {
		t.Run(tc.name, func(t *testing.T) {
			ss := &stubserver.StubServer{
				FullDuplexCallF: func(testgrpc.TestService_FullDuplexCallServer) error {
					return status.New(codes.Unavailable, "retryable error").Err()
				},
				EmptyCallF: func(context.Context, *testpb.Empty) (r *testpb.Empty, err error) {
					return nil, status.New(codes.Unavailable, "retryable error").Err()
				},
			}
			if err := ss.Start([]grpc.ServerOption{}, tc.dialOpts...); err != nil {
				t.Fatalf("Error starting endpoint server: %v", err)
			}
			defer ss.Stop()

			ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout)
			defer cancel()

			// Test streaming RPC
			stream, err := ss.Client.FullDuplexCall(ctx)
			if err != nil {
				t.Fatalf("Error while creating stream: %v", err)
			}
			_, err = stream.Recv()
			if err == nil {
				t.Fatal("stream.Recv() succeeded when expected to fail")
			}
			if status.Code(err) != codes.Unavailable {
				t.Fatalf("client: Recv() = _, %v; want _, Unavailable", err)