1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 memclnt "git.fd.io/govpp.git/binapi/memclnt"
14 // RPCService defines RPC service nat44_ei.
15 type RPCService interface {
16 Nat44EiAddDelAddressRange(ctx context.Context, in *Nat44EiAddDelAddressRange) (*Nat44EiAddDelAddressRangeReply, error)
17 Nat44EiAddDelIdentityMapping(ctx context.Context, in *Nat44EiAddDelIdentityMapping) (*Nat44EiAddDelIdentityMappingReply, error)
18 Nat44EiAddDelInterfaceAddr(ctx context.Context, in *Nat44EiAddDelInterfaceAddr) (*Nat44EiAddDelInterfaceAddrReply, error)
19 Nat44EiAddDelOutputInterface(ctx context.Context, in *Nat44EiAddDelOutputInterface) (*Nat44EiAddDelOutputInterfaceReply, error)
20 Nat44EiAddDelStaticMapping(ctx context.Context, in *Nat44EiAddDelStaticMapping) (*Nat44EiAddDelStaticMappingReply, error)
21 Nat44EiAddressDump(ctx context.Context, in *Nat44EiAddressDump) (RPCService_Nat44EiAddressDumpClient, error)
22 Nat44EiDelSession(ctx context.Context, in *Nat44EiDelSession) (*Nat44EiDelSessionReply, error)
23 Nat44EiDelUser(ctx context.Context, in *Nat44EiDelUser) (*Nat44EiDelUserReply, error)
24 Nat44EiForwardingEnableDisable(ctx context.Context, in *Nat44EiForwardingEnableDisable) (*Nat44EiForwardingEnableDisableReply, error)
25 Nat44EiGetAddrAndPortAllocAlg(ctx context.Context, in *Nat44EiGetAddrAndPortAllocAlg) (*Nat44EiGetAddrAndPortAllocAlgReply, error)
26 Nat44EiGetMssClamping(ctx context.Context, in *Nat44EiGetMssClamping) (*Nat44EiGetMssClampingReply, error)
27 Nat44EiHaFlush(ctx context.Context, in *Nat44EiHaFlush) (*Nat44EiHaFlushReply, error)
28 Nat44EiHaGetFailover(ctx context.Context, in *Nat44EiHaGetFailover) (*Nat44EiHaGetFailoverReply, error)
29 Nat44EiHaGetListener(ctx context.Context, in *Nat44EiHaGetListener) (*Nat44EiHaGetListenerReply, error)
30 Nat44EiHaResync(ctx context.Context, in *Nat44EiHaResync) (*Nat44EiHaResyncReply, error)
31 Nat44EiHaSetFailover(ctx context.Context, in *Nat44EiHaSetFailover) (*Nat44EiHaSetFailoverReply, error)
32 Nat44EiHaSetListener(ctx context.Context, in *Nat44EiHaSetListener) (*Nat44EiHaSetListenerReply, error)
33 Nat44EiIdentityMappingDump(ctx context.Context, in *Nat44EiIdentityMappingDump) (RPCService_Nat44EiIdentityMappingDumpClient, error)
34 Nat44EiInterfaceAddDelFeature(ctx context.Context, in *Nat44EiInterfaceAddDelFeature) (*Nat44EiInterfaceAddDelFeatureReply, error)
35 Nat44EiInterfaceAddDelOutputFeature(ctx context.Context, in *Nat44EiInterfaceAddDelOutputFeature) (*Nat44EiInterfaceAddDelOutputFeatureReply, error)
36 Nat44EiInterfaceAddrDump(ctx context.Context, in *Nat44EiInterfaceAddrDump) (RPCService_Nat44EiInterfaceAddrDumpClient, error)
37 Nat44EiInterfaceDump(ctx context.Context, in *Nat44EiInterfaceDump) (RPCService_Nat44EiInterfaceDumpClient, error)
38 Nat44EiInterfaceOutputFeatureDump(ctx context.Context, in *Nat44EiInterfaceOutputFeatureDump) (RPCService_Nat44EiInterfaceOutputFeatureDumpClient, error)
39 Nat44EiIpfixEnableDisable(ctx context.Context, in *Nat44EiIpfixEnableDisable) (*Nat44EiIpfixEnableDisableReply, error)
40 Nat44EiOutputInterfaceGet(ctx context.Context, in *Nat44EiOutputInterfaceGet) (RPCService_Nat44EiOutputInterfaceGetClient, error)
41 Nat44EiPluginEnableDisable(ctx context.Context, in *Nat44EiPluginEnableDisable) (*Nat44EiPluginEnableDisableReply, error)
42 Nat44EiSetAddrAndPortAllocAlg(ctx context.Context, in *Nat44EiSetAddrAndPortAllocAlg) (*Nat44EiSetAddrAndPortAllocAlgReply, error)
43 Nat44EiSetFqOptions(ctx context.Context, in *Nat44EiSetFqOptions) (*Nat44EiSetFqOptionsReply, error)
44 Nat44EiSetLogLevel(ctx context.Context, in *Nat44EiSetLogLevel) (*Nat44EiSetLogLevelReply, error)
45 Nat44EiSetMssClamping(ctx context.Context, in *Nat44EiSetMssClamping) (*Nat44EiSetMssClampingReply, error)
46 Nat44EiSetTimeouts(ctx context.Context, in *Nat44EiSetTimeouts) (*Nat44EiSetTimeoutsReply, error)
47 Nat44EiSetWorkers(ctx context.Context, in *Nat44EiSetWorkers) (*Nat44EiSetWorkersReply, error)
48 Nat44EiShowFqOptions(ctx context.Context, in *Nat44EiShowFqOptions) (*Nat44EiShowFqOptionsReply, error)
49 Nat44EiShowRunningConfig(ctx context.Context, in *Nat44EiShowRunningConfig) (*Nat44EiShowRunningConfigReply, error)
50 Nat44EiStaticMappingDump(ctx context.Context, in *Nat44EiStaticMappingDump) (RPCService_Nat44EiStaticMappingDumpClient, error)
51 Nat44EiUserDump(ctx context.Context, in *Nat44EiUserDump) (RPCService_Nat44EiUserDumpClient, error)
52 Nat44EiUserSessionDump(ctx context.Context, in *Nat44EiUserSessionDump) (RPCService_Nat44EiUserSessionDumpClient, error)
53 Nat44EiWorkerDump(ctx context.Context, in *Nat44EiWorkerDump) (RPCService_Nat44EiWorkerDumpClient, error)
56 type serviceClient struct {
60 func NewServiceClient(conn api.Connection) RPCService {
61 return &serviceClient{conn}
64 func (c *serviceClient) Nat44EiAddDelAddressRange(ctx context.Context, in *Nat44EiAddDelAddressRange) (*Nat44EiAddDelAddressRangeReply, error) {
65 out := new(Nat44EiAddDelAddressRangeReply)
66 err := c.conn.Invoke(ctx, in, out)
70 return out, api.RetvalToVPPApiError(out.Retval)
73 func (c *serviceClient) Nat44EiAddDelIdentityMapping(ctx context.Context, in *Nat44EiAddDelIdentityMapping) (*Nat44EiAddDelIdentityMappingReply, error) {
74 out := new(Nat44EiAddDelIdentityMappingReply)
75 err := c.conn.Invoke(ctx, in, out)
79 return out, api.RetvalToVPPApiError(out.Retval)
82 func (c *serviceClient) Nat44EiAddDelInterfaceAddr(ctx context.Context, in *Nat44EiAddDelInterfaceAddr) (*Nat44EiAddDelInterfaceAddrReply, error) {
83 out := new(Nat44EiAddDelInterfaceAddrReply)
84 err := c.conn.Invoke(ctx, in, out)
88 return out, api.RetvalToVPPApiError(out.Retval)
91 func (c *serviceClient) Nat44EiAddDelOutputInterface(ctx context.Context, in *Nat44EiAddDelOutputInterface) (*Nat44EiAddDelOutputInterfaceReply, error) {
92 out := new(Nat44EiAddDelOutputInterfaceReply)
93 err := c.conn.Invoke(ctx, in, out)
97 return out, api.RetvalToVPPApiError(out.Retval)
100 func (c *serviceClient) Nat44EiAddDelStaticMapping(ctx context.Context, in *Nat44EiAddDelStaticMapping) (*Nat44EiAddDelStaticMappingReply, error) {
101 out := new(Nat44EiAddDelStaticMappingReply)
102 err := c.conn.Invoke(ctx, in, out)
106 return out, api.RetvalToVPPApiError(out.Retval)
109 func (c *serviceClient) Nat44EiAddressDump(ctx context.Context, in *Nat44EiAddressDump) (RPCService_Nat44EiAddressDumpClient, error) {
110 stream, err := c.conn.NewStream(ctx)
114 x := &serviceClient_Nat44EiAddressDumpClient{stream}
115 if err := x.Stream.SendMsg(in); err != nil {
118 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
124 type RPCService_Nat44EiAddressDumpClient interface {
125 Recv() (*Nat44EiAddressDetails, error)
129 type serviceClient_Nat44EiAddressDumpClient struct {
133 func (c *serviceClient_Nat44EiAddressDumpClient) Recv() (*Nat44EiAddressDetails, error) {
134 msg, err := c.Stream.RecvMsg()
138 switch m := msg.(type) {
139 case *Nat44EiAddressDetails:
141 case *memclnt.ControlPingReply:
142 err = c.Stream.Close()
148 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
152 func (c *serviceClient) Nat44EiDelSession(ctx context.Context, in *Nat44EiDelSession) (*Nat44EiDelSessionReply, error) {
153 out := new(Nat44EiDelSessionReply)
154 err := c.conn.Invoke(ctx, in, out)
158 return out, api.RetvalToVPPApiError(out.Retval)
161 func (c *serviceClient) Nat44EiDelUser(ctx context.Context, in *Nat44EiDelUser) (*Nat44EiDelUserReply, error) {
162 out := new(Nat44EiDelUserReply)
163 err := c.conn.Invoke(ctx, in, out)
167 return out, api.RetvalToVPPApiError(out.Retval)
170 func (c *serviceClient) Nat44EiForwardingEnableDisable(ctx context.Context, in *Nat44EiForwardingEnableDisable) (*Nat44EiForwardingEnableDisableReply, error) {
171 out := new(Nat44EiForwardingEnableDisableReply)
172 err := c.conn.Invoke(ctx, in, out)
176 return out, api.RetvalToVPPApiError(out.Retval)
179 func (c *serviceClient) Nat44EiGetAddrAndPortAllocAlg(ctx context.Context, in *Nat44EiGetAddrAndPortAllocAlg) (*Nat44EiGetAddrAndPortAllocAlgReply, error) {
180 out := new(Nat44EiGetAddrAndPortAllocAlgReply)
181 err := c.conn.Invoke(ctx, in, out)
185 return out, api.RetvalToVPPApiError(out.Retval)
188 func (c *serviceClient) Nat44EiGetMssClamping(ctx context.Context, in *Nat44EiGetMssClamping) (*Nat44EiGetMssClampingReply, error) {
189 out := new(Nat44EiGetMssClampingReply)
190 err := c.conn.Invoke(ctx, in, out)
194 return out, api.RetvalToVPPApiError(out.Retval)
197 func (c *serviceClient) Nat44EiHaFlush(ctx context.Context, in *Nat44EiHaFlush) (*Nat44EiHaFlushReply, error) {
198 out := new(Nat44EiHaFlushReply)
199 err := c.conn.Invoke(ctx, in, out)
203 return out, api.RetvalToVPPApiError(out.Retval)
206 func (c *serviceClient) Nat44EiHaGetFailover(ctx context.Context, in *Nat44EiHaGetFailover) (*Nat44EiHaGetFailoverReply, error) {
207 out := new(Nat44EiHaGetFailoverReply)
208 err := c.conn.Invoke(ctx, in, out)
212 return out, api.RetvalToVPPApiError(out.Retval)
215 func (c *serviceClient) Nat44EiHaGetListener(ctx context.Context, in *Nat44EiHaGetListener) (*Nat44EiHaGetListenerReply, error) {
216 out := new(Nat44EiHaGetListenerReply)
217 err := c.conn.Invoke(ctx, in, out)
221 return out, api.RetvalToVPPApiError(out.Retval)
224 func (c *serviceClient) Nat44EiHaResync(ctx context.Context, in *Nat44EiHaResync) (*Nat44EiHaResyncReply, error) {
225 out := new(Nat44EiHaResyncReply)
226 err := c.conn.Invoke(ctx, in, out)
230 return out, api.RetvalToVPPApiError(out.Retval)
233 func (c *serviceClient) Nat44EiHaSetFailover(ctx context.Context, in *Nat44EiHaSetFailover) (*Nat44EiHaSetFailoverReply, error) {
234 out := new(Nat44EiHaSetFailoverReply)
235 err := c.conn.Invoke(ctx, in, out)
239 return out, api.RetvalToVPPApiError(out.Retval)
242 func (c *serviceClient) Nat44EiHaSetListener(ctx context.Context, in *Nat44EiHaSetListener) (*Nat44EiHaSetListenerReply, error) {
243 out := new(Nat44EiHaSetListenerReply)
244 err := c.conn.Invoke(ctx, in, out)
248 return out, api.RetvalToVPPApiError(out.Retval)
251 func (c *serviceClient) Nat44EiIdentityMappingDump(ctx context.Context, in *Nat44EiIdentityMappingDump) (RPCService_Nat44EiIdentityMappingDumpClient, error) {
252 stream, err := c.conn.NewStream(ctx)
256 x := &serviceClient_Nat44EiIdentityMappingDumpClient{stream}
257 if err := x.Stream.SendMsg(in); err != nil {
260 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
266 type RPCService_Nat44EiIdentityMappingDumpClient interface {
267 Recv() (*Nat44EiIdentityMappingDetails, error)
271 type serviceClient_Nat44EiIdentityMappingDumpClient struct {
275 func (c *serviceClient_Nat44EiIdentityMappingDumpClient) Recv() (*Nat44EiIdentityMappingDetails, error) {
276 msg, err := c.Stream.RecvMsg()
280 switch m := msg.(type) {
281 case *Nat44EiIdentityMappingDetails:
283 case *memclnt.ControlPingReply:
284 err = c.Stream.Close()
290 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
294 func (c *serviceClient) Nat44EiInterfaceAddDelFeature(ctx context.Context, in *Nat44EiInterfaceAddDelFeature) (*Nat44EiInterfaceAddDelFeatureReply, error) {
295 out := new(Nat44EiInterfaceAddDelFeatureReply)
296 err := c.conn.Invoke(ctx, in, out)
300 return out, api.RetvalToVPPApiError(out.Retval)
303 func (c *serviceClient) Nat44EiInterfaceAddDelOutputFeature(ctx context.Context, in *Nat44EiInterfaceAddDelOutputFeature) (*Nat44EiInterfaceAddDelOutputFeatureReply, error) {
304 out := new(Nat44EiInterfaceAddDelOutputFeatureReply)
305 err := c.conn.Invoke(ctx, in, out)
309 return out, api.RetvalToVPPApiError(out.Retval)
312 func (c *serviceClient) Nat44EiInterfaceAddrDump(ctx context.Context, in *Nat44EiInterfaceAddrDump) (RPCService_Nat44EiInterfaceAddrDumpClient, error) {
313 stream, err := c.conn.NewStream(ctx)
317 x := &serviceClient_Nat44EiInterfaceAddrDumpClient{stream}
318 if err := x.Stream.SendMsg(in); err != nil {
321 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
327 type RPCService_Nat44EiInterfaceAddrDumpClient interface {
328 Recv() (*Nat44EiInterfaceAddrDetails, error)
332 type serviceClient_Nat44EiInterfaceAddrDumpClient struct {
336 func (c *serviceClient_Nat44EiInterfaceAddrDumpClient) Recv() (*Nat44EiInterfaceAddrDetails, error) {
337 msg, err := c.Stream.RecvMsg()
341 switch m := msg.(type) {
342 case *Nat44EiInterfaceAddrDetails:
344 case *memclnt.ControlPingReply:
345 err = c.Stream.Close()
351 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
355 func (c *serviceClient) Nat44EiInterfaceDump(ctx context.Context, in *Nat44EiInterfaceDump) (RPCService_Nat44EiInterfaceDumpClient, error) {
356 stream, err := c.conn.NewStream(ctx)
360 x := &serviceClient_Nat44EiInterfaceDumpClient{stream}
361 if err := x.Stream.SendMsg(in); err != nil {
364 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
370 type RPCService_Nat44EiInterfaceDumpClient interface {
371 Recv() (*Nat44EiInterfaceDetails, error)
375 type serviceClient_Nat44EiInterfaceDumpClient struct {
379 func (c *serviceClient_Nat44EiInterfaceDumpClient) Recv() (*Nat44EiInterfaceDetails, error) {
380 msg, err := c.Stream.RecvMsg()
384 switch m := msg.(type) {
385 case *Nat44EiInterfaceDetails:
387 case *memclnt.ControlPingReply:
388 err = c.Stream.Close()
394 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
398 func (c *serviceClient) Nat44EiInterfaceOutputFeatureDump(ctx context.Context, in *Nat44EiInterfaceOutputFeatureDump) (RPCService_Nat44EiInterfaceOutputFeatureDumpClient, error) {
399 stream, err := c.conn.NewStream(ctx)
403 x := &serviceClient_Nat44EiInterfaceOutputFeatureDumpClient{stream}
404 if err := x.Stream.SendMsg(in); err != nil {
407 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
413 type RPCService_Nat44EiInterfaceOutputFeatureDumpClient interface {
414 Recv() (*Nat44EiInterfaceOutputFeatureDetails, error)
418 type serviceClient_Nat44EiInterfaceOutputFeatureDumpClient struct {
422 func (c *serviceClient_Nat44EiInterfaceOutputFeatureDumpClient) Recv() (*Nat44EiInterfaceOutputFeatureDetails, error) {
423 msg, err := c.Stream.RecvMsg()
427 switch m := msg.(type) {
428 case *Nat44EiInterfaceOutputFeatureDetails:
430 case *memclnt.ControlPingReply:
431 err = c.Stream.Close()
437 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
441 func (c *serviceClient) Nat44EiIpfixEnableDisable(ctx context.Context, in *Nat44EiIpfixEnableDisable) (*Nat44EiIpfixEnableDisableReply, error) {
442 out := new(Nat44EiIpfixEnableDisableReply)
443 err := c.conn.Invoke(ctx, in, out)
447 return out, api.RetvalToVPPApiError(out.Retval)
450 func (c *serviceClient) Nat44EiOutputInterfaceGet(ctx context.Context, in *Nat44EiOutputInterfaceGet) (RPCService_Nat44EiOutputInterfaceGetClient, error) {
451 stream, err := c.conn.NewStream(ctx)
455 x := &serviceClient_Nat44EiOutputInterfaceGetClient{stream}
456 if err := x.Stream.SendMsg(in); err != nil {
462 type RPCService_Nat44EiOutputInterfaceGetClient interface {
463 Recv() (*Nat44EiOutputInterfaceDetails, error)
467 type serviceClient_Nat44EiOutputInterfaceGetClient struct {
471 func (c *serviceClient_Nat44EiOutputInterfaceGetClient) Recv() (*Nat44EiOutputInterfaceDetails, error) {
472 msg, err := c.Stream.RecvMsg()
476 switch m := msg.(type) {
477 case *Nat44EiOutputInterfaceDetails:
479 case *Nat44EiOutputInterfaceGetReply:
480 err = c.Stream.Close()
486 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
490 func (c *serviceClient) Nat44EiPluginEnableDisable(ctx context.Context, in *Nat44EiPluginEnableDisable) (*Nat44EiPluginEnableDisableReply, error) {
491 out := new(Nat44EiPluginEnableDisableReply)
492 err := c.conn.Invoke(ctx, in, out)
496 return out, api.RetvalToVPPApiError(out.Retval)
499 func (c *serviceClient) Nat44EiSetAddrAndPortAllocAlg(ctx context.Context, in *Nat44EiSetAddrAndPortAllocAlg) (*Nat44EiSetAddrAndPortAllocAlgReply, error) {
500 out := new(Nat44EiSetAddrAndPortAllocAlgReply)
501 err := c.conn.Invoke(ctx, in, out)
505 return out, api.RetvalToVPPApiError(out.Retval)
508 func (c *serviceClient) Nat44EiSetFqOptions(ctx context.Context, in *Nat44EiSetFqOptions) (*Nat44EiSetFqOptionsReply, error) {
509 out := new(Nat44EiSetFqOptionsReply)
510 err := c.conn.Invoke(ctx, in, out)
514 return out, api.RetvalToVPPApiError(out.Retval)
517 func (c *serviceClient) Nat44EiSetLogLevel(ctx context.Context, in *Nat44EiSetLogLevel) (*Nat44EiSetLogLevelReply, error) {
518 out := new(Nat44EiSetLogLevelReply)
519 err := c.conn.Invoke(ctx, in, out)
523 return out, api.RetvalToVPPApiError(out.Retval)
526 func (c *serviceClient) Nat44EiSetMssClamping(ctx context.Context, in *Nat44EiSetMssClamping) (*Nat44EiSetMssClampingReply, error) {
527 out := new(Nat44EiSetMssClampingReply)
528 err := c.conn.Invoke(ctx, in, out)
532 return out, api.RetvalToVPPApiError(out.Retval)
535 func (c *serviceClient) Nat44EiSetTimeouts(ctx context.Context, in *Nat44EiSetTimeouts) (*Nat44EiSetTimeoutsReply, error) {
536 out := new(Nat44EiSetTimeoutsReply)
537 err := c.conn.Invoke(ctx, in, out)
541 return out, api.RetvalToVPPApiError(out.Retval)
544 func (c *serviceClient) Nat44EiSetWorkers(ctx context.Context, in *Nat44EiSetWorkers) (*Nat44EiSetWorkersReply, error) {
545 out := new(Nat44EiSetWorkersReply)
546 err := c.conn.Invoke(ctx, in, out)
550 return out, api.RetvalToVPPApiError(out.Retval)
553 func (c *serviceClient) Nat44EiShowFqOptions(ctx context.Context, in *Nat44EiShowFqOptions) (*Nat44EiShowFqOptionsReply, error) {
554 out := new(Nat44EiShowFqOptionsReply)
555 err := c.conn.Invoke(ctx, in, out)
559 return out, api.RetvalToVPPApiError(out.Retval)
562 func (c *serviceClient) Nat44EiShowRunningConfig(ctx context.Context, in *Nat44EiShowRunningConfig) (*Nat44EiShowRunningConfigReply, error) {
563 out := new(Nat44EiShowRunningConfigReply)
564 err := c.conn.Invoke(ctx, in, out)
568 return out, api.RetvalToVPPApiError(out.Retval)
571 func (c *serviceClient) Nat44EiStaticMappingDump(ctx context.Context, in *Nat44EiStaticMappingDump) (RPCService_Nat44EiStaticMappingDumpClient, error) {
572 stream, err := c.conn.NewStream(ctx)
576 x := &serviceClient_Nat44EiStaticMappingDumpClient{stream}
577 if err := x.Stream.SendMsg(in); err != nil {
580 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
586 type RPCService_Nat44EiStaticMappingDumpClient interface {
587 Recv() (*Nat44EiStaticMappingDetails, error)
591 type serviceClient_Nat44EiStaticMappingDumpClient struct {
595 func (c *serviceClient_Nat44EiStaticMappingDumpClient) Recv() (*Nat44EiStaticMappingDetails, error) {
596 msg, err := c.Stream.RecvMsg()
600 switch m := msg.(type) {
601 case *Nat44EiStaticMappingDetails:
603 case *memclnt.ControlPingReply:
604 err = c.Stream.Close()
610 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
614 func (c *serviceClient) Nat44EiUserDump(ctx context.Context, in *Nat44EiUserDump) (RPCService_Nat44EiUserDumpClient, error) {
615 stream, err := c.conn.NewStream(ctx)
619 x := &serviceClient_Nat44EiUserDumpClient{stream}
620 if err := x.Stream.SendMsg(in); err != nil {
623 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
629 type RPCService_Nat44EiUserDumpClient interface {
630 Recv() (*Nat44EiUserDetails, error)
634 type serviceClient_Nat44EiUserDumpClient struct {
638 func (c *serviceClient_Nat44EiUserDumpClient) Recv() (*Nat44EiUserDetails, error) {
639 msg, err := c.Stream.RecvMsg()
643 switch m := msg.(type) {
644 case *Nat44EiUserDetails:
646 case *memclnt.ControlPingReply:
647 err = c.Stream.Close()
653 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
657 func (c *serviceClient) Nat44EiUserSessionDump(ctx context.Context, in *Nat44EiUserSessionDump) (RPCService_Nat44EiUserSessionDumpClient, error) {
658 stream, err := c.conn.NewStream(ctx)
662 x := &serviceClient_Nat44EiUserSessionDumpClient{stream}
663 if err := x.Stream.SendMsg(in); err != nil {
666 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
672 type RPCService_Nat44EiUserSessionDumpClient interface {
673 Recv() (*Nat44EiUserSessionDetails, error)
677 type serviceClient_Nat44EiUserSessionDumpClient struct {
681 func (c *serviceClient_Nat44EiUserSessionDumpClient) Recv() (*Nat44EiUserSessionDetails, error) {
682 msg, err := c.Stream.RecvMsg()
686 switch m := msg.(type) {
687 case *Nat44EiUserSessionDetails:
689 case *memclnt.ControlPingReply:
690 err = c.Stream.Close()
696 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
700 func (c *serviceClient) Nat44EiWorkerDump(ctx context.Context, in *Nat44EiWorkerDump) (RPCService_Nat44EiWorkerDumpClient, error) {
701 stream, err := c.conn.NewStream(ctx)
705 x := &serviceClient_Nat44EiWorkerDumpClient{stream}
706 if err := x.Stream.SendMsg(in); err != nil {
709 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
715 type RPCService_Nat44EiWorkerDumpClient interface {
716 Recv() (*Nat44EiWorkerDetails, error)
720 type serviceClient_Nat44EiWorkerDumpClient struct {
724 func (c *serviceClient_Nat44EiWorkerDumpClient) Recv() (*Nat44EiWorkerDetails, error) {
725 msg, err := c.Stream.RecvMsg()
729 switch m := msg.(type) {
730 case *Nat44EiWorkerDetails:
732 case *memclnt.ControlPingReply:
733 err = c.Stream.Close()
739 return nil, fmt.Errorf("unexpected message: %T %v", m, m)