Skip to content

Commit

Permalink
Delete grpc.WithBlock() and grpc.WaitForReady(true) options (#917)
Browse files Browse the repository at this point in the history
* Delete grpc.WithBlock() and grpc.WaitForReady(true) options

Signed-off-by: Nikita Skrynnik <[email protected]>

* fix linter

Signed-off-by: Nikita Skrynnik <[email protected]>

---------

Signed-off-by: Nikita Skrynnik <[email protected]>
  • Loading branch information
NikitaSkrynnik authored Aug 11, 2023
1 parent 5dd4018 commit 2d3d13c
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 6 deletions.
4 changes: 1 addition & 3 deletions internal/tests/suite_healthcheck_test.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
// Copyright (c) 2020-2022 Cisco and/or its affiliates.
// Copyright (c) 2020-2023 Cisco and/or its affiliates.
//
// SPDX-License-Identifier: Apache-2.0
//
Expand All @@ -23,7 +23,6 @@ import (

"github.com/networkservicemesh/sdk/pkg/tools/log/logruslogger"

"google.golang.org/grpc"
"google.golang.org/grpc/health/grpc_health_v1"

"github.com/networkservicemesh/sdk/pkg/tools/log"
Expand All @@ -38,7 +37,6 @@ func (f *ForwarderTestSuite) TestHealthCheck() {
&grpc_health_v1.HealthCheckRequest{
Service: "networkservice.NetworkService",
},
grpc.WaitForReady(true),
)
f.NoError(err)
f.Require().NotNil(healthResponse)
Expand Down
1 change: 0 additions & 1 deletion internal/tests/suite_setup_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,6 @@ func (f *ForwarderTestSuite) SetupSuite() {
f.sutCC, err = grpc.DialContext(f.ctx,
regEndpoint.NetworkServiceEndpoint.GetUrl(),
grpc.WithTransportCredentials(clientCreds),
grpc.WithBlock(),
grpc.WithDefaultCallOptions(
grpc.PerRPCCredentials(token.NewPerRPCCredentials(spiffejwt.TokenGeneratorFunc(source, f.config.MaxTokenLifetime))),
),
Expand Down
2 changes: 0 additions & 2 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -228,9 +228,7 @@ func main() {

dialOptions := append(
tracing.WithTracingDial(),
grpc.WithBlock(),
grpc.WithDefaultCallOptions(
grpc.WaitForReady(true),
grpc.PerRPCCredentials(token.NewPerRPCCredentials(spiffejwt.TokenGeneratorFunc(source, cfg.MaxTokenLifetime)))),
grpc.WithTransportCredentials(
grpcfd.TransportCredentials(
Expand Down

0 comments on commit 2d3d13c

Please sign in to comment.