X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=examples%2Fcmd%2Fstats-client%2Fstats_client.go;h=5f9966fae02da3ec1538983d5e5281e682380de0;hb=f1bef4a3c66f4408afdeb64cda62ccd8562d0fc6;hp=e0c44635c9a03084e8b76733357f0095077779e1;hpb=de8e6592e23a3819266cea5e9999c7c21fdd826f;p=govpp.git diff --git a/examples/cmd/stats-client/stats_client.go b/examples/cmd/stats-client/stats_client.go index e0c4463..5f9966f 100644 --- a/examples/cmd/stats-client/stats_client.go +++ b/examples/cmd/stats-client/stats_client.go @@ -27,15 +27,15 @@ import ( "git.fd.io/govpp.git" "git.fd.io/govpp.git/api" "git.fd.io/govpp.git/core" - "git.fd.io/govpp.git/core/bin_api/vpe" "git.fd.io/govpp.git/examples/bin_api/interfaces" + "git.fd.io/govpp.git/examples/bin_api/stats" ) func main() { fmt.Println("Starting stats VPP client...") // async connect to VPP - conn, statCh, err := govpp.AsyncConnect() + conn, statCh, err := govpp.AsyncConnect("") if err != nil { fmt.Println("Error:", err) os.Exit(1) @@ -101,7 +101,7 @@ loop: } // subscribeNotifications subscribes for interface counters notifications. -func subscribeNotifications(ch *api.Channel) (*api.NotifSubscription, *api.NotifSubscription, chan api.Message) { +func subscribeNotifications(ch api.Channel) (*api.NotifSubscription, *api.NotifSubscription, chan api.Message) { notifChan := make(chan api.Message, 100) simpleCountersSubs, _ := ch.SubscribeNotification(notifChan, interfaces.NewVnetInterfaceSimpleCounters) @@ -111,11 +111,11 @@ func subscribeNotifications(ch *api.Channel) (*api.NotifSubscription, *api.Notif } // requestStatistics requests interface counters notifications from VPP. -func requestStatistics(ch *api.Channel) { - ch.SendRequest(&vpe.WantStats{ +func requestStatistics(ch api.Channel) { + ch.SendRequest(&stats.WantStats{ Pid: uint32(os.Getpid()), EnableDisable: 1, - }).ReceiveReply(&vpe.WantStatsReply{}) + }).ReceiveReply(&stats.WantStatsReply{}) } // processSimpleCounters processes simple counters received from VPP.