github/containerd
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Add transport credentials GRPC opt

Browse Source 
Signed-off-by: Maksym Pavlenko <pavlenko.maksym@gmail.com>
This commit is contained in:
Maksym Pavlenko 2023-02-10 15:02:51 -08:00
parent 77fc0948c4
commit 8ef298d863
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
runtime/v2/shim.go
View File

@ -30,6 +30,7 @@ import (
"github.com/containerd/ttrpc" "github.com/containerd/ttrpc"
"github.com/hashicorp/go-multierror" "github.com/hashicorp/go-multierror"
"google.golang.org/grpc" "google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
eventstypes "github.com/containerd/containerd/api/events" eventstypes "github.com/containerd/containerd/api/events"
"github.com/containerd/containerd/api/runtime/task/v2" "github.com/containerd/containerd/api/runtime/task/v2"
@ -240,9 +241,9 @@ func makeConnection(ctx context.Context, address string, onClose func()) (_ io.C
return ttrpcClient, nil return ttrpcClient, nil
case "grpc": case "grpc":
var ( gopts := []grpc.DialOption{
gopts []grpc.DialOption grpc.WithTransportCredentials(insecure.NewCredentials()),
) }
conn, err := grpc.DialContext(ctx, dialer.DialAddress(params.Address), gopts...) conn, err := grpc.DialContext(ctx, dialer.DialAddress(params.Address), gopts...)
if err != nil { if err != nil {