1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 vpe "git.fd.io/govpp.git/binapi/vpe"
14 // RPCService defines RPC service ip.
15 type RPCService interface {
16 IoamDisable(ctx context.Context, in *IoamDisable) (*IoamDisableReply, error)
17 IoamEnable(ctx context.Context, in *IoamEnable) (*IoamEnableReply, error)
18 IPAddressDump(ctx context.Context, in *IPAddressDump) (RPCService_IPAddressDumpClient, error)
19 IPContainerProxyAddDel(ctx context.Context, in *IPContainerProxyAddDel) (*IPContainerProxyAddDelReply, error)
20 IPContainerProxyDump(ctx context.Context, in *IPContainerProxyDump) (RPCService_IPContainerProxyDumpClient, error)
21 IPDump(ctx context.Context, in *IPDump) (RPCService_IPDumpClient, error)
22 IPMrouteAddDel(ctx context.Context, in *IPMrouteAddDel) (*IPMrouteAddDelReply, error)
23 IPMrouteDump(ctx context.Context, in *IPMrouteDump) (RPCService_IPMrouteDumpClient, error)
24 IPMtableDump(ctx context.Context, in *IPMtableDump) (RPCService_IPMtableDumpClient, error)
25 IPPuntPolice(ctx context.Context, in *IPPuntPolice) (*IPPuntPoliceReply, error)
26 IPPuntRedirect(ctx context.Context, in *IPPuntRedirect) (*IPPuntRedirectReply, error)
27 IPPuntRedirectDump(ctx context.Context, in *IPPuntRedirectDump) (RPCService_IPPuntRedirectDumpClient, error)
28 IPReassemblyEnableDisable(ctx context.Context, in *IPReassemblyEnableDisable) (*IPReassemblyEnableDisableReply, error)
29 IPReassemblyGet(ctx context.Context, in *IPReassemblyGet) (*IPReassemblyGetReply, error)
30 IPReassemblySet(ctx context.Context, in *IPReassemblySet) (*IPReassemblySetReply, error)
31 IPRouteAddDel(ctx context.Context, in *IPRouteAddDel) (*IPRouteAddDelReply, error)
32 IPRouteDump(ctx context.Context, in *IPRouteDump) (RPCService_IPRouteDumpClient, error)
33 IPRouteLookup(ctx context.Context, in *IPRouteLookup) (*IPRouteLookupReply, error)
34 IPSourceAndPortRangeCheckAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckAddDel) (*IPSourceAndPortRangeCheckAddDelReply, error)
35 IPSourceAndPortRangeCheckInterfaceAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckInterfaceAddDel) (*IPSourceAndPortRangeCheckInterfaceAddDelReply, error)
36 IPTableAddDel(ctx context.Context, in *IPTableAddDel) (*IPTableAddDelReply, error)
37 IPTableDump(ctx context.Context, in *IPTableDump) (RPCService_IPTableDumpClient, error)
38 IPTableFlush(ctx context.Context, in *IPTableFlush) (*IPTableFlushReply, error)
39 IPTableReplaceBegin(ctx context.Context, in *IPTableReplaceBegin) (*IPTableReplaceBeginReply, error)
40 IPTableReplaceEnd(ctx context.Context, in *IPTableReplaceEnd) (*IPTableReplaceEndReply, error)
41 IPUnnumberedDump(ctx context.Context, in *IPUnnumberedDump) (RPCService_IPUnnumberedDumpClient, error)
42 MfibSignalDump(ctx context.Context, in *MfibSignalDump) (RPCService_MfibSignalDumpClient, error)
43 SetIPFlowHash(ctx context.Context, in *SetIPFlowHash) (*SetIPFlowHashReply, error)
44 SwInterfaceIP6EnableDisable(ctx context.Context, in *SwInterfaceIP6EnableDisable) (*SwInterfaceIP6EnableDisableReply, error)
45 SwInterfaceIP6SetLinkLocalAddress(ctx context.Context, in *SwInterfaceIP6SetLinkLocalAddress) (*SwInterfaceIP6SetLinkLocalAddressReply, error)
48 type serviceClient struct {
52 func NewServiceClient(conn api.Connection) RPCService {
53 return &serviceClient{conn}
56 func (c *serviceClient) IoamDisable(ctx context.Context, in *IoamDisable) (*IoamDisableReply, error) {
57 out := new(IoamDisableReply)
58 err := c.conn.Invoke(ctx, in, out)
62 return out, api.RetvalToVPPApiError(out.Retval)
65 func (c *serviceClient) IoamEnable(ctx context.Context, in *IoamEnable) (*IoamEnableReply, error) {
66 out := new(IoamEnableReply)
67 err := c.conn.Invoke(ctx, in, out)
71 return out, api.RetvalToVPPApiError(out.Retval)
74 func (c *serviceClient) IPAddressDump(ctx context.Context, in *IPAddressDump) (RPCService_IPAddressDumpClient, error) {
75 stream, err := c.conn.NewStream(ctx)
79 x := &serviceClient_IPAddressDumpClient{stream}
80 if err := x.Stream.SendMsg(in); err != nil {
83 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
89 type RPCService_IPAddressDumpClient interface {
90 Recv() (*IPAddressDetails, error)
94 type serviceClient_IPAddressDumpClient struct {
98 func (c *serviceClient_IPAddressDumpClient) Recv() (*IPAddressDetails, error) {
99 msg, err := c.Stream.RecvMsg()
103 switch m := msg.(type) {
104 case *IPAddressDetails:
106 case *vpe.ControlPingReply:
109 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
113 func (c *serviceClient) IPContainerProxyAddDel(ctx context.Context, in *IPContainerProxyAddDel) (*IPContainerProxyAddDelReply, error) {
114 out := new(IPContainerProxyAddDelReply)
115 err := c.conn.Invoke(ctx, in, out)
119 return out, api.RetvalToVPPApiError(out.Retval)
122 func (c *serviceClient) IPContainerProxyDump(ctx context.Context, in *IPContainerProxyDump) (RPCService_IPContainerProxyDumpClient, error) {
123 stream, err := c.conn.NewStream(ctx)
127 x := &serviceClient_IPContainerProxyDumpClient{stream}
128 if err := x.Stream.SendMsg(in); err != nil {
131 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
137 type RPCService_IPContainerProxyDumpClient interface {
138 Recv() (*IPContainerProxyDetails, error)
142 type serviceClient_IPContainerProxyDumpClient struct {
146 func (c *serviceClient_IPContainerProxyDumpClient) Recv() (*IPContainerProxyDetails, error) {
147 msg, err := c.Stream.RecvMsg()
151 switch m := msg.(type) {
152 case *IPContainerProxyDetails:
154 case *vpe.ControlPingReply:
157 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
161 func (c *serviceClient) IPDump(ctx context.Context, in *IPDump) (RPCService_IPDumpClient, error) {
162 stream, err := c.conn.NewStream(ctx)
166 x := &serviceClient_IPDumpClient{stream}
167 if err := x.Stream.SendMsg(in); err != nil {
170 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
176 type RPCService_IPDumpClient interface {
177 Recv() (*IPDetails, error)
181 type serviceClient_IPDumpClient struct {
185 func (c *serviceClient_IPDumpClient) Recv() (*IPDetails, error) {
186 msg, err := c.Stream.RecvMsg()
190 switch m := msg.(type) {
193 case *vpe.ControlPingReply:
196 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
200 func (c *serviceClient) IPMrouteAddDel(ctx context.Context, in *IPMrouteAddDel) (*IPMrouteAddDelReply, error) {
201 out := new(IPMrouteAddDelReply)
202 err := c.conn.Invoke(ctx, in, out)
206 return out, api.RetvalToVPPApiError(out.Retval)
209 func (c *serviceClient) IPMrouteDump(ctx context.Context, in *IPMrouteDump) (RPCService_IPMrouteDumpClient, error) {
210 stream, err := c.conn.NewStream(ctx)
214 x := &serviceClient_IPMrouteDumpClient{stream}
215 if err := x.Stream.SendMsg(in); err != nil {
218 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
224 type RPCService_IPMrouteDumpClient interface {
225 Recv() (*IPMrouteDetails, error)
229 type serviceClient_IPMrouteDumpClient struct {
233 func (c *serviceClient_IPMrouteDumpClient) Recv() (*IPMrouteDetails, error) {
234 msg, err := c.Stream.RecvMsg()
238 switch m := msg.(type) {
239 case *IPMrouteDetails:
241 case *vpe.ControlPingReply:
244 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
248 func (c *serviceClient) IPMtableDump(ctx context.Context, in *IPMtableDump) (RPCService_IPMtableDumpClient, error) {
249 stream, err := c.conn.NewStream(ctx)
253 x := &serviceClient_IPMtableDumpClient{stream}
254 if err := x.Stream.SendMsg(in); err != nil {
257 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
263 type RPCService_IPMtableDumpClient interface {
264 Recv() (*IPMtableDetails, error)
268 type serviceClient_IPMtableDumpClient struct {
272 func (c *serviceClient_IPMtableDumpClient) Recv() (*IPMtableDetails, error) {
273 msg, err := c.Stream.RecvMsg()
277 switch m := msg.(type) {
278 case *IPMtableDetails:
280 case *vpe.ControlPingReply:
283 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
287 func (c *serviceClient) IPPuntPolice(ctx context.Context, in *IPPuntPolice) (*IPPuntPoliceReply, error) {
288 out := new(IPPuntPoliceReply)
289 err := c.conn.Invoke(ctx, in, out)
293 return out, api.RetvalToVPPApiError(out.Retval)
296 func (c *serviceClient) IPPuntRedirect(ctx context.Context, in *IPPuntRedirect) (*IPPuntRedirectReply, error) {
297 out := new(IPPuntRedirectReply)
298 err := c.conn.Invoke(ctx, in, out)
302 return out, api.RetvalToVPPApiError(out.Retval)
305 func (c *serviceClient) IPPuntRedirectDump(ctx context.Context, in *IPPuntRedirectDump) (RPCService_IPPuntRedirectDumpClient, error) {
306 stream, err := c.conn.NewStream(ctx)
310 x := &serviceClient_IPPuntRedirectDumpClient{stream}
311 if err := x.Stream.SendMsg(in); err != nil {
314 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
320 type RPCService_IPPuntRedirectDumpClient interface {
321 Recv() (*IPPuntRedirectDetails, error)
325 type serviceClient_IPPuntRedirectDumpClient struct {
329 func (c *serviceClient_IPPuntRedirectDumpClient) Recv() (*IPPuntRedirectDetails, error) {
330 msg, err := c.Stream.RecvMsg()
334 switch m := msg.(type) {
335 case *IPPuntRedirectDetails:
337 case *vpe.ControlPingReply:
340 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
344 func (c *serviceClient) IPReassemblyEnableDisable(ctx context.Context, in *IPReassemblyEnableDisable) (*IPReassemblyEnableDisableReply, error) {
345 out := new(IPReassemblyEnableDisableReply)
346 err := c.conn.Invoke(ctx, in, out)
350 return out, api.RetvalToVPPApiError(out.Retval)
353 func (c *serviceClient) IPReassemblyGet(ctx context.Context, in *IPReassemblyGet) (*IPReassemblyGetReply, error) {
354 out := new(IPReassemblyGetReply)
355 err := c.conn.Invoke(ctx, in, out)
359 return out, api.RetvalToVPPApiError(out.Retval)
362 func (c *serviceClient) IPReassemblySet(ctx context.Context, in *IPReassemblySet) (*IPReassemblySetReply, error) {
363 out := new(IPReassemblySetReply)
364 err := c.conn.Invoke(ctx, in, out)
368 return out, api.RetvalToVPPApiError(out.Retval)
371 func (c *serviceClient) IPRouteAddDel(ctx context.Context, in *IPRouteAddDel) (*IPRouteAddDelReply, error) {
372 out := new(IPRouteAddDelReply)
373 err := c.conn.Invoke(ctx, in, out)
377 return out, api.RetvalToVPPApiError(out.Retval)
380 func (c *serviceClient) IPRouteDump(ctx context.Context, in *IPRouteDump) (RPCService_IPRouteDumpClient, error) {
381 stream, err := c.conn.NewStream(ctx)
385 x := &serviceClient_IPRouteDumpClient{stream}
386 if err := x.Stream.SendMsg(in); err != nil {
389 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
395 type RPCService_IPRouteDumpClient interface {
396 Recv() (*IPRouteDetails, error)
400 type serviceClient_IPRouteDumpClient struct {
404 func (c *serviceClient_IPRouteDumpClient) Recv() (*IPRouteDetails, error) {
405 msg, err := c.Stream.RecvMsg()
409 switch m := msg.(type) {
410 case *IPRouteDetails:
412 case *vpe.ControlPingReply:
415 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
419 func (c *serviceClient) IPRouteLookup(ctx context.Context, in *IPRouteLookup) (*IPRouteLookupReply, error) {
420 out := new(IPRouteLookupReply)
421 err := c.conn.Invoke(ctx, in, out)
425 return out, api.RetvalToVPPApiError(out.Retval)
428 func (c *serviceClient) IPSourceAndPortRangeCheckAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckAddDel) (*IPSourceAndPortRangeCheckAddDelReply, error) {
429 out := new(IPSourceAndPortRangeCheckAddDelReply)
430 err := c.conn.Invoke(ctx, in, out)
434 return out, api.RetvalToVPPApiError(out.Retval)
437 func (c *serviceClient) IPSourceAndPortRangeCheckInterfaceAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckInterfaceAddDel) (*IPSourceAndPortRangeCheckInterfaceAddDelReply, error) {
438 out := new(IPSourceAndPortRangeCheckInterfaceAddDelReply)
439 err := c.conn.Invoke(ctx, in, out)
443 return out, api.RetvalToVPPApiError(out.Retval)
446 func (c *serviceClient) IPTableAddDel(ctx context.Context, in *IPTableAddDel) (*IPTableAddDelReply, error) {
447 out := new(IPTableAddDelReply)
448 err := c.conn.Invoke(ctx, in, out)
452 return out, api.RetvalToVPPApiError(out.Retval)
455 func (c *serviceClient) IPTableDump(ctx context.Context, in *IPTableDump) (RPCService_IPTableDumpClient, error) {
456 stream, err := c.conn.NewStream(ctx)
460 x := &serviceClient_IPTableDumpClient{stream}
461 if err := x.Stream.SendMsg(in); err != nil {
464 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
470 type RPCService_IPTableDumpClient interface {
471 Recv() (*IPTableDetails, error)
475 type serviceClient_IPTableDumpClient struct {
479 func (c *serviceClient_IPTableDumpClient) Recv() (*IPTableDetails, error) {
480 msg, err := c.Stream.RecvMsg()
484 switch m := msg.(type) {
485 case *IPTableDetails:
487 case *vpe.ControlPingReply:
490 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
494 func (c *serviceClient) IPTableFlush(ctx context.Context, in *IPTableFlush) (*IPTableFlushReply, error) {
495 out := new(IPTableFlushReply)
496 err := c.conn.Invoke(ctx, in, out)
500 return out, api.RetvalToVPPApiError(out.Retval)
503 func (c *serviceClient) IPTableReplaceBegin(ctx context.Context, in *IPTableReplaceBegin) (*IPTableReplaceBeginReply, error) {
504 out := new(IPTableReplaceBeginReply)
505 err := c.conn.Invoke(ctx, in, out)
509 return out, api.RetvalToVPPApiError(out.Retval)
512 func (c *serviceClient) IPTableReplaceEnd(ctx context.Context, in *IPTableReplaceEnd) (*IPTableReplaceEndReply, error) {
513 out := new(IPTableReplaceEndReply)
514 err := c.conn.Invoke(ctx, in, out)
518 return out, api.RetvalToVPPApiError(out.Retval)
521 func (c *serviceClient) IPUnnumberedDump(ctx context.Context, in *IPUnnumberedDump) (RPCService_IPUnnumberedDumpClient, error) {
522 stream, err := c.conn.NewStream(ctx)
526 x := &serviceClient_IPUnnumberedDumpClient{stream}
527 if err := x.Stream.SendMsg(in); err != nil {
530 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
536 type RPCService_IPUnnumberedDumpClient interface {
537 Recv() (*IPUnnumberedDetails, error)
541 type serviceClient_IPUnnumberedDumpClient struct {
545 func (c *serviceClient_IPUnnumberedDumpClient) Recv() (*IPUnnumberedDetails, error) {
546 msg, err := c.Stream.RecvMsg()
550 switch m := msg.(type) {
551 case *IPUnnumberedDetails:
553 case *vpe.ControlPingReply:
556 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
560 func (c *serviceClient) MfibSignalDump(ctx context.Context, in *MfibSignalDump) (RPCService_MfibSignalDumpClient, error) {
561 stream, err := c.conn.NewStream(ctx)
565 x := &serviceClient_MfibSignalDumpClient{stream}
566 if err := x.Stream.SendMsg(in); err != nil {
569 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
575 type RPCService_MfibSignalDumpClient interface {
576 Recv() (*MfibSignalDetails, error)
580 type serviceClient_MfibSignalDumpClient struct {
584 func (c *serviceClient_MfibSignalDumpClient) Recv() (*MfibSignalDetails, error) {
585 msg, err := c.Stream.RecvMsg()
589 switch m := msg.(type) {
590 case *MfibSignalDetails:
592 case *vpe.ControlPingReply:
595 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
599 func (c *serviceClient) SetIPFlowHash(ctx context.Context, in *SetIPFlowHash) (*SetIPFlowHashReply, error) {
600 out := new(SetIPFlowHashReply)
601 err := c.conn.Invoke(ctx, in, out)
605 return out, api.RetvalToVPPApiError(out.Retval)
608 func (c *serviceClient) SwInterfaceIP6EnableDisable(ctx context.Context, in *SwInterfaceIP6EnableDisable) (*SwInterfaceIP6EnableDisableReply, error) {
609 out := new(SwInterfaceIP6EnableDisableReply)
610 err := c.conn.Invoke(ctx, in, out)
614 return out, api.RetvalToVPPApiError(out.Retval)
617 func (c *serviceClient) SwInterfaceIP6SetLinkLocalAddress(ctx context.Context, in *SwInterfaceIP6SetLinkLocalAddress) (*SwInterfaceIP6SetLinkLocalAddressReply, error) {
618 out := new(SwInterfaceIP6SetLinkLocalAddressReply)
619 err := c.conn.Invoke(ctx, in, out)
623 return out, api.RetvalToVPPApiError(out.Retval)