Improvements for binapi-generator and support VPP 19.04 in statsclient

[govpp.git] / examples / rpc-service / rpc_service.go

diff --git a/examples/rpc-service/rpc_service.go b/examples/rpc-service/rpc_service.go
new file mode 100644 (file)
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"))
+       }
+}