1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "go.fd.io/govpp/api"
11 memclnt "go.fd.io/govpp/binapi/memclnt"
14 // RPCService defines RPC service vxlan_gpe.
15 type RPCService interface {
16 SwInterfaceSetVxlanGpeBypass(ctx context.Context, in *SwInterfaceSetVxlanGpeBypass) (*SwInterfaceSetVxlanGpeBypassReply, error)
17 VxlanGpeAddDelTunnel(ctx context.Context, in *VxlanGpeAddDelTunnel) (*VxlanGpeAddDelTunnelReply, error)
18 VxlanGpeAddDelTunnelV2(ctx context.Context, in *VxlanGpeAddDelTunnelV2) (*VxlanGpeAddDelTunnelV2Reply, error)
19 VxlanGpeTunnelDump(ctx context.Context, in *VxlanGpeTunnelDump) (RPCService_VxlanGpeTunnelDumpClient, error)
20 VxlanGpeTunnelV2Dump(ctx context.Context, in *VxlanGpeTunnelV2Dump) (RPCService_VxlanGpeTunnelV2DumpClient, error)
23 type serviceClient struct {
27 func NewServiceClient(conn api.Connection) RPCService {
28 return &serviceClient{conn}
31 func (c *serviceClient) SwInterfaceSetVxlanGpeBypass(ctx context.Context, in *SwInterfaceSetVxlanGpeBypass) (*SwInterfaceSetVxlanGpeBypassReply, error) {
32 out := new(SwInterfaceSetVxlanGpeBypassReply)
33 err := c.conn.Invoke(ctx, in, out)
37 return out, api.RetvalToVPPApiError(out.Retval)
40 func (c *serviceClient) VxlanGpeAddDelTunnel(ctx context.Context, in *VxlanGpeAddDelTunnel) (*VxlanGpeAddDelTunnelReply, error) {
41 out := new(VxlanGpeAddDelTunnelReply)
42 err := c.conn.Invoke(ctx, in, out)
46 return out, api.RetvalToVPPApiError(out.Retval)
49 func (c *serviceClient) VxlanGpeAddDelTunnelV2(ctx context.Context, in *VxlanGpeAddDelTunnelV2) (*VxlanGpeAddDelTunnelV2Reply, error) {
50 out := new(VxlanGpeAddDelTunnelV2Reply)
51 err := c.conn.Invoke(ctx, in, out)
55 return out, api.RetvalToVPPApiError(out.Retval)
58 func (c *serviceClient) VxlanGpeTunnelDump(ctx context.Context, in *VxlanGpeTunnelDump) (RPCService_VxlanGpeTunnelDumpClient, error) {
59 stream, err := c.conn.NewStream(ctx)
63 x := &serviceClient_VxlanGpeTunnelDumpClient{stream}
64 if err := x.Stream.SendMsg(in); err != nil {
67 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
73 type RPCService_VxlanGpeTunnelDumpClient interface {
74 Recv() (*VxlanGpeTunnelDetails, error)
78 type serviceClient_VxlanGpeTunnelDumpClient struct {
82 func (c *serviceClient_VxlanGpeTunnelDumpClient) Recv() (*VxlanGpeTunnelDetails, error) {
83 msg, err := c.Stream.RecvMsg()
87 switch m := msg.(type) {
88 case *VxlanGpeTunnelDetails:
90 case *memclnt.ControlPingReply:
91 err = c.Stream.Close()
97 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
101 func (c *serviceClient) VxlanGpeTunnelV2Dump(ctx context.Context, in *VxlanGpeTunnelV2Dump) (RPCService_VxlanGpeTunnelV2DumpClient, error) {
102 stream, err := c.conn.NewStream(ctx)
106 x := &serviceClient_VxlanGpeTunnelV2DumpClient{stream}
107 if err := x.Stream.SendMsg(in); err != nil {
110 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
116 type RPCService_VxlanGpeTunnelV2DumpClient interface {
117 Recv() (*VxlanGpeTunnelV2Details, error)
121 type serviceClient_VxlanGpeTunnelV2DumpClient struct {
125 func (c *serviceClient_VxlanGpeTunnelV2DumpClient) Recv() (*VxlanGpeTunnelV2Details, error) {
126 msg, err := c.Stream.RecvMsg()
130 switch m := msg.(type) {
131 case *VxlanGpeTunnelV2Details:
133 case *memclnt.ControlPingReply:
134 err = c.Stream.Close()
140 return nil, fmt.Errorf("unexpected message: %T %v", m, m)