Use buf for proto generation

examples/bidirectional/shared/grpc.go

@@ -55,6 +55,7 @@ func (m *GRPCClient) Get(key string) (int64, error) {
 
 // Here is the gRPC server that GRPCClient talks to.
 type GRPCServer struct {
+	proto.UnimplementedCounterServer
 	// This is the real implementation
 	Impl Counter
 
@@ -94,6 +95,7 @@ func (m *GRPCAddHelperClient) Sum(a, b int64) (int64, error) {
 
 // Here is the gRPC server that GRPCClient talks to.
 type GRPCAddHelperServer struct {
+	proto.UnimplementedAddHelperServer
 	// This is the real implementation
 	Impl AddHelper
 }

examples/grpc/shared/grpc.go

@@ -33,6 +33,7 @@ func (m *GRPCClient) Get(key string) ([]byte, error) {
 
 // Here is the gRPC server that GRPCClient talks to.
 type GRPCServer struct {
+	proto.UnimplementedKVServer
 	// This is the real implementation
 	Impl KV
 }

grpc_broker.go

@@ -40,6 +40,8 @@ type sendErr struct {
 // connection information to/from the plugin. Implements GRPCBrokerServer and
 // streamer interfaces.
 type gRPCBrokerServer struct {
+	plugin.UnimplementedGRPCBrokerServer
+
 	// send is used to send connection info to the gRPC stream.
 	send chan *sendErr
 

grpc_controller.go

@@ -12,6 +12,7 @@ import (
 // GRPCControllerServer handles shutdown calls to terminate the server when the
 // plugin client is closed.
 type grpcControllerServer struct {
+	plugin.UnimplementedGRPCControllerServer
 	server *GRPCServer
 }
 

grpc_stdio.go

@@ -24,6 +24,7 @@ const grpcStdioBuffer = 1 * 1024
 
 // grpcStdioServer implements the Stdio service and streams stdiout/stderr.
 type grpcStdioServer struct {
+	plugin.UnimplementedGRPCStdioServer
 	stdoutCh <-chan []byte
 	stderrCh <-chan []byte
 }

plugin_test.go

@@ -207,6 +207,7 @@ var testGRPCPluginMap = map[string]Plugin{
 
 // testGRPCServer is the implementation of our GRPC service.
 type testGRPCServer struct {
+	grpctest.UnimplementedTestServer
 	Impl   testInterface
 	broker *GRPCBroker
 }
@@ -273,7 +274,9 @@ func (s *testGRPCServer) PrintStdio(
 	return &empty.Empty{}, nil
 }
 
-type pingPongServer struct{}
+type pingPongServer struct {
+	grpctest.UnimplementedPingPongServer
+}
 
 func (p *pingPongServer) Ping(ctx context.Context, req *grpctest.PingRequest) (*grpctest.PongResponse, error) {
 	return &grpctest.PongResponse{