@@ -18,9 +18,9 @@ import (
18
18
"google.golang.org/grpc/reflection"
19
19
"google.golang.org/protobuf/encoding/protojson"
20
20
"google.golang.org/protobuf/proto"
21
- "google.golang.org/protobuf/types/known/emptypb"
22
21
23
22
confpb "google.golang.org/genproto/googleapis/api/expr/conformance/v1alpha1"
23
+ epb "google.golang.org/protobuf/types/known/emptypb"
24
24
)
25
25
26
26
// ConfClient manages calls to conformance test services.
@@ -46,7 +46,7 @@ type grpcConfClient struct {
46
46
// - one output line is expected, repeat again.
47
47
type pipeConfClient struct {
48
48
binary string
49
- cmd_args []string
49
+ cmdArgs []string
50
50
cmd * exec.Cmd
51
51
stdOut * bufio.Reader
52
52
stdIn io.Writer
@@ -139,7 +139,7 @@ func NewPipeClient(serverCmd string, base64Encode bool, pingsEnabled bool) (Conf
139
139
return & c , fmt .Errorf ("server cmd '%s' invalid" , serverCmd )
140
140
}
141
141
c .binary = fields [0 ]
142
- c .cmd_args = fields [1 :]
142
+ c .cmdArgs = fields [1 :]
143
143
144
144
return & c , c .reset ()
145
145
}
@@ -149,7 +149,7 @@ func (c *pipeConfClient) reset() error {
149
149
if c .binary == "" {
150
150
return errors .New ("reset on invalid pipe service configuration" )
151
151
}
152
- cmd := exec .Command (c .binary , c .cmd_args ... )
152
+ cmd := exec .Command (c .binary , c .cmdArgs ... )
153
153
out , err := cmd .StdoutPipe ()
154
154
if err != nil {
155
155
return err
@@ -171,7 +171,7 @@ func (c *pipeConfClient) reset() error {
171
171
}
172
172
173
173
func (c * pipeConfClient ) isAlive () bool {
174
- m := emptypb .Empty {}
174
+ m := epb .Empty {}
175
175
err := c .pipeCommand ("ping" , & m , & m )
176
176
return err == nil
177
177
}
0 commit comments