change end2end test
This commit is contained in:
@ -381,12 +381,6 @@ func main() {
|
||||
grpclog.Fatalf("Failed to create JWT credentials: %v", err)
|
||||
}
|
||||
opts = append(opts, grpc.WithPerRPCCredentials(jwtCreds))
|
||||
} else if *testCase == "jwt_token_creds" {
|
||||
jwtCreds, err := oauth.NewServiceAccountFromFile(*serviceAccountKeyFile, *oauthScope)
|
||||
if err != nil {
|
||||
grpclog.Fatalf("Failed to create JWT credentials: %v", err)
|
||||
}
|
||||
opts = append(opts, grpc.WithPerRPCCredentials(jwtCreds))
|
||||
}
|
||||
}
|
||||
conn, err := grpc.Dial(serverAddr, opts...)
|
||||
|
@ -75,7 +75,11 @@ func (s *testServer) EmptyCall(ctx context.Context, in *testpb.Empty) (*testpb.E
|
||||
if _, ok := md["user-agent"]; !ok {
|
||||
return nil, grpc.Errorf(codes.DataLoss, "got extra metadata")
|
||||
}
|
||||
grpc.SendHeader(ctx, metadata.Pairs("ua", md["user-agent"][0]))
|
||||
var str []string
|
||||
for _,entry := range md["user-agent"]{
|
||||
str = append(str,"ua",entry)
|
||||
}
|
||||
grpc.SendHeader(ctx, metadata.Pairs(str...))
|
||||
}
|
||||
return new(testpb.Empty), nil
|
||||
}
|
||||
|
Reference in New Issue
Block a user