xds: use different proto import for grpc services

grpc · Mar 23, 2021 · 158ef3d · 158ef3d
1 parent b331a48
commit 158ef3d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/admin/test/utils.go b/admin/test/utils.go
@@ -26,6 +26,7 @@ import (
 	"testing"
 	"time"
 
+	v3statusgrpc "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
 	v3statuspb "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
 	"github.com/google/uuid"
 	"google.golang.org/grpc"
@@ -105,7 +106,7 @@ func RunChannelz(conn *grpc.ClientConn) error {
 
 // RunCSDS makes a CSDS RPC.
 func RunCSDS(conn *grpc.ClientConn) error {
-	c := v3statuspb.NewClientStatusDiscoveryServiceClient(conn)
+	c := v3statusgrpc.NewClientStatusDiscoveryServiceClient(conn)
 	ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout)
 	defer cancel()
 	_, err := c.FetchClientStatus(ctx, &v3statuspb.ClientStatusRequest{}, grpc.WaitForReady(true))

diff --git a/xds/csds/csds.go b/xds/csds/csds.go
@@ -32,6 +32,7 @@ import (
 	v3adminpb "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
 	v2corepb "github.com/envoyproxy/go-control-plane/envoy/api/v2/core"
 	v3corepb "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
+	v3statusgrpc "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
 	v3statuspb "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
 	"github.com/golang/protobuf/proto"
 	"google.golang.org/grpc/codes"
@@ -83,7 +84,7 @@ func NewClientStatusDiscoveryServer() (*ClientStatusDiscoveryServer, error) {
 }
 
 // StreamClientStatus implementations interface ClientStatusDiscoveryServiceServer.
-func (s *ClientStatusDiscoveryServer) StreamClientStatus(stream v3statuspb.ClientStatusDiscoveryService_StreamClientStatusServer) error {
+func (s *ClientStatusDiscoveryServer) StreamClientStatus(stream v3statusgrpc.ClientStatusDiscoveryService_StreamClientStatusServer) error {
 	for {
 		req, err := stream.Recv()
 		if err == io.EOF {