grpc
/
grpc-go
mirror of https://github.com/grpc/grpc-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

admin/test: split channelz imports (#6058)

This commit is contained in:
Easwar Swaminathan 2023-02-27 16:57:44 -08:00 committed by GitHub
parent 1093d3ac0a
commit 681b13383c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
admin/test/utils.go
View File

@ -36,6 +36,7 @@ import (
v3statusgrpc "github.com/envoyproxy/go-control-plane/envoy/service/status/v3" v3statusgrpc "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
v3statuspb "github.com/envoyproxy/go-control-plane/envoy/service/status/v3" v3statuspb "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
channelzgrpc "google.golang.org/grpc/channelz/grpc_channelz_v1"
channelzpb "google.golang.org/grpc/channelz/grpc_channelz_v1" channelzpb "google.golang.org/grpc/channelz/grpc_channelz_v1"
) )
@ -98,7 +99,7 @@ func RunRegisterTests(t *testing.T, ec ExpectedStatusCodes) {
// RunChannelz makes a channelz RPC. // RunChannelz makes a channelz RPC.
func RunChannelz(conn *grpc.ClientConn) error { func RunChannelz(conn *grpc.ClientConn) error {
c := channelzpb.NewChannelzClient(conn) c := channelzgrpc.NewChannelzClient(conn)
ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout) ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout)
defer cancel() defer cancel()
_, err := c.GetTopChannels(ctx, &channelzpb.GetTopChannelsRequest{}, grpc.WaitForReady(true)) _, err := c.GetTopChannels(ctx, &channelzpb.GetTopChannelsRequest{}, grpc.WaitForReady(true))