Skip to content

Commit

Permalink
xds: rename rls proto import (#5205)
Browse files Browse the repository at this point in the history
  • Loading branch information
easwars committed Feb 23, 2022
1 parent fd1f988 commit 02f384d
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 13 deletions.
4 changes: 2 additions & 2 deletions xds/internal/clusterspecifier/rls/rls.go
Expand Up @@ -27,7 +27,7 @@ import (
"github.com/golang/protobuf/ptypes"
"google.golang.org/grpc/balancer"
"google.golang.org/grpc/internal/envconfig"
"google.golang.org/grpc/internal/proto/grpc_lookup_v1"
rlspb "google.golang.org/grpc/internal/proto/grpc_lookup_v1"
"google.golang.org/grpc/xds/internal/clusterspecifier"
"google.golang.org/protobuf/encoding/protojson"
"google.golang.org/protobuf/types/known/anypb"
Expand Down Expand Up @@ -65,7 +65,7 @@ func (rls) ParseClusterSpecifierConfig(cfg proto.Message) (clusterspecifier.Bala
if !ok {
return nil, fmt.Errorf("rls_csp: error parsing config %v: unknown type %T", cfg, cfg)
}
rlcs := new(grpc_lookup_v1.RouteLookupClusterSpecifier)
rlcs := new(rlspb.RouteLookupClusterSpecifier)

if err := ptypes.UnmarshalAny(any, rlcs); err != nil {
return nil, fmt.Errorf("rls_csp: error parsing config %v: %v", cfg, err)
Expand Down
22 changes: 11 additions & 11 deletions xds/internal/clusterspecifier/rls/rls_test.go
Expand Up @@ -27,7 +27,7 @@ import (
"github.com/google/go-cmp/cmp/cmpopts"
_ "google.golang.org/grpc/balancer/rls"
"google.golang.org/grpc/internal/grpctest"
"google.golang.org/grpc/internal/proto/grpc_lookup_v1"
rlspb "google.golang.org/grpc/internal/proto/grpc_lookup_v1"
"google.golang.org/grpc/internal/testutils"
_ "google.golang.org/grpc/xds/internal/balancer/cdsbalancer"
"google.golang.org/grpc/xds/internal/clusterspecifier"
Expand Down Expand Up @@ -106,17 +106,17 @@ func (s) TestParseClusterSpecifierConfig(t *testing.T) {
}

// This will error because the required match field is set in grpc key builder.
var rlsClusterSpecifierConfigError = testutils.MarshalAny(&grpc_lookup_v1.RouteLookupClusterSpecifier{
RouteLookupConfig: &grpc_lookup_v1.RouteLookupConfig{
GrpcKeybuilders: []*grpc_lookup_v1.GrpcKeyBuilder{
var rlsClusterSpecifierConfigError = testutils.MarshalAny(&rlspb.RouteLookupClusterSpecifier{
RouteLookupConfig: &rlspb.RouteLookupConfig{
GrpcKeybuilders: []*rlspb.GrpcKeyBuilder{
{
Names: []*grpc_lookup_v1.GrpcKeyBuilder_Name{
Names: []*rlspb.GrpcKeyBuilder_Name{
{
Service: "service",
Method: "method",
},
},
Headers: []*grpc_lookup_v1.NameMatcher{
Headers: []*rlspb.NameMatcher{
{
Key: "k1",
RequiredMatch: true,
Expand All @@ -130,17 +130,17 @@ var rlsClusterSpecifierConfigError = testutils.MarshalAny(&grpc_lookup_v1.RouteL

// Corresponds to the rls unit test case in
// balancer/rls/internal/config_test.go.
var rlsClusterSpecifierConfigWithoutTransformations = testutils.MarshalAny(&grpc_lookup_v1.RouteLookupClusterSpecifier{
RouteLookupConfig: &grpc_lookup_v1.RouteLookupConfig{
GrpcKeybuilders: []*grpc_lookup_v1.GrpcKeyBuilder{
var rlsClusterSpecifierConfigWithoutTransformations = testutils.MarshalAny(&rlspb.RouteLookupClusterSpecifier{
RouteLookupConfig: &rlspb.RouteLookupConfig{
GrpcKeybuilders: []*rlspb.GrpcKeyBuilder{
{
Names: []*grpc_lookup_v1.GrpcKeyBuilder_Name{
Names: []*rlspb.GrpcKeyBuilder_Name{
{
Service: "service",
Method: "method",
},
},
Headers: []*grpc_lookup_v1.NameMatcher{
Headers: []*rlspb.NameMatcher{
{
Key: "k1",
Names: []string{"v1"},
Expand Down

0 comments on commit 02f384d

Please sign in to comment.