diff --git a/pkg/ingester/client/mimir_util_test.go b/pkg/ingester/client/mimir_util_test.go index f1b18f2530..672c1f8553 100644 --- a/pkg/ingester/client/mimir_util_test.go +++ b/pkg/ingester/client/mimir_util_test.go @@ -18,6 +18,7 @@ import ( "github.com/stretchr/testify/mock" "github.com/stretchr/testify/require" "google.golang.org/grpc" + "google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/test/bufconn" ) @@ -29,7 +30,7 @@ func TestSendQueryStream(t *testing.T) { return listen.Dial() } - conn, err := grpc.DialContext(context.Background(), "bufnet", grpc.WithContextDialer(bufDialer), grpc.WithInsecure()) + conn, err := grpc.DialContext(context.Background(), "bufnet", grpc.WithContextDialer(bufDialer), grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) defer conn.Close() diff --git a/pkg/mimir/mimir_test.go b/pkg/mimir/mimir_test.go index a6cae907b0..352b4ecde6 100644 --- a/pkg/mimir/mimir_test.go +++ b/pkg/mimir/mimir_test.go @@ -35,6 +35,7 @@ import ( "github.com/weaveworks/common/server" "go.uber.org/atomic" "google.golang.org/grpc" + "google.golang.org/grpc/credentials/insecure" "github.com/grafana/mimir/pkg/alertmanager" "github.com/grafana/mimir/pkg/alertmanager/alertstore" @@ -362,7 +363,7 @@ func TestGrpcAuthMiddleware(t *testing.T) { }() } - conn, err := grpc.Dial(net.JoinHostPort(cfg.Server.GRPCListenAddress, strconv.Itoa(cfg.Server.GRPCListenPort)), grpc.WithInsecure()) + conn, err := grpc.Dial(net.JoinHostPort(cfg.Server.GRPCListenAddress, strconv.Itoa(cfg.Server.GRPCListenPort)), grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) defer func() { require.NoError(t, conn.Close()) diff --git a/pkg/querier/worker/frontend_processor_test.go b/pkg/querier/worker/frontend_processor_test.go index 81d546cb19..535532371b 100644 --- a/pkg/querier/worker/frontend_processor_test.go +++ b/pkg/querier/worker/frontend_processor_test.go @@ -16,6 +16,7 @@ import ( "github.com/stretchr/testify/require" "go.uber.org/atomic" "google.golang.org/grpc" + "google.golang.org/grpc/credentials/insecure" ) func TestRecvFailDoesntCancelProcess(t *testing.T) { @@ -23,7 +24,7 @@ func TestRecvFailDoesntCancelProcess(t *testing.T) { defer cancel() // We use random port here, hopefully without any gRPC server. - cc, err := grpc.DialContext(ctx, "localhost:999", grpc.WithInsecure()) + cc, err := grpc.DialContext(ctx, "localhost:999", grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) cfg := Config{} @@ -56,7 +57,7 @@ func TestContextCancelStopsProcess(t *testing.T) { defer cancel() // We use random port here, hopefully without any gRPC server. - cc, err := grpc.DialContext(ctx, "localhost:999", grpc.WithInsecure()) + cc, err := grpc.DialContext(ctx, "localhost:999", grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) pm := newProcessorManager(ctx, &mockProcessor{}, cc, "test") diff --git a/pkg/scheduler/scheduler_test.go b/pkg/scheduler/scheduler_test.go index 1fa6c4ca65..bb01124160 100644 --- a/pkg/scheduler/scheduler_test.go +++ b/pkg/scheduler/scheduler_test.go @@ -26,6 +26,7 @@ import ( "github.com/uber/jaeger-client-go/config" "github.com/weaveworks/common/httpgrpc" "google.golang.org/grpc" + "google.golang.org/grpc/credentials/insecure" "github.com/grafana/mimir/pkg/frontend/v2/frontendv2pb" "github.com/grafana/mimir/pkg/scheduler/schedulerpb" @@ -62,7 +63,7 @@ func setupScheduler(t *testing.T, reg prometheus.Registerer) (*Scheduler, schedu _ = l.Close() }) - c, err := grpc.Dial(l.Addr().String(), grpc.WithInsecure()) + c, err := grpc.Dial(l.Addr().String(), grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) t.Cleanup(func() {