aboutsummaryrefslogtreecommitdiffstats
path: root/examples/rpc-service/rpc_service.go
diff options
context:
space:
mode:
Diffstat (limited to 'examples/rpc-service/rpc_service.go')
-rw-r--r--examples/rpc-service/rpc_service.go93
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"))
+ }
+}