Skip to content

Commit af5502b

Browse files
remove no longer required grpc replace (issue: #3284)
1 parent 8723097 commit af5502b

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

pkg/controller/registry/grpc/source.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ func grpcConnection(address string) (*grpc.ClientConn, error) {
163163
}))
164164
}
165165

166-
return grpc.Dial(address, dialOptions...)
166+
return grpc.NewClient(address, dialOptions...)
167167
}
168168

169169
func (s *SourceStore) Add(key registry.CatalogKey, address string) (*SourceConn, error) {

pkg/package-server/provider/registry_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2067,7 +2067,7 @@ func TestRegistryProviderListLabels(t *testing.T) {
20672067
}
20682068

20692069
func newTestRegistryClient(t *testing.T, catsrc *operatorsv1alpha1.CatalogSource) *registryClient {
2070-
conn, err := grpc.Dial(address+catsrc.Status.RegistryServiceStatus.Port, grpc.WithTransportCredentials(insecure.NewCredentials()))
2070+
conn, err := grpc.NewClient(address+catsrc.Status.RegistryServiceStatus.Port, grpc.WithTransportCredentials(insecure.NewCredentials()))
20712071
require.NoError(t, err, "could not set up test grpc connection")
20722072
return newRegistryClient(catsrc, conn)
20732073
}

0 commit comments

Comments
 (0)