Improvements for binapi-generator and support VPP 19.04 in statsclient

- RPC service client implementation for dumps requests
  now streams responses
- RPC service generation is now enabled by default
- examples now allow setting binapi socket address
- input dir flag for binapi-generator will recursively look
  into dirs to support core/plugins in /usr/share/vpp/api
- minor improvements in debug logs
- add support for VPP 19.04 for statsclient

Change-Id: I0939ee3aa6e9f850d073fc5c87aff4ccc56b0d70
Signed-off-by: Ondrej Fabry <ofabry@cisco.com>

1 files changed, 93 insertions, 0 deletions

diff --git a/examples/rpc-service/rpc_service.go b/examples/rpc-service/rpc_service.go
new file mode 100644
index 0000000..ca0c295
--- /dev/null
+++ b/examples/rpc-service/rpc_service.go
@@ -0,0 +1,93 @@
+// Copyright (c) 2017 Cisco and/or its affiliates.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at:
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// service-client is an example VPP management application that exercises the
+// govpp API using generated service client.
+package main
+
+import (
+	"bytes"
+	"context"
+	"flag"
+	"fmt"
+	"io"
+	"log"
+
+	"git.fd.io/govpp.git"
+	"git.fd.io/govpp.git/adapter/socketclient"
+	"git.fd.io/govpp.git/api"
+	"git.fd.io/govpp.git/examples/binapi/interfaces"
+	"git.fd.io/govpp.git/examples/binapi/vpe"
+)
+
+var (
+	sockAddr = flag.String("sock", socketclient.DefaultSocketName, "Path to VPP binary API socket file")
+)
+
+func main() {
+	flag.Parse()
+
+	fmt.Println("Starting RPC service example")
+
+	// connect to VPP
+	conn, err := govpp.Connect(*sockAddr)
+	if err != nil {
+		log.Fatalln("ERROR: connecting to VPP failed:", err)
+	}
+	defer conn.Disconnect()
+
+	// create a channel
+	ch, err := conn.NewAPIChannel()
+	if err != nil {
+		log.Fatalln("ERROR: creating channel failed:", err)
+	}
+	defer ch.Close()
+
+	showVersion(ch)
+	interfaceDump(ch)
+}
+
+// showVersion shows an example of simple request with services.
+func showVersion(ch api.Channel) {
+	c := vpe.NewServiceClient(ch)
+
+	version, err := c.ShowVersion(context.Background(), &vpe.ShowVersion{})
+	if err != nil {
+		log.Fatalln("ERROR: ShowVersion failed:", err)
+	}
+
+	fmt.Printf("Version: %v\n", version.Version)
+}
+
+// interfaceDump shows an example of multi request with services.
+func interfaceDump(ch api.Channel) {
+	c := interfaces.NewServiceClient(ch)
+
+	stream, err := c.DumpSwInterface(context.Background(), &interfaces.SwInterfaceDump{})
+	if err != nil {
+		log.Fatalln("ERROR: DumpSwInterface failed:", err)
+	}
+
+	fmt.Println("Dumping interfaces")
+	for {
+		iface, err := stream.Recv()
+		if err == io.EOF {
+			break
+		}
+		if err != nil {
+			log.Fatalln("ERROR: DumpSwInterface failed:", err)
+		}
+		fmt.Printf("- interface: %s\n", bytes.Trim(iface.InterfaceName, "\x00"))
+	}
+}