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 nat44_ed.
15 type RPCService interface {
16 Nat44AddDelAddressRange(ctx context.Context, in *Nat44AddDelAddressRange) (*Nat44AddDelAddressRangeReply, error)
17 Nat44AddDelIdentityMapping(ctx context.Context, in *Nat44AddDelIdentityMapping) (*Nat44AddDelIdentityMappingReply, error)
18 Nat44AddDelInterfaceAddr(ctx context.Context, in *Nat44AddDelInterfaceAddr) (*Nat44AddDelInterfaceAddrReply, error)
19 Nat44AddDelLbStaticMapping(ctx context.Context, in *Nat44AddDelLbStaticMapping) (*Nat44AddDelLbStaticMappingReply, error)
20 Nat44AddDelStaticMapping(ctx context.Context, in *Nat44AddDelStaticMapping) (*Nat44AddDelStaticMappingReply, error)
21 Nat44AddDelStaticMappingV2(ctx context.Context, in *Nat44AddDelStaticMappingV2) (*Nat44AddDelStaticMappingV2Reply, error)
22 Nat44AddressDump(ctx context.Context, in *Nat44AddressDump) (RPCService_Nat44AddressDumpClient, error)
23 Nat44DelSession(ctx context.Context, in *Nat44DelSession) (*Nat44DelSessionReply, error)
24 Nat44DelUser(ctx context.Context, in *Nat44DelUser) (*Nat44DelUserReply, error)
25 Nat44EdAddDelOutputInterface(ctx context.Context, in *Nat44EdAddDelOutputInterface) (*Nat44EdAddDelOutputInterfaceReply, error)
26 Nat44EdOutputInterfaceGet(ctx context.Context, in *Nat44EdOutputInterfaceGet) (RPCService_Nat44EdOutputInterfaceGetClient, error)
27 Nat44EdPluginEnableDisable(ctx context.Context, in *Nat44EdPluginEnableDisable) (*Nat44EdPluginEnableDisableReply, error)
28 Nat44EdSetFqOptions(ctx context.Context, in *Nat44EdSetFqOptions) (*Nat44EdSetFqOptionsReply, error)
29 Nat44EdShowFqOptions(ctx context.Context, in *Nat44EdShowFqOptions) (*Nat44EdShowFqOptionsReply, error)
30 Nat44ForwardingEnableDisable(ctx context.Context, in *Nat44ForwardingEnableDisable) (*Nat44ForwardingEnableDisableReply, error)
31 Nat44ForwardingIsEnabled(ctx context.Context, in *Nat44ForwardingIsEnabled) (*Nat44ForwardingIsEnabledReply, error)
32 Nat44IdentityMappingDump(ctx context.Context, in *Nat44IdentityMappingDump) (RPCService_Nat44IdentityMappingDumpClient, error)
33 Nat44InterfaceAddDelFeature(ctx context.Context, in *Nat44InterfaceAddDelFeature) (*Nat44InterfaceAddDelFeatureReply, error)
34 Nat44InterfaceAddDelOutputFeature(ctx context.Context, in *Nat44InterfaceAddDelOutputFeature) (*Nat44InterfaceAddDelOutputFeatureReply, error)
35 Nat44InterfaceAddrDump(ctx context.Context, in *Nat44InterfaceAddrDump) (RPCService_Nat44InterfaceAddrDumpClient, error)
36 Nat44InterfaceDump(ctx context.Context, in *Nat44InterfaceDump) (RPCService_Nat44InterfaceDumpClient, error)
37 Nat44InterfaceOutputFeatureDump(ctx context.Context, in *Nat44InterfaceOutputFeatureDump) (RPCService_Nat44InterfaceOutputFeatureDumpClient, error)
38 Nat44LbStaticMappingAddDelLocal(ctx context.Context, in *Nat44LbStaticMappingAddDelLocal) (*Nat44LbStaticMappingAddDelLocalReply, error)
39 Nat44LbStaticMappingDump(ctx context.Context, in *Nat44LbStaticMappingDump) (RPCService_Nat44LbStaticMappingDumpClient, error)
40 Nat44PluginEnableDisable(ctx context.Context, in *Nat44PluginEnableDisable) (*Nat44PluginEnableDisableReply, error)
41 Nat44SessionCleanup(ctx context.Context, in *Nat44SessionCleanup) (*Nat44SessionCleanupReply, error)
42 Nat44SetSessionLimit(ctx context.Context, in *Nat44SetSessionLimit) (*Nat44SetSessionLimitReply, error)
43 Nat44ShowRunningConfig(ctx context.Context, in *Nat44ShowRunningConfig) (*Nat44ShowRunningConfigReply, error)
44 Nat44StaticMappingDump(ctx context.Context, in *Nat44StaticMappingDump) (RPCService_Nat44StaticMappingDumpClient, error)
45 Nat44UserDump(ctx context.Context, in *Nat44UserDump) (RPCService_Nat44UserDumpClient, error)
46 Nat44UserSessionDump(ctx context.Context, in *Nat44UserSessionDump) (RPCService_Nat44UserSessionDumpClient, error)
47 Nat44UserSessionV2Dump(ctx context.Context, in *Nat44UserSessionV2Dump) (RPCService_Nat44UserSessionV2DumpClient, error)
48 NatControlPing(ctx context.Context, in *NatControlPing) (*NatControlPingReply, error)
49 NatGetAddrAndPortAllocAlg(ctx context.Context, in *NatGetAddrAndPortAllocAlg) (*NatGetAddrAndPortAllocAlgReply, error)
50 NatGetMssClamping(ctx context.Context, in *NatGetMssClamping) (*NatGetMssClampingReply, error)
51 NatGetTimeouts(ctx context.Context, in *NatGetTimeouts) (*NatGetTimeoutsReply, error)
52 NatHaFlush(ctx context.Context, in *NatHaFlush) (*NatHaFlushReply, error)
53 NatHaGetFailover(ctx context.Context, in *NatHaGetFailover) (*NatHaGetFailoverReply, error)
54 NatHaGetListener(ctx context.Context, in *NatHaGetListener) (*NatHaGetListenerReply, error)
55 NatHaResync(ctx context.Context, in *NatHaResync) (*NatHaResyncReply, error)
56 NatHaSetFailover(ctx context.Context, in *NatHaSetFailover) (*NatHaSetFailoverReply, error)
57 NatHaSetListener(ctx context.Context, in *NatHaSetListener) (*NatHaSetListenerReply, error)
58 NatIpfixEnableDisable(ctx context.Context, in *NatIpfixEnableDisable) (*NatIpfixEnableDisableReply, error)
59 NatSetAddrAndPortAllocAlg(ctx context.Context, in *NatSetAddrAndPortAllocAlg) (*NatSetAddrAndPortAllocAlgReply, error)
60 NatSetLogLevel(ctx context.Context, in *NatSetLogLevel) (*NatSetLogLevelReply, error)
61 NatSetMssClamping(ctx context.Context, in *NatSetMssClamping) (*NatSetMssClampingReply, error)
62 NatSetTimeouts(ctx context.Context, in *NatSetTimeouts) (*NatSetTimeoutsReply, error)
63 NatSetWorkers(ctx context.Context, in *NatSetWorkers) (*NatSetWorkersReply, error)
64 NatShowConfig(ctx context.Context, in *NatShowConfig) (*NatShowConfigReply, error)
65 NatShowConfig2(ctx context.Context, in *NatShowConfig2) (*NatShowConfig2Reply, error)
66 NatWorkerDump(ctx context.Context, in *NatWorkerDump) (RPCService_NatWorkerDumpClient, error)
69 type serviceClient struct {
73 func NewServiceClient(conn api.Connection) RPCService {
74 return &serviceClient{conn}
77 func (c *serviceClient) Nat44AddDelAddressRange(ctx context.Context, in *Nat44AddDelAddressRange) (*Nat44AddDelAddressRangeReply, error) {
78 out := new(Nat44AddDelAddressRangeReply)
79 err := c.conn.Invoke(ctx, in, out)
83 return out, api.RetvalToVPPApiError(out.Retval)
86 func (c *serviceClient) Nat44AddDelIdentityMapping(ctx context.Context, in *Nat44AddDelIdentityMapping) (*Nat44AddDelIdentityMappingReply, error) {
87 out := new(Nat44AddDelIdentityMappingReply)
88 err := c.conn.Invoke(ctx, in, out)
92 return out, api.RetvalToVPPApiError(out.Retval)
95 func (c *serviceClient) Nat44AddDelInterfaceAddr(ctx context.Context, in *Nat44AddDelInterfaceAddr) (*Nat44AddDelInterfaceAddrReply, error) {
96 out := new(Nat44AddDelInterfaceAddrReply)
97 err := c.conn.Invoke(ctx, in, out)
101 return out, api.RetvalToVPPApiError(out.Retval)
104 func (c *serviceClient) Nat44AddDelLbStaticMapping(ctx context.Context, in *Nat44AddDelLbStaticMapping) (*Nat44AddDelLbStaticMappingReply, error) {
105 out := new(Nat44AddDelLbStaticMappingReply)
106 err := c.conn.Invoke(ctx, in, out)
110 return out, api.RetvalToVPPApiError(out.Retval)
113 func (c *serviceClient) Nat44AddDelStaticMapping(ctx context.Context, in *Nat44AddDelStaticMapping) (*Nat44AddDelStaticMappingReply, error) {
114 out := new(Nat44AddDelStaticMappingReply)
115 err := c.conn.Invoke(ctx, in, out)
119 return out, api.RetvalToVPPApiError(out.Retval)
122 func (c *serviceClient) Nat44AddDelStaticMappingV2(ctx context.Context, in *Nat44AddDelStaticMappingV2) (*Nat44AddDelStaticMappingV2Reply, error) {
123 out := new(Nat44AddDelStaticMappingV2Reply)
124 err := c.conn.Invoke(ctx, in, out)
128 return out, api.RetvalToVPPApiError(out.Retval)
131 func (c *serviceClient) Nat44AddressDump(ctx context.Context, in *Nat44AddressDump) (RPCService_Nat44AddressDumpClient, error) {
132 stream, err := c.conn.NewStream(ctx)
136 x := &serviceClient_Nat44AddressDumpClient{stream}
137 if err := x.Stream.SendMsg(in); err != nil {
140 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
146 type RPCService_Nat44AddressDumpClient interface {
147 Recv() (*Nat44AddressDetails, error)
151 type serviceClient_Nat44AddressDumpClient struct {
155 func (c *serviceClient_Nat44AddressDumpClient) Recv() (*Nat44AddressDetails, error) {
156 msg, err := c.Stream.RecvMsg()
160 switch m := msg.(type) {
161 case *Nat44AddressDetails:
163 case *memclnt.ControlPingReply:
164 err = c.Stream.Close()
170 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
174 func (c *serviceClient) Nat44DelSession(ctx context.Context, in *Nat44DelSession) (*Nat44DelSessionReply, error) {
175 out := new(Nat44DelSessionReply)
176 err := c.conn.Invoke(ctx, in, out)
180 return out, api.RetvalToVPPApiError(out.Retval)
183 func (c *serviceClient) Nat44DelUser(ctx context.Context, in *Nat44DelUser) (*Nat44DelUserReply, error) {
184 out := new(Nat44DelUserReply)
185 err := c.conn.Invoke(ctx, in, out)
189 return out, api.RetvalToVPPApiError(out.Retval)
192 func (c *serviceClient) Nat44EdAddDelOutputInterface(ctx context.Context, in *Nat44EdAddDelOutputInterface) (*Nat44EdAddDelOutputInterfaceReply, error) {
193 out := new(Nat44EdAddDelOutputInterfaceReply)
194 err := c.conn.Invoke(ctx, in, out)
198 return out, api.RetvalToVPPApiError(out.Retval)
201 func (c *serviceClient) Nat44EdOutputInterfaceGet(ctx context.Context, in *Nat44EdOutputInterfaceGet) (RPCService_Nat44EdOutputInterfaceGetClient, error) {
202 stream, err := c.conn.NewStream(ctx)
206 x := &serviceClient_Nat44EdOutputInterfaceGetClient{stream}
207 if err := x.Stream.SendMsg(in); err != nil {
213 type RPCService_Nat44EdOutputInterfaceGetClient interface {
214 Recv() (*Nat44EdOutputInterfaceDetails, error)
218 type serviceClient_Nat44EdOutputInterfaceGetClient struct {
222 func (c *serviceClient_Nat44EdOutputInterfaceGetClient) Recv() (*Nat44EdOutputInterfaceDetails, error) {
223 msg, err := c.Stream.RecvMsg()
227 switch m := msg.(type) {
228 case *Nat44EdOutputInterfaceDetails:
230 case *Nat44EdOutputInterfaceGetReply:
231 err = c.Stream.Close()
237 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
241 func (c *serviceClient) Nat44EdPluginEnableDisable(ctx context.Context, in *Nat44EdPluginEnableDisable) (*Nat44EdPluginEnableDisableReply, error) {
242 out := new(Nat44EdPluginEnableDisableReply)
243 err := c.conn.Invoke(ctx, in, out)
247 return out, api.RetvalToVPPApiError(out.Retval)
250 func (c *serviceClient) Nat44EdSetFqOptions(ctx context.Context, in *Nat44EdSetFqOptions) (*Nat44EdSetFqOptionsReply, error) {
251 out := new(Nat44EdSetFqOptionsReply)
252 err := c.conn.Invoke(ctx, in, out)
256 return out, api.RetvalToVPPApiError(out.Retval)
259 func (c *serviceClient) Nat44EdShowFqOptions(ctx context.Context, in *Nat44EdShowFqOptions) (*Nat44EdShowFqOptionsReply, error) {
260 out := new(Nat44EdShowFqOptionsReply)
261 err := c.conn.Invoke(ctx, in, out)
265 return out, api.RetvalToVPPApiError(out.Retval)
268 func (c *serviceClient) Nat44ForwardingEnableDisable(ctx context.Context, in *Nat44ForwardingEnableDisable) (*Nat44ForwardingEnableDisableReply, error) {
269 out := new(Nat44ForwardingEnableDisableReply)
270 err := c.conn.Invoke(ctx, in, out)
274 return out, api.RetvalToVPPApiError(out.Retval)
277 func (c *serviceClient) Nat44ForwardingIsEnabled(ctx context.Context, in *Nat44ForwardingIsEnabled) (*Nat44ForwardingIsEnabledReply, error) {
278 out := new(Nat44ForwardingIsEnabledReply)
279 err := c.conn.Invoke(ctx, in, out)
286 func (c *serviceClient) Nat44IdentityMappingDump(ctx context.Context, in *Nat44IdentityMappingDump) (RPCService_Nat44IdentityMappingDumpClient, error) {
287 stream, err := c.conn.NewStream(ctx)
291 x := &serviceClient_Nat44IdentityMappingDumpClient{stream}
292 if err := x.Stream.SendMsg(in); err != nil {
295 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
301 type RPCService_Nat44IdentityMappingDumpClient interface {
302 Recv() (*Nat44IdentityMappingDetails, error)
306 type serviceClient_Nat44IdentityMappingDumpClient struct {
310 func (c *serviceClient_Nat44IdentityMappingDumpClient) Recv() (*Nat44IdentityMappingDetails, error) {
311 msg, err := c.Stream.RecvMsg()
315 switch m := msg.(type) {
316 case *Nat44IdentityMappingDetails:
318 case *memclnt.ControlPingReply:
319 err = c.Stream.Close()
325 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
329 func (c *serviceClient) Nat44InterfaceAddDelFeature(ctx context.Context, in *Nat44InterfaceAddDelFeature) (*Nat44InterfaceAddDelFeatureReply, error) {
330 out := new(Nat44InterfaceAddDelFeatureReply)
331 err := c.conn.Invoke(ctx, in, out)
335 return out, api.RetvalToVPPApiError(out.Retval)
338 func (c *serviceClient) Nat44InterfaceAddDelOutputFeature(ctx context.Context, in *Nat44InterfaceAddDelOutputFeature) (*Nat44InterfaceAddDelOutputFeatureReply, error) {
339 out := new(Nat44InterfaceAddDelOutputFeatureReply)
340 err := c.conn.Invoke(ctx, in, out)
344 return out, api.RetvalToVPPApiError(out.Retval)
347 func (c *serviceClient) Nat44InterfaceAddrDump(ctx context.Context, in *Nat44InterfaceAddrDump) (RPCService_Nat44InterfaceAddrDumpClient, error) {
348 stream, err := c.conn.NewStream(ctx)
352 x := &serviceClient_Nat44InterfaceAddrDumpClient{stream}
353 if err := x.Stream.SendMsg(in); err != nil {
356 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
362 type RPCService_Nat44InterfaceAddrDumpClient interface {
363 Recv() (*Nat44InterfaceAddrDetails, error)
367 type serviceClient_Nat44InterfaceAddrDumpClient struct {
371 func (c *serviceClient_Nat44InterfaceAddrDumpClient) Recv() (*Nat44InterfaceAddrDetails, error) {
372 msg, err := c.Stream.RecvMsg()
376 switch m := msg.(type) {
377 case *Nat44InterfaceAddrDetails:
379 case *memclnt.ControlPingReply:
380 err = c.Stream.Close()
386 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
390 func (c *serviceClient) Nat44InterfaceDump(ctx context.Context, in *Nat44InterfaceDump) (RPCService_Nat44InterfaceDumpClient, error) {
391 stream, err := c.conn.NewStream(ctx)
395 x := &serviceClient_Nat44InterfaceDumpClient{stream}
396 if err := x.Stream.SendMsg(in); err != nil {
399 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
405 type RPCService_Nat44InterfaceDumpClient interface {
406 Recv() (*Nat44InterfaceDetails, error)
410 type serviceClient_Nat44InterfaceDumpClient struct {
414 func (c *serviceClient_Nat44InterfaceDumpClient) Recv() (*Nat44InterfaceDetails, error) {
415 msg, err := c.Stream.RecvMsg()
419 switch m := msg.(type) {
420 case *Nat44InterfaceDetails:
422 case *memclnt.ControlPingReply:
423 err = c.Stream.Close()
429 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
433 func (c *serviceClient) Nat44InterfaceOutputFeatureDump(ctx context.Context, in *Nat44InterfaceOutputFeatureDump) (RPCService_Nat44InterfaceOutputFeatureDumpClient, error) {
434 stream, err := c.conn.NewStream(ctx)
438 x := &serviceClient_Nat44InterfaceOutputFeatureDumpClient{stream}
439 if err := x.Stream.SendMsg(in); err != nil {
442 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
448 type RPCService_Nat44InterfaceOutputFeatureDumpClient interface {
449 Recv() (*Nat44InterfaceOutputFeatureDetails, error)
453 type serviceClient_Nat44InterfaceOutputFeatureDumpClient struct {
457 func (c *serviceClient_Nat44InterfaceOutputFeatureDumpClient) Recv() (*Nat44InterfaceOutputFeatureDetails, error) {
458 msg, err := c.Stream.RecvMsg()
462 switch m := msg.(type) {
463 case *Nat44InterfaceOutputFeatureDetails:
465 case *memclnt.ControlPingReply:
466 err = c.Stream.Close()
472 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
476 func (c *serviceClient) Nat44LbStaticMappingAddDelLocal(ctx context.Context, in *Nat44LbStaticMappingAddDelLocal) (*Nat44LbStaticMappingAddDelLocalReply, error) {
477 out := new(Nat44LbStaticMappingAddDelLocalReply)
478 err := c.conn.Invoke(ctx, in, out)
482 return out, api.RetvalToVPPApiError(out.Retval)
485 func (c *serviceClient) Nat44LbStaticMappingDump(ctx context.Context, in *Nat44LbStaticMappingDump) (RPCService_Nat44LbStaticMappingDumpClient, error) {
486 stream, err := c.conn.NewStream(ctx)
490 x := &serviceClient_Nat44LbStaticMappingDumpClient{stream}
491 if err := x.Stream.SendMsg(in); err != nil {
494 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
500 type RPCService_Nat44LbStaticMappingDumpClient interface {
501 Recv() (*Nat44LbStaticMappingDetails, error)
505 type serviceClient_Nat44LbStaticMappingDumpClient struct {
509 func (c *serviceClient_Nat44LbStaticMappingDumpClient) Recv() (*Nat44LbStaticMappingDetails, error) {
510 msg, err := c.Stream.RecvMsg()
514 switch m := msg.(type) {
515 case *Nat44LbStaticMappingDetails:
517 case *memclnt.ControlPingReply:
518 err = c.Stream.Close()
524 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
528 func (c *serviceClient) Nat44PluginEnableDisable(ctx context.Context, in *Nat44PluginEnableDisable) (*Nat44PluginEnableDisableReply, error) {
529 out := new(Nat44PluginEnableDisableReply)
530 err := c.conn.Invoke(ctx, in, out)
534 return out, api.RetvalToVPPApiError(out.Retval)
537 func (c *serviceClient) Nat44SessionCleanup(ctx context.Context, in *Nat44SessionCleanup) (*Nat44SessionCleanupReply, error) {
538 out := new(Nat44SessionCleanupReply)
539 err := c.conn.Invoke(ctx, in, out)
543 return out, api.RetvalToVPPApiError(out.Retval)
546 func (c *serviceClient) Nat44SetSessionLimit(ctx context.Context, in *Nat44SetSessionLimit) (*Nat44SetSessionLimitReply, error) {
547 out := new(Nat44SetSessionLimitReply)
548 err := c.conn.Invoke(ctx, in, out)
552 return out, api.RetvalToVPPApiError(out.Retval)
555 func (c *serviceClient) Nat44ShowRunningConfig(ctx context.Context, in *Nat44ShowRunningConfig) (*Nat44ShowRunningConfigReply, error) {
556 out := new(Nat44ShowRunningConfigReply)
557 err := c.conn.Invoke(ctx, in, out)
561 return out, api.RetvalToVPPApiError(out.Retval)
564 func (c *serviceClient) Nat44StaticMappingDump(ctx context.Context, in *Nat44StaticMappingDump) (RPCService_Nat44StaticMappingDumpClient, error) {
565 stream, err := c.conn.NewStream(ctx)
569 x := &serviceClient_Nat44StaticMappingDumpClient{stream}
570 if err := x.Stream.SendMsg(in); err != nil {
573 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
579 type RPCService_Nat44StaticMappingDumpClient interface {
580 Recv() (*Nat44StaticMappingDetails, error)
584 type serviceClient_Nat44StaticMappingDumpClient struct {
588 func (c *serviceClient_Nat44StaticMappingDumpClient) Recv() (*Nat44StaticMappingDetails, error) {
589 msg, err := c.Stream.RecvMsg()
593 switch m := msg.(type) {
594 case *Nat44StaticMappingDetails:
596 case *memclnt.ControlPingReply:
597 err = c.Stream.Close()
603 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
607 func (c *serviceClient) Nat44UserDump(ctx context.Context, in *Nat44UserDump) (RPCService_Nat44UserDumpClient, error) {
608 stream, err := c.conn.NewStream(ctx)
612 x := &serviceClient_Nat44UserDumpClient{stream}
613 if err := x.Stream.SendMsg(in); err != nil {
616 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
622 type RPCService_Nat44UserDumpClient interface {
623 Recv() (*Nat44UserDetails, error)
627 type serviceClient_Nat44UserDumpClient struct {
631 func (c *serviceClient_Nat44UserDumpClient) Recv() (*Nat44UserDetails, error) {
632 msg, err := c.Stream.RecvMsg()
636 switch m := msg.(type) {
637 case *Nat44UserDetails:
639 case *memclnt.ControlPingReply:
640 err = c.Stream.Close()
646 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
650 func (c *serviceClient) Nat44UserSessionDump(ctx context.Context, in *Nat44UserSessionDump) (RPCService_Nat44UserSessionDumpClient, error) {
651 stream, err := c.conn.NewStream(ctx)
655 x := &serviceClient_Nat44UserSessionDumpClient{stream}
656 if err := x.Stream.SendMsg(in); err != nil {
659 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
665 type RPCService_Nat44UserSessionDumpClient interface {
666 Recv() (*Nat44UserSessionDetails, error)
670 type serviceClient_Nat44UserSessionDumpClient struct {
674 func (c *serviceClient_Nat44UserSessionDumpClient) Recv() (*Nat44UserSessionDetails, error) {
675 msg, err := c.Stream.RecvMsg()
679 switch m := msg.(type) {
680 case *Nat44UserSessionDetails:
682 case *memclnt.ControlPingReply:
683 err = c.Stream.Close()
689 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
693 func (c *serviceClient) Nat44UserSessionV2Dump(ctx context.Context, in *Nat44UserSessionV2Dump) (RPCService_Nat44UserSessionV2DumpClient, error) {
694 stream, err := c.conn.NewStream(ctx)
698 x := &serviceClient_Nat44UserSessionV2DumpClient{stream}
699 if err := x.Stream.SendMsg(in); err != nil {
702 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
708 type RPCService_Nat44UserSessionV2DumpClient interface {
709 Recv() (*Nat44UserSessionV2Details, error)
713 type serviceClient_Nat44UserSessionV2DumpClient struct {
717 func (c *serviceClient_Nat44UserSessionV2DumpClient) Recv() (*Nat44UserSessionV2Details, error) {
718 msg, err := c.Stream.RecvMsg()
722 switch m := msg.(type) {
723 case *Nat44UserSessionV2Details:
725 case *memclnt.ControlPingReply:
726 err = c.Stream.Close()
732 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
736 func (c *serviceClient) NatControlPing(ctx context.Context, in *NatControlPing) (*NatControlPingReply, error) {
737 out := new(NatControlPingReply)
738 err := c.conn.Invoke(ctx, in, out)
742 return out, api.RetvalToVPPApiError(out.Retval)
745 func (c *serviceClient) NatGetAddrAndPortAllocAlg(ctx context.Context, in *NatGetAddrAndPortAllocAlg) (*NatGetAddrAndPortAllocAlgReply, error) {
746 out := new(NatGetAddrAndPortAllocAlgReply)
747 err := c.conn.Invoke(ctx, in, out)
751 return out, api.RetvalToVPPApiError(out.Retval)
754 func (c *serviceClient) NatGetMssClamping(ctx context.Context, in *NatGetMssClamping) (*NatGetMssClampingReply, error) {
755 out := new(NatGetMssClampingReply)
756 err := c.conn.Invoke(ctx, in, out)
760 return out, api.RetvalToVPPApiError(out.Retval)
763 func (c *serviceClient) NatGetTimeouts(ctx context.Context, in *NatGetTimeouts) (*NatGetTimeoutsReply, error) {
764 out := new(NatGetTimeoutsReply)
765 err := c.conn.Invoke(ctx, in, out)
769 return out, api.RetvalToVPPApiError(out.Retval)
772 func (c *serviceClient) NatHaFlush(ctx context.Context, in *NatHaFlush) (*NatHaFlushReply, error) {
773 out := new(NatHaFlushReply)
774 err := c.conn.Invoke(ctx, in, out)
778 return out, api.RetvalToVPPApiError(out.Retval)
781 func (c *serviceClient) NatHaGetFailover(ctx context.Context, in *NatHaGetFailover) (*NatHaGetFailoverReply, error) {
782 out := new(NatHaGetFailoverReply)
783 err := c.conn.Invoke(ctx, in, out)
787 return out, api.RetvalToVPPApiError(out.Retval)
790 func (c *serviceClient) NatHaGetListener(ctx context.Context, in *NatHaGetListener) (*NatHaGetListenerReply, error) {
791 out := new(NatHaGetListenerReply)
792 err := c.conn.Invoke(ctx, in, out)
796 return out, api.RetvalToVPPApiError(out.Retval)
799 func (c *serviceClient) NatHaResync(ctx context.Context, in *NatHaResync) (*NatHaResyncReply, error) {
800 out := new(NatHaResyncReply)
801 err := c.conn.Invoke(ctx, in, out)
805 return out, api.RetvalToVPPApiError(out.Retval)
808 func (c *serviceClient) NatHaSetFailover(ctx context.Context, in *NatHaSetFailover) (*NatHaSetFailoverReply, error) {
809 out := new(NatHaSetFailoverReply)
810 err := c.conn.Invoke(ctx, in, out)
814 return out, api.RetvalToVPPApiError(out.Retval)
817 func (c *serviceClient) NatHaSetListener(ctx context.Context, in *NatHaSetListener) (*NatHaSetListenerReply, error) {
818 out := new(NatHaSetListenerReply)
819 err := c.conn.Invoke(ctx, in, out)
823 return out, api.RetvalToVPPApiError(out.Retval)
826 func (c *serviceClient) NatIpfixEnableDisable(ctx context.Context, in *NatIpfixEnableDisable) (*NatIpfixEnableDisableReply, error) {
827 out := new(NatIpfixEnableDisableReply)
828 err := c.conn.Invoke(ctx, in, out)
832 return out, api.RetvalToVPPApiError(out.Retval)
835 func (c *serviceClient) NatSetAddrAndPortAllocAlg(ctx context.Context, in *NatSetAddrAndPortAllocAlg) (*NatSetAddrAndPortAllocAlgReply, error) {
836 out := new(NatSetAddrAndPortAllocAlgReply)
837 err := c.conn.Invoke(ctx, in, out)
841 return out, api.RetvalToVPPApiError(out.Retval)
844 func (c *serviceClient) NatSetLogLevel(ctx context.Context, in *NatSetLogLevel) (*NatSetLogLevelReply, error) {
845 out := new(NatSetLogLevelReply)
846 err := c.conn.Invoke(ctx, in, out)
850 return out, api.RetvalToVPPApiError(out.Retval)
853 func (c *serviceClient) NatSetMssClamping(ctx context.Context, in *NatSetMssClamping) (*NatSetMssClampingReply, error) {
854 out := new(NatSetMssClampingReply)
855 err := c.conn.Invoke(ctx, in, out)
859 return out, api.RetvalToVPPApiError(out.Retval)
862 func (c *serviceClient) NatSetTimeouts(ctx context.Context, in *NatSetTimeouts) (*NatSetTimeoutsReply, error) {
863 out := new(NatSetTimeoutsReply)
864 err := c.conn.Invoke(ctx, in, out)
868 return out, api.RetvalToVPPApiError(out.Retval)
871 func (c *serviceClient) NatSetWorkers(ctx context.Context, in *NatSetWorkers) (*NatSetWorkersReply, error) {
872 out := new(NatSetWorkersReply)
873 err := c.conn.Invoke(ctx, in, out)
877 return out, api.RetvalToVPPApiError(out.Retval)
880 func (c *serviceClient) NatShowConfig(ctx context.Context, in *NatShowConfig) (*NatShowConfigReply, error) {
881 out := new(NatShowConfigReply)
882 err := c.conn.Invoke(ctx, in, out)
886 return out, api.RetvalToVPPApiError(out.Retval)
889 func (c *serviceClient) NatShowConfig2(ctx context.Context, in *NatShowConfig2) (*NatShowConfig2Reply, error) {
890 out := new(NatShowConfig2Reply)
891 err := c.conn.Invoke(ctx, in, out)
895 return out, api.RetvalToVPPApiError(out.Retval)
898 func (c *serviceClient) NatWorkerDump(ctx context.Context, in *NatWorkerDump) (RPCService_NatWorkerDumpClient, error) {
899 stream, err := c.conn.NewStream(ctx)
903 x := &serviceClient_NatWorkerDumpClient{stream}
904 if err := x.Stream.SendMsg(in); err != nil {
907 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
913 type RPCService_NatWorkerDumpClient interface {
914 Recv() (*NatWorkerDetails, error)
918 type serviceClient_NatWorkerDumpClient struct {
922 func (c *serviceClient_NatWorkerDumpClient) Recv() (*NatWorkerDetails, error) {
923 msg, err := c.Stream.RecvMsg()
927 switch m := msg.(type) {
928 case *NatWorkerDetails:
930 case *memclnt.ControlPingReply:
931 err = c.Stream.Close()
937 return nil, fmt.Errorf("unexpected message: %T %v", m, m)