package main
import (
- "context"
"encoding/gob"
"flag"
- "io"
"log"
- "git.fd.io/govpp.git/adapter/socketclient"
- "git.fd.io/govpp.git/adapter/statsclient"
- "git.fd.io/govpp.git/api"
- _ "git.fd.io/govpp.git/core"
- "git.fd.io/govpp.git/examples/binapi/interfaces"
- "git.fd.io/govpp.git/examples/binapi/vpe"
- "git.fd.io/govpp.git/proxy"
+ "go.fd.io/govpp/adapter/socketclient"
+ "go.fd.io/govpp/adapter/statsclient"
+ "go.fd.io/govpp/api"
+ interfaces "go.fd.io/govpp/binapi/interface"
+ "go.fd.io/govpp/binapi/vlib"
+ "go.fd.io/govpp/binapi/vpe"
+ _ "go.fd.io/govpp/core"
+ "go.fd.io/govpp/proxy"
)
var (
)
func init() {
- for _, msg := range api.GetRegisteredMessages() {
- gob.Register(msg)
+ for _, msgList := range api.GetRegisteredMessages() {
+ for _, msg := range msgList {
+ gob.Register(msg)
+ }
}
}
panic(err)
}
- // - using binapi message directly
- req := &vpe.CliInband{Cmd: "show version"}
- reply := new(vpe.CliInbandReply)
+ req := &vlib.CliInband{Cmd: "show version"}
+ reply := new(vlib.CliInbandReply)
if err := binapiChannel.SendRequest(req).ReceiveReply(reply); err != nil {
log.Fatalln("binapi request failed:", err)
}
log.Printf("VPP version: %+v", reply.Reply)
-
- // - or using generated rpc service
- svc := interfaces.NewServiceClient(binapiChannel)
- stream, err := svc.DumpSwInterface(context.Background(), &interfaces.SwInterfaceDump{})
- if err != nil {
- log.Fatalln("binapi request failed:", err)
- }
- for {
- iface, err := stream.Recv()
- if err == io.EOF {
- break
- }
- if err != nil {
- log.Fatalln(err)
- }
- log.Printf("- interface: %+v", iface)
- }
}
func runServer() {