* refactor creation of new channel
* add missing closing of created streams
* correct documentation regarding thread safety of stream
Signed-off-by: mhalaj1 <matus.halaj@pantheon.tech>
Change-Id: Ic601efff298fcbdecaafab83fa236253af69de21
204 files changed:
// Stream provides low-level access for sending and receiving messages.
// Users should handle correct type and ordering of messages.
//
// Stream provides low-level access for sending and receiving messages.
// Users should handle correct type and ordering of messages.
//
+// It is not safe to call these methods on the same stream in different
+// goroutines.
+//
// NOTE: This API is EXPERIMENTAL.
type Stream interface {
// SendMsg sends a message to the client.
// It blocks until message is sent to the transport.
// NOTE: This API is EXPERIMENTAL.
type Stream interface {
// SendMsg sends a message to the client.
// It blocks until message is sent to the transport.
- //
- // It is safe to have a goroutine calling SendMsg and another goroutine
- // calling RecvMsg on the same stream at the same time, but it is not safe
- // to call SendMsg on the same stream in different goroutines.
SendMsg(Message) error
// RecvMsg blocks until a message is received or error occurs.
SendMsg(Message) error
// RecvMsg blocks until a message is received or error occurs.
- //
- // It is safe to have a goroutine calling SendMsg and another goroutine
- // calling RecvMsg on the same stream at the same time, but it is not safe
- // to call SendMsg on the same stream in different goroutines.
RecvMsg() (Message, error)
// Close closes the stream. Calling SendMsg and RecvMsg will return error
RecvMsg() (Message, error)
// Close closes the stream. Calling SendMsg and RecvMsg will return error
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/abf.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/abf.api.json
case *AbfItfAttachDetails:
return m, nil
case *vpe.ControlPingReply:
case *AbfItfAttachDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *AbfPolicyDetails:
return m, nil
case *vpe.ControlPingReply:
case *AbfPolicyDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/acl.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/acl.api.json
case *ACLDetails:
return m, nil
case *vpe.ControlPingReply:
case *ACLDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *ACLInterfaceEtypeWhitelistDetails:
return m, nil
case *vpe.ControlPingReply:
case *ACLInterfaceEtypeWhitelistDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *ACLInterfaceListDetails:
return m, nil
case *vpe.ControlPingReply:
case *ACLInterfaceListDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MacipACLDetails:
return m, nil
case *vpe.ControlPingReply:
case *MacipACLDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MacipACLInterfaceListDetails:
return m, nil
case *vpe.ControlPingReply:
case *MacipACLInterfaceListDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/acl_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/acl_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/adl.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/adl.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/af_packet.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/af_packet.api.json
case *AfPacketDetails:
return m, nil
case *vpe.ControlPingReply:
case *AfPacketDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/af_xdp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/af_xdp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/arp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/arp.api.json
case *ProxyArpDetails:
return m, nil
case *vpe.ControlPingReply:
case *ProxyArpDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *ProxyArpIntfcDetails:
return m, nil
case *vpe.ControlPingReply:
case *ProxyArpIntfcDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/arping.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/arping.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/avf.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/avf.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/bfd.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/bfd.api.json
case *BfdAuthKeysDetails:
return m, nil
case *vpe.ControlPingReply:
case *BfdAuthKeysDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *BfdUDPSessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *BfdUDPSessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/bier.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/bier.api.json
case *BierDispEntryDetails:
return m, nil
case *vpe.ControlPingReply:
case *BierDispEntryDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *BierDispTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *BierDispTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *BierImpDetails:
return m, nil
case *vpe.ControlPingReply:
case *BierImpDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *BierRouteDetails:
return m, nil
case *vpe.ControlPingReply:
case *BierRouteDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *BierTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *BierTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/bond.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/bond.api.json
case *SwBondInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwBondInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SwInterfaceBondDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceBondDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SwInterfaceSlaveDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceSlaveDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SwMemberInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwMemberInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/builtinurl.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/builtinurl.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/cdp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/cdp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/classify.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/classify.api.json
case *ClassifySessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *ClassifySessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *FlowClassifyDetails:
return m, nil
case *vpe.ControlPingReply:
case *FlowClassifyDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *PolicerClassifyDetails:
return m, nil
case *vpe.ControlPingReply:
case *PolicerClassifyDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/cnat.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/cnat.api.json
case *CnatSessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *CnatSessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *CnatTranslationDetails:
return m, nil
case *vpe.ControlPingReply:
case *CnatTranslationDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/crypto.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/crypto.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/crypto_sw_scheduler.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/crypto_sw_scheduler.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ct6.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ct6.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/det44.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/det44.api.json
case *Det44InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *Det44InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Det44MapDetails:
return m, nil
case *vpe.ControlPingReply:
case *Det44MapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Det44SessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *Det44SessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *NatDetMapDetails:
return m, nil
case *vpe.ControlPingReply:
case *NatDetMapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *NatDetSessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *NatDetSessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dhcp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dhcp.api.json
case *DHCPClientDetails:
return m, nil
case *vpe.ControlPingReply:
case *DHCPClientDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *DHCPProxyDetails:
return m, nil
case *vpe.ControlPingReply:
case *DHCPProxyDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dhcp6_ia_na_client_cp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dhcp6_ia_na_client_cp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dhcp6_pd_client_cp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dhcp6_pd_client_cp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dns.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dns.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dslite.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/dslite.api.json
case *DsliteAddressDetails:
return m, nil
case *vpe.ControlPingReply:
case *DsliteAddressDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ethernet_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ethernet_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/feature.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/feature.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/fib.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/fib.api.json
case *FibSourceDetails:
return m, nil
case *vpe.ControlPingReply:
case *FibSourceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/fib_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/fib_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/flow.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/flow.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/flow_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/flow_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/flowprobe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/flowprobe.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/gbp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/gbp.api.json
case *GbpBridgeDomainDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpBridgeDomainDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpContractDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpContractDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpEndpointDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpEndpointDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpEndpointGroupDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpEndpointGroupDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpExtItfDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpExtItfDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpRecircDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpRecircDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpRouteDomainDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpRouteDomainDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpSubnetDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpSubnetDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *GbpVxlanTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *GbpVxlanTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/geneve.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/geneve.api.json
case *GeneveTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *GeneveTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/graph.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/graph.api.json
case *GraphNodeDetails:
return m, nil
case *GraphNodeGetReply:
case *GraphNodeDetails:
return m, nil
case *GraphNodeGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/gre.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/gre.api.json
case *GreTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *GreTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/gso.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/gso.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/gtpu.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/gtpu.api.json
case *GtpuTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *GtpuTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/http_static.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/http_static.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/igmp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/igmp.api.json
case *IgmpDetails:
return m, nil
case *vpe.ControlPingReply:
case *IgmpDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IgmpGroupPrefixDetails:
return m, nil
case *vpe.ControlPingReply:
case *IgmpGroupPrefixDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ikev2.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ikev2.api.json
case *Ikev2ChildSaDetails:
return m, nil
case *vpe.ControlPingReply:
case *Ikev2ChildSaDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Ikev2ProfileDetails:
return m, nil
case *vpe.ControlPingReply:
case *Ikev2ProfileDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Ikev2SaDetails:
return m, nil
case *vpe.ControlPingReply:
case *Ikev2SaDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Ikev2TrafficSelectorDetails:
return m, nil
case *vpe.ControlPingReply:
case *Ikev2TrafficSelectorDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ikev2_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ikev2_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/interface.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/interface.api.json
case *SwInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SwInterfaceRxPlacementDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceRxPlacementDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/interface_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/interface_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ioam_cache.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ioam_cache.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ioam_export.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ioam_export.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ioam_vxlan_gpe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/ioam_vxlan_gpe.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip.api.json
case *IPAddressDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPAddressDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPContainerProxyDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPContainerProxyDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPMrouteDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPMrouteDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPMtableDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPMtableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPPathMtuDetails:
return m, nil
case *IPPathMtuGetReply:
case *IPPathMtuDetails:
return m, nil
case *IPPathMtuGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPPuntRedirectDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPPuntRedirectDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPRouteDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPRouteDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPRouteV2Details:
return m, nil
case *vpe.ControlPingReply:
case *IPRouteV2Details:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IPUnnumberedDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPUnnumberedDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MfibSignalDetails:
return m, nil
case *vpe.ControlPingReply:
case *MfibSignalDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip6_nd.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip6_nd.api.json
case *IP6ndProxyDetails:
return m, nil
case *vpe.ControlPingReply:
case *IP6ndProxyDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip_neighbor.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip_neighbor.api.json
case *IPNeighborDetails:
return m, nil
case *vpe.ControlPingReply:
case *IPNeighborDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ip_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipfix_export.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipfix_export.api.json
case *IpfixClassifyStreamDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpfixClassifyStreamDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpfixClassifyTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpfixClassifyTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpfixExporterDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpfixExporterDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipip.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipip.api.json
case *IpipTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpipTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipsec.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipsec.api.json
case *IpsecBackendDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecBackendDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecItfDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecItfDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecSaDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecSaDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecSaV2Details:
return m, nil
case *vpe.ControlPingReply:
case *IpsecSaV2Details:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecSaV3Details:
return m, nil
case *vpe.ControlPingReply:
case *IpsecSaV3Details:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecSpdDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecSpdDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecSpdInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecSpdInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecSpdsDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecSpdsDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *IpsecTunnelProtectDetails:
return m, nil
case *vpe.ControlPingReply:
case *IpsecTunnelProtectDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipsec_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/ipsec_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/l2.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/l2.api.json
case *BdIPMacDetails:
return m, nil
case *vpe.ControlPingReply:
case *BdIPMacDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *BridgeDomainDetails:
return m, nil
case *vpe.ControlPingReply:
case *BridgeDomainDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *L2FibTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *L2FibTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *L2XconnectDetails:
return m, nil
case *vpe.ControlPingReply:
case *L2XconnectDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/l2e.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/l2e.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/l2tp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/l2tp.api.json
case *SwIfL2tpv3TunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwIfL2tpv3TunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/l3xc.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/l3xc.api.json
case *L3xcDetails:
return m, nil
case *vpe.ControlPingReply:
case *L3xcDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lacp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lacp.api.json
case *SwInterfaceLacpDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceLacpDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lb.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lb.api.json
case *LbAsDetails:
return m, nil
case *vpe.ControlPingReply:
case *LbAsDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LbVipDetails:
return m, nil
case *vpe.ControlPingReply:
case *LbVipDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lb_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lb_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lcp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lcp.api.json
case *LcpItfPairDetails:
return m, nil
case *LcpItfPairGetReply:
case *LcpItfPairDetails:
return m, nil
case *LcpItfPairGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lisp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lisp.api.json
case *LispEidTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispEidTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LispEidTableMapDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispEidTableMapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LispEidTableVniDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispEidTableVniDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LispLocatorDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispLocatorDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LispLocatorSetDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispLocatorSetDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LispMapResolverDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispMapResolverDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *LispMapServerDetails:
return m, nil
case *vpe.ControlPingReply:
case *LispMapServerDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lisp_gpe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lisp_gpe.api.json
case *GpeFwdEntryPathDetails:
return m, nil
case *vpe.ControlPingReply:
case *GpeFwdEntryPathDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lisp_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lisp_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lldp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/lldp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/mactime.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/mactime.api.json
case *MactimeDetails:
return m, nil
case *vpe.ControlPingReply:
case *MactimeDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/map.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/map.api.json
case *MapDomainDetails:
return m, nil
case *vpe.ControlPingReply:
case *MapDomainDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MapDomainDetails:
return m, nil
case *MapDomainsGetReply:
case *MapDomainDetails:
return m, nil
case *MapDomainsGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MapRuleDetails:
return m, nil
case *vpe.ControlPingReply:
case *MapRuleDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/mdata.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/mdata.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/memclnt.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/memclnt.api.json
if err != nil {
return err
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
if err != nil {
return err
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
if err != nil {
return err
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
if err != nil {
return err
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/memif.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/memif.api.json
case *MemifDetails:
return m, nil
case *vpe.ControlPingReply:
case *MemifDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MemifSocketFilenameDetails:
return m, nil
case *vpe.ControlPingReply:
case *MemifSocketFilenameDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/mfib_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/mfib_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/mpls.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/mpls.api.json
case *MplsRouteDetails:
return m, nil
case *vpe.ControlPingReply:
case *MplsRouteDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MplsTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *MplsTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *MplsTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *MplsTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/mss_clamp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/mss_clamp.api.json
case *MssClampDetails:
return m, nil
case *MssClampGetReply:
case *MssClampDetails:
return m, nil
case *MssClampGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat44_ed.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat44_ed.api.json
case *Nat44AddressDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44AddressDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44IdentityMappingDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44IdentityMappingDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44InterfaceAddrDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44InterfaceAddrDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44InterfaceOutputFeatureDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44InterfaceOutputFeatureDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44LbStaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44LbStaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44StaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44StaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44UserDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44UserDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44UserSessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44UserSessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *NatWorkerDetails:
return m, nil
case *vpe.ControlPingReply:
case *NatWorkerDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat44_ei.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat44_ei.api.json
case *Nat44EiAddressDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiAddressDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiIdentityMappingDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiIdentityMappingDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiInterfaceAddrDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiInterfaceAddrDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiInterfaceOutputFeatureDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiInterfaceOutputFeatureDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiStaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiStaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiUserDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiUserDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiUserSessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiUserSessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat44EiWorkerDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat44EiWorkerDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat64.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat64.api.json
case *Nat64BibDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat64BibDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat64InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat64InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat64PoolAddrDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat64PoolAddrDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat64PrefixDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat64PrefixDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat64StDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat64StDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat66.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat66.api.json
case *Nat66InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat66InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Nat66StaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
case *Nat66StaticMappingDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nat_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nsh.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nsh.api.json
case *NshEntryDetails:
return m, nil
case *vpe.ControlPingReply:
case *NshEntryDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *NshMapDetails:
return m, nil
case *vpe.ControlPingReply:
case *NshMapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nsim.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/nsim.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/oddbuf.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/oddbuf.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/one.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/one.api.json
case *OneEidTableDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneEidTableDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneEidTableMapDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneEidTableMapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneEidTableVniDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneEidTableVniDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneLocatorDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneLocatorDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneLocatorSetDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneLocatorSetDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneMapResolverDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneMapResolverDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneMapServerDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneMapServerDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *OneStatsDetails:
return m, nil
case *vpe.ControlPingReply:
case *OneStatsDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/p2p_ethernet.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/p2p_ethernet.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/pci_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/pci_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/pg.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/pg.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/pipe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/pipe.api.json
case *PipeDetails:
return m, nil
case *vpe.ControlPingReply:
case *PipeDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/pnat.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/pnat.api.json
case *PnatBindingsDetails:
return m, nil
case *PnatBindingsGetReply:
case *PnatBindingsDetails:
return m, nil
case *PnatBindingsGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *PnatInterfacesDetails:
return m, nil
case *PnatInterfacesGetReply:
case *PnatInterfacesDetails:
return m, nil
case *PnatInterfacesGetReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/policer.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/policer.api.json
case *PolicerDetails:
return m, nil
case *vpe.ControlPingReply:
case *PolicerDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/policer_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/policer_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/pot.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/pot.api.json
case *PotProfileShowConfigDetails:
return m, nil
case *vpe.ControlPingReply:
case *PotProfileShowConfigDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/pppoe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/pppoe.api.json
case *PppoeSessionDetails:
return m, nil
case *vpe.ControlPingReply:
case *PppoeSessionDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/punt.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/punt.api.json
case *PuntReasonDetails:
return m, nil
case *vpe.ControlPingReply:
case *PuntReasonDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *PuntSocketDetails:
return m, nil
case *vpe.ControlPingReply:
case *PuntSocketDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/qos.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/qos.api.json
case *QosEgressMapDetails:
return m, nil
case *vpe.ControlPingReply:
case *QosEgressMapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *QosMarkDetails:
return m, nil
case *vpe.ControlPingReply:
case *QosMarkDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *QosRecordDetails:
return m, nil
case *vpe.ControlPingReply:
case *QosRecordDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *QosStoreDetails:
return m, nil
case *vpe.ControlPingReply:
case *QosStoreDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/rd_cp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/rd_cp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/rdma.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/rdma.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/session.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/session.api.json
case *SessionRulesDetails:
return m, nil
case *vpe.ControlPingReply:
case *SessionRulesDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/span.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/span.api.json
case *SwInterfaceSpanDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceSpanDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/sr.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/sr.api.json
case *SrLocalsidsDetails:
return m, nil
case *vpe.ControlPingReply:
case *SrLocalsidsDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SrPoliciesDetails:
return m, nil
case *vpe.ControlPingReply:
case *SrPoliciesDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SrPoliciesWithSlIndexDetails:
return m, nil
case *vpe.ControlPingReply:
case *SrPoliciesWithSlIndexDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *SrSteeringPolDetails:
return m, nil
case *vpe.ControlPingReply:
case *SrSteeringPolDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/sr_mpls.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/sr_mpls.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/sr_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/sr_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/stn.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/stn.api.json
case *StnRulesDetails:
return m, nil
case *vpe.ControlPingReply:
case *StnRulesDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/svs.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/svs.api.json
case *SvsDetails:
return m, nil
case *vpe.ControlPingReply:
case *SvsDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/syslog.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/syslog.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/tapv2.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/tapv2.api.json
case *SwInterfaceTapV2Details:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceTapV2Details:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/tcp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/tcp.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/teib.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/teib.api.json
case *TeibDetails:
return m, nil
case *vpe.ControlPingReply:
case *TeibDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/tls_openssl.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/tls_openssl.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/trace.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/trace.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/tracedump.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/tracedump.api.json
case *TraceDetails:
return m, nil
case *TraceDumpReply:
case *TraceDetails:
return m, nil
case *TraceDumpReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/tunnel_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/tunnel_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/udp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/udp.api.json
case *UDPEncapDetails:
return m, nil
case *vpe.ControlPingReply:
case *UDPEncapDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/udp_ping.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/udp_ping.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/urpf.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/urpf.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vhost_user.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vhost_user.api.json
case *SwInterfaceVhostUserDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceVhostUserDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/virtio.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/virtio.api.json
case *SwInterfaceVirtioPciDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwInterfaceVirtioPciDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/virtio_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/virtio_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/vmxnet3.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/vmxnet3.api.json
case *SwVmxnet3InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *SwVmxnet3InterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *Vmxnet3Details:
return m, nil
case *vpe.ControlPingReply:
case *Vmxnet3Details:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vpe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vpe.api.json
case *LogDetails:
return m, nil
case *ControlPingReply:
case *LogDetails:
return m, nil
case *ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vpe_types.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vpe_types.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/vrrp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/vrrp.api.json
case *VrrpVrDetails:
return m, nil
case *vpe.ControlPingReply:
case *VrrpVrDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *VrrpVrPeerDetails:
return m, nil
case *vpe.ControlPingReply:
case *VrrpVrPeerDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *VrrpVrTrackIfDetails:
return m, nil
case *vpe.ControlPingReply:
case *VrrpVrTrackIfDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vxlan.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vxlan.api.json
case *VxlanTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *VxlanTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *VxlanTunnelV2Details:
return m, nil
case *vpe.ControlPingReply:
case *VxlanTunnelV2Details:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vxlan_gbp.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vxlan_gbp.api.json
case *VxlanGbpTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *VxlanGbpTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vxlan_gpe.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/core/vxlan_gpe.api.json
case *VxlanGpeTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
case *VxlanGpeTunnelDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/vxlan_gpe_ioam_export.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/vxlan_gpe_ioam_export.api.json
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
// versions:
-// binapi-generator: v0.3.5-56-gc0da1f2-dirty
+// binapi-generator: v0.4.0-dev
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/wireguard.api.json
// VPP: 21.06-release
// source: /usr/share/vpp/api/plugins/wireguard.api.json
case *WireguardInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
case *WireguardInterfaceDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
case *WireguardPeersDetails:
return m, nil
case *vpe.ControlPingReply:
case *WireguardPeersDetails:
return m, nil
case *vpe.ControlPingReply:
+ err = c.Stream.Close()
+ if err != nil {
+ return nil, err
+ }
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
return nil, io.EOF
default:
return nil, fmt.Errorf("unexpected message: %T %v", m, m)
g.P(" case *", msgDetails.GoIdent, ":")
g.P(" return m, nil")
g.P(" case *", msgReply.GoIdent, ":")
g.P(" case *", msgDetails.GoIdent, ":")
g.P(" return m, nil")
g.P(" case *", msgReply.GoIdent, ":")
+ g.P(" err = c.Stream.Close()")
+ g.P(" if err != nil { return nil, err }")
g.P(" return nil, ", ioPkg.Ident("EOF"))
g.P(" default:")
g.P(" return nil, ", fmtPkg.Ident("Errorf"), "(\"unexpected message: %T %v\", m, m)")
g.P(" return nil, ", ioPkg.Ident("EOF"))
g.P(" default:")
g.P(" return nil, ", fmtPkg.Ident("Errorf"), "(\"unexpected message: %T %v\", m, m)")
g.P("if err != nil { return err }")
g.P("err = stream.SendMsg(in)")
g.P("if err != nil { return err }")
g.P("if err != nil { return err }")
g.P("err = stream.SendMsg(in)")
g.P("if err != nil { return err }")
+ g.P("err = stream.Close()")
+ g.P("if err != nil { return err }")
g.P("return nil")
}
g.P("}")
g.P("return nil")
}
g.P("}")
"fmt"
"reflect"
"strings"
"fmt"
"reflect"
"strings"
"time"
"github.com/sirupsen/logrus"
"time"
"github.com/sirupsen/logrus"
receiveReplyTimeout time.Duration // maximum time that we wait for receiver to consume reply
}
receiveReplyTimeout time.Duration // maximum time that we wait for receiver to consume reply
}
-func newChannel(id uint16, conn *Connection, codec MessageCodec, identifier MessageIdentifier, reqSize, replySize int) *Channel {
- return &Channel{
- id: id,
- conn: conn,
- msgCodec: codec,
- msgIdentifier: identifier,
- reqChan: make(chan *vppRequest, reqSize),
- replyChan: make(chan *vppReply, replySize),
+func (c *Connection) newChannel(reqChanBufSize, replyChanBufSize int) *Channel {
+ // create new channel
+ chID := uint16(atomic.AddUint32(&c.maxChannelID, 1) & 0x7fff)
+ channel := &Channel{
+ id: chID,
+ conn: c,
+ msgCodec: c.codec,
+ msgIdentifier: c,
+ reqChan: make(chan *vppRequest, reqChanBufSize),
+ replyChan: make(chan *vppReply, replyChanBufSize),
replyTimeout: DefaultReplyTimeout,
receiveReplyTimeout: ReplyChannelTimeout,
}
replyTimeout: DefaultReplyTimeout,
receiveReplyTimeout: ReplyChannelTimeout,
}
+
+ // store API channel within the client
+ c.channelsLock.Lock()
+ c.channels[chID] = channel
+ c.channelsLock.Unlock()
+
+ return channel
}
func (ch *Channel) GetID() uint16 {
}
func (ch *Channel) GetID() uint16 {
return nil, errors.New("nil connection passed in")
}
return nil, errors.New("nil connection passed in")
}
- // create new channel
- chID := uint16(atomic.AddUint32(&c.maxChannelID, 1) & 0x7fff)
- channel := newChannel(chID, c, c.codec, c, reqChanBufSize, replyChanBufSize)
-
- // store API channel within the client
- c.channelsLock.Lock()
- c.channels[chID] = channel
- c.channelsLock.Unlock()
+ channel := c.newChannel(reqChanBufSize, replyChanBufSize)
// start watching on the request channel
go c.watchRequests(channel)
// start watching on the request channel
go c.watchRequests(channel)
"time"
"git.fd.io/govpp.git/api"
)
type Stream struct {
"time"
"git.fd.io/govpp.git/api"
)
type Stream struct {
conn *Connection
ctx context.Context
channel *Channel
conn *Connection
ctx context.Context
channel *Channel
for _, option := range options {
option(s)
}
for _, option := range options {
option(s)
}
- // create and store a new channel
- s.id = atomic.AddUint32(&c.maxChannelID, 1) & 0x7fff
- s.channel = newChannel(uint16(s.id), c, c.codec, c, s.requestSize, s.replySize)
- s.channel.SetReplyTimeout(s.replyTimeout)
- // store API channel within the client
- c.channelsLock.Lock()
- c.channels[uint16(s.id)] = s.channel
- c.channelsLock.Unlock()
+ s.channel = c.newChannel(s.requestSize, s.replySize)
+ s.channel.SetReplyTimeout(s.replyTimeout)
// Channel.watchRequests are not started here intentionally, because
// requests are sent directly by SendMsg.
// Channel.watchRequests are not started here intentionally, because
// requests are sent directly by SendMsg.