1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
8 api "git.fd.io/govpp.git/api"
9 vpe "git.fd.io/govpp.git/internal/testbinapi/binapi2001/vpe"
13 // RPCService defines RPC service ip.
14 type RPCService interface {
15 IoamDisable(ctx context.Context, in *IoamDisable) (*IoamDisableReply, error)
16 IoamEnable(ctx context.Context, in *IoamEnable) (*IoamEnableReply, error)
17 IPAddressDump(ctx context.Context, in *IPAddressDump) (RPCService_IPAddressDumpClient, error)
18 IPContainerProxyAddDel(ctx context.Context, in *IPContainerProxyAddDel) (*IPContainerProxyAddDelReply, error)
19 IPContainerProxyDump(ctx context.Context, in *IPContainerProxyDump) (RPCService_IPContainerProxyDumpClient, error)
20 IPDump(ctx context.Context, in *IPDump) (RPCService_IPDumpClient, error)
21 IPMrouteAddDel(ctx context.Context, in *IPMrouteAddDel) (*IPMrouteAddDelReply, error)
22 IPMrouteDump(ctx context.Context, in *IPMrouteDump) (RPCService_IPMrouteDumpClient, error)
23 IPMtableDump(ctx context.Context, in *IPMtableDump) (RPCService_IPMtableDumpClient, error)
24 IPPuntPolice(ctx context.Context, in *IPPuntPolice) (*IPPuntPoliceReply, error)
25 IPPuntRedirect(ctx context.Context, in *IPPuntRedirect) (*IPPuntRedirectReply, error)
26 IPPuntRedirectDump(ctx context.Context, in *IPPuntRedirectDump) (RPCService_IPPuntRedirectDumpClient, error)
27 IPReassemblyEnableDisable(ctx context.Context, in *IPReassemblyEnableDisable) (*IPReassemblyEnableDisableReply, error)
28 IPReassemblyGet(ctx context.Context, in *IPReassemblyGet) (*IPReassemblyGetReply, error)
29 IPReassemblySet(ctx context.Context, in *IPReassemblySet) (*IPReassemblySetReply, error)
30 IPRouteAddDel(ctx context.Context, in *IPRouteAddDel) (*IPRouteAddDelReply, error)
31 IPRouteDump(ctx context.Context, in *IPRouteDump) (RPCService_IPRouteDumpClient, error)
32 IPSourceAndPortRangeCheckAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckAddDel) (*IPSourceAndPortRangeCheckAddDelReply, error)
33 IPSourceAndPortRangeCheckInterfaceAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckInterfaceAddDel) (*IPSourceAndPortRangeCheckInterfaceAddDelReply, error)
34 IPSourceCheckInterfaceAddDel(ctx context.Context, in *IPSourceCheckInterfaceAddDel) (*IPSourceCheckInterfaceAddDelReply, error)
35 IPTableAddDel(ctx context.Context, in *IPTableAddDel) (*IPTableAddDelReply, error)
36 IPTableDump(ctx context.Context, in *IPTableDump) (RPCService_IPTableDumpClient, error)
37 IPTableFlush(ctx context.Context, in *IPTableFlush) (*IPTableFlushReply, error)
38 IPTableReplaceBegin(ctx context.Context, in *IPTableReplaceBegin) (*IPTableReplaceBeginReply, error)
39 IPTableReplaceEnd(ctx context.Context, in *IPTableReplaceEnd) (*IPTableReplaceEndReply, error)
40 IPUnnumberedDump(ctx context.Context, in *IPUnnumberedDump) (RPCService_IPUnnumberedDumpClient, error)
41 MfibSignalDump(ctx context.Context, in *MfibSignalDump) (RPCService_MfibSignalDumpClient, error)
42 SetIPFlowHash(ctx context.Context, in *SetIPFlowHash) (*SetIPFlowHashReply, error)
43 SwInterfaceIP6EnableDisable(ctx context.Context, in *SwInterfaceIP6EnableDisable) (*SwInterfaceIP6EnableDisableReply, error)
44 SwInterfaceIP6SetLinkLocalAddress(ctx context.Context, in *SwInterfaceIP6SetLinkLocalAddress) (*SwInterfaceIP6SetLinkLocalAddressReply, error)
47 type serviceClient struct {
51 func NewServiceClient(conn api.Connection) RPCService {
52 return &serviceClient{conn}
55 func (c *serviceClient) IoamDisable(ctx context.Context, in *IoamDisable) (*IoamDisableReply, error) {
56 out := new(IoamDisableReply)
57 err := c.conn.Invoke(ctx, in, out)
64 func (c *serviceClient) IoamEnable(ctx context.Context, in *IoamEnable) (*IoamEnableReply, error) {
65 out := new(IoamEnableReply)
66 err := c.conn.Invoke(ctx, in, out)
73 func (c *serviceClient) IPAddressDump(ctx context.Context, in *IPAddressDump) (RPCService_IPAddressDumpClient, error) {
74 stream, err := c.conn.NewStream(ctx)
78 x := &serviceClient_IPAddressDumpClient{stream}
79 if err := x.Stream.SendMsg(in); err != nil {
82 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
88 type RPCService_IPAddressDumpClient interface {
89 Recv() (*IPAddressDetails, error)
93 type serviceClient_IPAddressDumpClient struct {
97 func (c *serviceClient_IPAddressDumpClient) Recv() (*IPAddressDetails, error) {
98 msg, err := c.Stream.RecvMsg()
102 switch m := msg.(type) {
103 case *IPAddressDetails:
105 case *vpe.ControlPingReply:
108 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
112 func (c *serviceClient) IPContainerProxyAddDel(ctx context.Context, in *IPContainerProxyAddDel) (*IPContainerProxyAddDelReply, error) {
113 out := new(IPContainerProxyAddDelReply)
114 err := c.conn.Invoke(ctx, in, out)
121 func (c *serviceClient) IPContainerProxyDump(ctx context.Context, in *IPContainerProxyDump) (RPCService_IPContainerProxyDumpClient, error) {
122 stream, err := c.conn.NewStream(ctx)
126 x := &serviceClient_IPContainerProxyDumpClient{stream}
127 if err := x.Stream.SendMsg(in); err != nil {
130 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
136 type RPCService_IPContainerProxyDumpClient interface {
137 Recv() (*IPContainerProxyDetails, error)
141 type serviceClient_IPContainerProxyDumpClient struct {
145 func (c *serviceClient_IPContainerProxyDumpClient) Recv() (*IPContainerProxyDetails, error) {
146 msg, err := c.Stream.RecvMsg()
150 switch m := msg.(type) {
151 case *IPContainerProxyDetails:
153 case *vpe.ControlPingReply:
156 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
160 func (c *serviceClient) IPDump(ctx context.Context, in *IPDump) (RPCService_IPDumpClient, error) {
161 stream, err := c.conn.NewStream(ctx)
165 x := &serviceClient_IPDumpClient{stream}
166 if err := x.Stream.SendMsg(in); err != nil {
169 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
175 type RPCService_IPDumpClient interface {
176 Recv() (*IPDetails, error)
180 type serviceClient_IPDumpClient struct {
184 func (c *serviceClient_IPDumpClient) Recv() (*IPDetails, error) {
185 msg, err := c.Stream.RecvMsg()
189 switch m := msg.(type) {
192 case *vpe.ControlPingReply:
195 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
199 func (c *serviceClient) IPMrouteAddDel(ctx context.Context, in *IPMrouteAddDel) (*IPMrouteAddDelReply, error) {
200 out := new(IPMrouteAddDelReply)
201 err := c.conn.Invoke(ctx, in, out)
208 func (c *serviceClient) IPMrouteDump(ctx context.Context, in *IPMrouteDump) (RPCService_IPMrouteDumpClient, error) {
209 stream, err := c.conn.NewStream(ctx)
213 x := &serviceClient_IPMrouteDumpClient{stream}
214 if err := x.Stream.SendMsg(in); err != nil {
217 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
223 type RPCService_IPMrouteDumpClient interface {
224 Recv() (*IPMrouteDetails, error)
228 type serviceClient_IPMrouteDumpClient struct {
232 func (c *serviceClient_IPMrouteDumpClient) Recv() (*IPMrouteDetails, error) {
233 msg, err := c.Stream.RecvMsg()
237 switch m := msg.(type) {
238 case *IPMrouteDetails:
240 case *vpe.ControlPingReply:
243 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
247 func (c *serviceClient) IPMtableDump(ctx context.Context, in *IPMtableDump) (RPCService_IPMtableDumpClient, error) {
248 stream, err := c.conn.NewStream(ctx)
252 x := &serviceClient_IPMtableDumpClient{stream}
253 if err := x.Stream.SendMsg(in); err != nil {
256 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
262 type RPCService_IPMtableDumpClient interface {
263 Recv() (*IPMtableDetails, error)
267 type serviceClient_IPMtableDumpClient struct {
271 func (c *serviceClient_IPMtableDumpClient) Recv() (*IPMtableDetails, error) {
272 msg, err := c.Stream.RecvMsg()
276 switch m := msg.(type) {
277 case *IPMtableDetails:
279 case *vpe.ControlPingReply:
282 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
286 func (c *serviceClient) IPPuntPolice(ctx context.Context, in *IPPuntPolice) (*IPPuntPoliceReply, error) {
287 out := new(IPPuntPoliceReply)
288 err := c.conn.Invoke(ctx, in, out)
295 func (c *serviceClient) IPPuntRedirect(ctx context.Context, in *IPPuntRedirect) (*IPPuntRedirectReply, error) {
296 out := new(IPPuntRedirectReply)
297 err := c.conn.Invoke(ctx, in, out)
304 func (c *serviceClient) IPPuntRedirectDump(ctx context.Context, in *IPPuntRedirectDump) (RPCService_IPPuntRedirectDumpClient, error) {
305 stream, err := c.conn.NewStream(ctx)
309 x := &serviceClient_IPPuntRedirectDumpClient{stream}
310 if err := x.Stream.SendMsg(in); err != nil {
313 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
319 type RPCService_IPPuntRedirectDumpClient interface {
320 Recv() (*IPPuntRedirectDetails, error)
324 type serviceClient_IPPuntRedirectDumpClient struct {
328 func (c *serviceClient_IPPuntRedirectDumpClient) Recv() (*IPPuntRedirectDetails, error) {
329 msg, err := c.Stream.RecvMsg()
333 switch m := msg.(type) {
334 case *IPPuntRedirectDetails:
336 case *vpe.ControlPingReply:
339 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
343 func (c *serviceClient) IPReassemblyEnableDisable(ctx context.Context, in *IPReassemblyEnableDisable) (*IPReassemblyEnableDisableReply, error) {
344 out := new(IPReassemblyEnableDisableReply)
345 err := c.conn.Invoke(ctx, in, out)
352 func (c *serviceClient) IPReassemblyGet(ctx context.Context, in *IPReassemblyGet) (*IPReassemblyGetReply, error) {
353 out := new(IPReassemblyGetReply)
354 err := c.conn.Invoke(ctx, in, out)
361 func (c *serviceClient) IPReassemblySet(ctx context.Context, in *IPReassemblySet) (*IPReassemblySetReply, error) {
362 out := new(IPReassemblySetReply)
363 err := c.conn.Invoke(ctx, in, out)
370 func (c *serviceClient) IPRouteAddDel(ctx context.Context, in *IPRouteAddDel) (*IPRouteAddDelReply, error) {
371 out := new(IPRouteAddDelReply)
372 err := c.conn.Invoke(ctx, in, out)
379 func (c *serviceClient) IPRouteDump(ctx context.Context, in *IPRouteDump) (RPCService_IPRouteDumpClient, error) {
380 stream, err := c.conn.NewStream(ctx)
384 x := &serviceClient_IPRouteDumpClient{stream}
385 if err := x.Stream.SendMsg(in); err != nil {
388 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
394 type RPCService_IPRouteDumpClient interface {
395 Recv() (*IPRouteDetails, error)
399 type serviceClient_IPRouteDumpClient struct {
403 func (c *serviceClient_IPRouteDumpClient) Recv() (*IPRouteDetails, error) {
404 msg, err := c.Stream.RecvMsg()
408 switch m := msg.(type) {
409 case *IPRouteDetails:
411 case *vpe.ControlPingReply:
414 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
418 func (c *serviceClient) IPSourceAndPortRangeCheckAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckAddDel) (*IPSourceAndPortRangeCheckAddDelReply, error) {
419 out := new(IPSourceAndPortRangeCheckAddDelReply)
420 err := c.conn.Invoke(ctx, in, out)
427 func (c *serviceClient) IPSourceAndPortRangeCheckInterfaceAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckInterfaceAddDel) (*IPSourceAndPortRangeCheckInterfaceAddDelReply, error) {
428 out := new(IPSourceAndPortRangeCheckInterfaceAddDelReply)
429 err := c.conn.Invoke(ctx, in, out)
436 func (c *serviceClient) IPSourceCheckInterfaceAddDel(ctx context.Context, in *IPSourceCheckInterfaceAddDel) (*IPSourceCheckInterfaceAddDelReply, error) {
437 out := new(IPSourceCheckInterfaceAddDelReply)
438 err := c.conn.Invoke(ctx, in, out)
445 func (c *serviceClient) IPTableAddDel(ctx context.Context, in *IPTableAddDel) (*IPTableAddDelReply, error) {
446 out := new(IPTableAddDelReply)
447 err := c.conn.Invoke(ctx, in, out)
454 func (c *serviceClient) IPTableDump(ctx context.Context, in *IPTableDump) (RPCService_IPTableDumpClient, error) {
455 stream, err := c.conn.NewStream(ctx)
459 x := &serviceClient_IPTableDumpClient{stream}
460 if err := x.Stream.SendMsg(in); err != nil {
463 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
469 type RPCService_IPTableDumpClient interface {
470 Recv() (*IPTableDetails, error)
474 type serviceClient_IPTableDumpClient struct {
478 func (c *serviceClient_IPTableDumpClient) Recv() (*IPTableDetails, error) {
479 msg, err := c.Stream.RecvMsg()
483 switch m := msg.(type) {
484 case *IPTableDetails:
486 case *vpe.ControlPingReply:
489 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
493 func (c *serviceClient) IPTableFlush(ctx context.Context, in *IPTableFlush) (*IPTableFlushReply, error) {
494 out := new(IPTableFlushReply)
495 err := c.conn.Invoke(ctx, in, out)
502 func (c *serviceClient) IPTableReplaceBegin(ctx context.Context, in *IPTableReplaceBegin) (*IPTableReplaceBeginReply, error) {
503 out := new(IPTableReplaceBeginReply)
504 err := c.conn.Invoke(ctx, in, out)
511 func (c *serviceClient) IPTableReplaceEnd(ctx context.Context, in *IPTableReplaceEnd) (*IPTableReplaceEndReply, error) {
512 out := new(IPTableReplaceEndReply)
513 err := c.conn.Invoke(ctx, in, out)
520 func (c *serviceClient) IPUnnumberedDump(ctx context.Context, in *IPUnnumberedDump) (RPCService_IPUnnumberedDumpClient, error) {
521 stream, err := c.conn.NewStream(ctx)
525 x := &serviceClient_IPUnnumberedDumpClient{stream}
526 if err := x.Stream.SendMsg(in); err != nil {
529 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
535 type RPCService_IPUnnumberedDumpClient interface {
536 Recv() (*IPUnnumberedDetails, error)
540 type serviceClient_IPUnnumberedDumpClient struct {
544 func (c *serviceClient_IPUnnumberedDumpClient) Recv() (*IPUnnumberedDetails, error) {
545 msg, err := c.Stream.RecvMsg()
549 switch m := msg.(type) {
550 case *IPUnnumberedDetails:
552 case *vpe.ControlPingReply:
555 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
559 func (c *serviceClient) MfibSignalDump(ctx context.Context, in *MfibSignalDump) (RPCService_MfibSignalDumpClient, error) {
560 stream, err := c.conn.NewStream(ctx)
564 x := &serviceClient_MfibSignalDumpClient{stream}
565 if err := x.Stream.SendMsg(in); err != nil {
568 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
574 type RPCService_MfibSignalDumpClient interface {
575 Recv() (*MfibSignalDetails, error)
579 type serviceClient_MfibSignalDumpClient struct {
583 func (c *serviceClient_MfibSignalDumpClient) Recv() (*MfibSignalDetails, error) {
584 msg, err := c.Stream.RecvMsg()
588 switch m := msg.(type) {
589 case *MfibSignalDetails:
591 case *vpe.ControlPingReply:
594 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
598 func (c *serviceClient) SetIPFlowHash(ctx context.Context, in *SetIPFlowHash) (*SetIPFlowHashReply, error) {
599 out := new(SetIPFlowHashReply)
600 err := c.conn.Invoke(ctx, in, out)
607 func (c *serviceClient) SwInterfaceIP6EnableDisable(ctx context.Context, in *SwInterfaceIP6EnableDisable) (*SwInterfaceIP6EnableDisableReply, error) {
608 out := new(SwInterfaceIP6EnableDisableReply)
609 err := c.conn.Invoke(ctx, in, out)
616 func (c *serviceClient) SwInterfaceIP6SetLinkLocalAddress(ctx context.Context, in *SwInterfaceIP6SetLinkLocalAddress) (*SwInterfaceIP6SetLinkLocalAddressReply, error) {
617 out := new(SwInterfaceIP6SetLinkLocalAddressReply)
618 err := c.conn.Invoke(ctx, in, out)