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 nat.
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 Nat44AddressDump(ctx context.Context, in *Nat44AddressDump) (RPCService_Nat44AddressDumpClient, error)
22 Nat44DelSession(ctx context.Context, in *Nat44DelSession) (*Nat44DelSessionReply, error)
23 Nat44DelUser(ctx context.Context, in *Nat44DelUser) (*Nat44DelUserReply, error)
24 Nat44ForwardingEnableDisable(ctx context.Context, in *Nat44ForwardingEnableDisable) (*Nat44ForwardingEnableDisableReply, error)
25 Nat44ForwardingIsEnabled(ctx context.Context, in *Nat44ForwardingIsEnabled) (*Nat44ForwardingIsEnabledReply, error)
26 Nat44IdentityMappingDump(ctx context.Context, in *Nat44IdentityMappingDump) (RPCService_Nat44IdentityMappingDumpClient, error)
27 Nat44InterfaceAddDelFeature(ctx context.Context, in *Nat44InterfaceAddDelFeature) (*Nat44InterfaceAddDelFeatureReply, error)
28 Nat44InterfaceAddDelOutputFeature(ctx context.Context, in *Nat44InterfaceAddDelOutputFeature) (*Nat44InterfaceAddDelOutputFeatureReply, error)
29 Nat44InterfaceAddrDump(ctx context.Context, in *Nat44InterfaceAddrDump) (RPCService_Nat44InterfaceAddrDumpClient, error)
30 Nat44InterfaceDump(ctx context.Context, in *Nat44InterfaceDump) (RPCService_Nat44InterfaceDumpClient, error)
31 Nat44InterfaceOutputFeatureDump(ctx context.Context, in *Nat44InterfaceOutputFeatureDump) (RPCService_Nat44InterfaceOutputFeatureDumpClient, error)
32 Nat44LbStaticMappingAddDelLocal(ctx context.Context, in *Nat44LbStaticMappingAddDelLocal) (*Nat44LbStaticMappingAddDelLocalReply, error)
33 Nat44LbStaticMappingDump(ctx context.Context, in *Nat44LbStaticMappingDump) (RPCService_Nat44LbStaticMappingDumpClient, error)
34 Nat44SessionCleanup(ctx context.Context, in *Nat44SessionCleanup) (*Nat44SessionCleanupReply, error)
35 Nat44SetSessionLimit(ctx context.Context, in *Nat44SetSessionLimit) (*Nat44SetSessionLimitReply, error)
36 Nat44StaticMappingDump(ctx context.Context, in *Nat44StaticMappingDump) (RPCService_Nat44StaticMappingDumpClient, error)
37 Nat44UserDump(ctx context.Context, in *Nat44UserDump) (RPCService_Nat44UserDumpClient, error)
38 Nat44UserSessionDump(ctx context.Context, in *Nat44UserSessionDump) (RPCService_Nat44UserSessionDumpClient, error)
39 Nat64AddDelInterface(ctx context.Context, in *Nat64AddDelInterface) (*Nat64AddDelInterfaceReply, error)
40 Nat64AddDelInterfaceAddr(ctx context.Context, in *Nat64AddDelInterfaceAddr) (*Nat64AddDelInterfaceAddrReply, error)
41 Nat64AddDelPoolAddrRange(ctx context.Context, in *Nat64AddDelPoolAddrRange) (*Nat64AddDelPoolAddrRangeReply, error)
42 Nat64AddDelPrefix(ctx context.Context, in *Nat64AddDelPrefix) (*Nat64AddDelPrefixReply, error)
43 Nat64AddDelStaticBib(ctx context.Context, in *Nat64AddDelStaticBib) (*Nat64AddDelStaticBibReply, error)
44 Nat64BibDump(ctx context.Context, in *Nat64BibDump) (RPCService_Nat64BibDumpClient, error)
45 Nat64InterfaceDump(ctx context.Context, in *Nat64InterfaceDump) (RPCService_Nat64InterfaceDumpClient, error)
46 Nat64PoolAddrDump(ctx context.Context, in *Nat64PoolAddrDump) (RPCService_Nat64PoolAddrDumpClient, error)
47 Nat64PrefixDump(ctx context.Context, in *Nat64PrefixDump) (RPCService_Nat64PrefixDumpClient, error)
48 Nat64StDump(ctx context.Context, in *Nat64StDump) (RPCService_Nat64StDumpClient, error)
49 Nat66AddDelInterface(ctx context.Context, in *Nat66AddDelInterface) (*Nat66AddDelInterfaceReply, error)
50 Nat66AddDelStaticMapping(ctx context.Context, in *Nat66AddDelStaticMapping) (*Nat66AddDelStaticMappingReply, error)
51 Nat66InterfaceDump(ctx context.Context, in *Nat66InterfaceDump) (RPCService_Nat66InterfaceDumpClient, error)
52 Nat66StaticMappingDump(ctx context.Context, in *Nat66StaticMappingDump) (RPCService_Nat66StaticMappingDumpClient, error)
53 NatControlPing(ctx context.Context, in *NatControlPing) (*NatControlPingReply, error)
54 NatDetAddDelMap(ctx context.Context, in *NatDetAddDelMap) (*NatDetAddDelMapReply, error)
55 NatDetCloseSessionIn(ctx context.Context, in *NatDetCloseSessionIn) (*NatDetCloseSessionInReply, error)
56 NatDetCloseSessionOut(ctx context.Context, in *NatDetCloseSessionOut) (*NatDetCloseSessionOutReply, error)
57 NatDetForward(ctx context.Context, in *NatDetForward) (*NatDetForwardReply, error)
58 NatDetMapDump(ctx context.Context, in *NatDetMapDump) (RPCService_NatDetMapDumpClient, error)
59 NatDetReverse(ctx context.Context, in *NatDetReverse) (*NatDetReverseReply, error)
60 NatDetSessionDump(ctx context.Context, in *NatDetSessionDump) (RPCService_NatDetSessionDumpClient, error)
61 NatGetAddrAndPortAllocAlg(ctx context.Context, in *NatGetAddrAndPortAllocAlg) (*NatGetAddrAndPortAllocAlgReply, error)
62 NatGetMssClamping(ctx context.Context, in *NatGetMssClamping) (*NatGetMssClampingReply, error)
63 NatGetTimeouts(ctx context.Context, in *NatGetTimeouts) (*NatGetTimeoutsReply, error)
64 NatHaFlush(ctx context.Context, in *NatHaFlush) (*NatHaFlushReply, error)
65 NatHaGetFailover(ctx context.Context, in *NatHaGetFailover) (*NatHaGetFailoverReply, error)
66 NatHaGetListener(ctx context.Context, in *NatHaGetListener) (*NatHaGetListenerReply, error)
67 NatHaResync(ctx context.Context, in *NatHaResync) (*NatHaResyncReply, error)
68 NatHaSetFailover(ctx context.Context, in *NatHaSetFailover) (*NatHaSetFailoverReply, error)
69 NatHaSetListener(ctx context.Context, in *NatHaSetListener) (*NatHaSetListenerReply, error)
70 NatIpfixEnableDisable(ctx context.Context, in *NatIpfixEnableDisable) (*NatIpfixEnableDisableReply, error)
71 NatSetAddrAndPortAllocAlg(ctx context.Context, in *NatSetAddrAndPortAllocAlg) (*NatSetAddrAndPortAllocAlgReply, error)
72 NatSetLogLevel(ctx context.Context, in *NatSetLogLevel) (*NatSetLogLevelReply, error)
73 NatSetMssClamping(ctx context.Context, in *NatSetMssClamping) (*NatSetMssClampingReply, error)
74 NatSetTimeouts(ctx context.Context, in *NatSetTimeouts) (*NatSetTimeoutsReply, error)
75 NatSetWorkers(ctx context.Context, in *NatSetWorkers) (*NatSetWorkersReply, error)
76 NatShowConfig(ctx context.Context, in *NatShowConfig) (*NatShowConfigReply, error)
77 NatWorkerDump(ctx context.Context, in *NatWorkerDump) (RPCService_NatWorkerDumpClient, error)
80 type serviceClient struct {
84 func NewServiceClient(conn api.Connection) RPCService {
85 return &serviceClient{conn}
88 func (c *serviceClient) Nat44AddDelAddressRange(ctx context.Context, in *Nat44AddDelAddressRange) (*Nat44AddDelAddressRangeReply, error) {
89 out := new(Nat44AddDelAddressRangeReply)
90 err := c.conn.Invoke(ctx, in, out)
97 func (c *serviceClient) Nat44AddDelIdentityMapping(ctx context.Context, in *Nat44AddDelIdentityMapping) (*Nat44AddDelIdentityMappingReply, error) {
98 out := new(Nat44AddDelIdentityMappingReply)
99 err := c.conn.Invoke(ctx, in, out)
106 func (c *serviceClient) Nat44AddDelInterfaceAddr(ctx context.Context, in *Nat44AddDelInterfaceAddr) (*Nat44AddDelInterfaceAddrReply, error) {
107 out := new(Nat44AddDelInterfaceAddrReply)
108 err := c.conn.Invoke(ctx, in, out)
115 func (c *serviceClient) Nat44AddDelLbStaticMapping(ctx context.Context, in *Nat44AddDelLbStaticMapping) (*Nat44AddDelLbStaticMappingReply, error) {
116 out := new(Nat44AddDelLbStaticMappingReply)
117 err := c.conn.Invoke(ctx, in, out)
124 func (c *serviceClient) Nat44AddDelStaticMapping(ctx context.Context, in *Nat44AddDelStaticMapping) (*Nat44AddDelStaticMappingReply, error) {
125 out := new(Nat44AddDelStaticMappingReply)
126 err := c.conn.Invoke(ctx, in, out)
133 func (c *serviceClient) Nat44AddressDump(ctx context.Context, in *Nat44AddressDump) (RPCService_Nat44AddressDumpClient, error) {
134 stream, err := c.conn.NewStream(ctx)
138 x := &serviceClient_Nat44AddressDumpClient{stream}
139 if err := x.Stream.SendMsg(in); err != nil {
142 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
148 type RPCService_Nat44AddressDumpClient interface {
149 Recv() (*Nat44AddressDetails, error)
153 type serviceClient_Nat44AddressDumpClient struct {
157 func (c *serviceClient_Nat44AddressDumpClient) Recv() (*Nat44AddressDetails, error) {
158 msg, err := c.Stream.RecvMsg()
162 switch m := msg.(type) {
163 case *Nat44AddressDetails:
165 case *vpe.ControlPingReply:
168 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
172 func (c *serviceClient) Nat44DelSession(ctx context.Context, in *Nat44DelSession) (*Nat44DelSessionReply, error) {
173 out := new(Nat44DelSessionReply)
174 err := c.conn.Invoke(ctx, in, out)
181 func (c *serviceClient) Nat44DelUser(ctx context.Context, in *Nat44DelUser) (*Nat44DelUserReply, error) {
182 out := new(Nat44DelUserReply)
183 err := c.conn.Invoke(ctx, in, out)
190 func (c *serviceClient) Nat44ForwardingEnableDisable(ctx context.Context, in *Nat44ForwardingEnableDisable) (*Nat44ForwardingEnableDisableReply, error) {
191 out := new(Nat44ForwardingEnableDisableReply)
192 err := c.conn.Invoke(ctx, in, out)
199 func (c *serviceClient) Nat44ForwardingIsEnabled(ctx context.Context, in *Nat44ForwardingIsEnabled) (*Nat44ForwardingIsEnabledReply, error) {
200 out := new(Nat44ForwardingIsEnabledReply)
201 err := c.conn.Invoke(ctx, in, out)
208 func (c *serviceClient) Nat44IdentityMappingDump(ctx context.Context, in *Nat44IdentityMappingDump) (RPCService_Nat44IdentityMappingDumpClient, error) {
209 stream, err := c.conn.NewStream(ctx)
213 x := &serviceClient_Nat44IdentityMappingDumpClient{stream}
214 if err := x.Stream.SendMsg(in); err != nil {
217 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
223 type RPCService_Nat44IdentityMappingDumpClient interface {
224 Recv() (*Nat44IdentityMappingDetails, error)
228 type serviceClient_Nat44IdentityMappingDumpClient struct {
232 func (c *serviceClient_Nat44IdentityMappingDumpClient) Recv() (*Nat44IdentityMappingDetails, error) {
233 msg, err := c.Stream.RecvMsg()
237 switch m := msg.(type) {
238 case *Nat44IdentityMappingDetails:
240 case *vpe.ControlPingReply:
243 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
247 func (c *serviceClient) Nat44InterfaceAddDelFeature(ctx context.Context, in *Nat44InterfaceAddDelFeature) (*Nat44InterfaceAddDelFeatureReply, error) {
248 out := new(Nat44InterfaceAddDelFeatureReply)
249 err := c.conn.Invoke(ctx, in, out)
256 func (c *serviceClient) Nat44InterfaceAddDelOutputFeature(ctx context.Context, in *Nat44InterfaceAddDelOutputFeature) (*Nat44InterfaceAddDelOutputFeatureReply, error) {
257 out := new(Nat44InterfaceAddDelOutputFeatureReply)
258 err := c.conn.Invoke(ctx, in, out)
265 func (c *serviceClient) Nat44InterfaceAddrDump(ctx context.Context, in *Nat44InterfaceAddrDump) (RPCService_Nat44InterfaceAddrDumpClient, error) {
266 stream, err := c.conn.NewStream(ctx)
270 x := &serviceClient_Nat44InterfaceAddrDumpClient{stream}
271 if err := x.Stream.SendMsg(in); err != nil {
274 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
280 type RPCService_Nat44InterfaceAddrDumpClient interface {
281 Recv() (*Nat44InterfaceAddrDetails, error)
285 type serviceClient_Nat44InterfaceAddrDumpClient struct {
289 func (c *serviceClient_Nat44InterfaceAddrDumpClient) Recv() (*Nat44InterfaceAddrDetails, error) {
290 msg, err := c.Stream.RecvMsg()
294 switch m := msg.(type) {
295 case *Nat44InterfaceAddrDetails:
297 case *vpe.ControlPingReply:
300 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
304 func (c *serviceClient) Nat44InterfaceDump(ctx context.Context, in *Nat44InterfaceDump) (RPCService_Nat44InterfaceDumpClient, error) {
305 stream, err := c.conn.NewStream(ctx)
309 x := &serviceClient_Nat44InterfaceDumpClient{stream}
310 if err := x.Stream.SendMsg(in); err != nil {
313 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
319 type RPCService_Nat44InterfaceDumpClient interface {
320 Recv() (*Nat44InterfaceDetails, error)
324 type serviceClient_Nat44InterfaceDumpClient struct {
328 func (c *serviceClient_Nat44InterfaceDumpClient) Recv() (*Nat44InterfaceDetails, error) {
329 msg, err := c.Stream.RecvMsg()
333 switch m := msg.(type) {
334 case *Nat44InterfaceDetails:
336 case *vpe.ControlPingReply:
339 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
343 func (c *serviceClient) Nat44InterfaceOutputFeatureDump(ctx context.Context, in *Nat44InterfaceOutputFeatureDump) (RPCService_Nat44InterfaceOutputFeatureDumpClient, error) {
344 stream, err := c.conn.NewStream(ctx)
348 x := &serviceClient_Nat44InterfaceOutputFeatureDumpClient{stream}
349 if err := x.Stream.SendMsg(in); err != nil {
352 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
358 type RPCService_Nat44InterfaceOutputFeatureDumpClient interface {
359 Recv() (*Nat44InterfaceOutputFeatureDetails, error)
363 type serviceClient_Nat44InterfaceOutputFeatureDumpClient struct {
367 func (c *serviceClient_Nat44InterfaceOutputFeatureDumpClient) Recv() (*Nat44InterfaceOutputFeatureDetails, error) {
368 msg, err := c.Stream.RecvMsg()
372 switch m := msg.(type) {
373 case *Nat44InterfaceOutputFeatureDetails:
375 case *vpe.ControlPingReply:
378 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
382 func (c *serviceClient) Nat44LbStaticMappingAddDelLocal(ctx context.Context, in *Nat44LbStaticMappingAddDelLocal) (*Nat44LbStaticMappingAddDelLocalReply, error) {
383 out := new(Nat44LbStaticMappingAddDelLocalReply)
384 err := c.conn.Invoke(ctx, in, out)
391 func (c *serviceClient) Nat44LbStaticMappingDump(ctx context.Context, in *Nat44LbStaticMappingDump) (RPCService_Nat44LbStaticMappingDumpClient, error) {
392 stream, err := c.conn.NewStream(ctx)
396 x := &serviceClient_Nat44LbStaticMappingDumpClient{stream}
397 if err := x.Stream.SendMsg(in); err != nil {
400 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
406 type RPCService_Nat44LbStaticMappingDumpClient interface {
407 Recv() (*Nat44LbStaticMappingDetails, error)
411 type serviceClient_Nat44LbStaticMappingDumpClient struct {
415 func (c *serviceClient_Nat44LbStaticMappingDumpClient) Recv() (*Nat44LbStaticMappingDetails, error) {
416 msg, err := c.Stream.RecvMsg()
420 switch m := msg.(type) {
421 case *Nat44LbStaticMappingDetails:
423 case *vpe.ControlPingReply:
426 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
430 func (c *serviceClient) Nat44SessionCleanup(ctx context.Context, in *Nat44SessionCleanup) (*Nat44SessionCleanupReply, error) {
431 out := new(Nat44SessionCleanupReply)
432 err := c.conn.Invoke(ctx, in, out)
439 func (c *serviceClient) Nat44SetSessionLimit(ctx context.Context, in *Nat44SetSessionLimit) (*Nat44SetSessionLimitReply, error) {
440 out := new(Nat44SetSessionLimitReply)
441 err := c.conn.Invoke(ctx, in, out)
448 func (c *serviceClient) Nat44StaticMappingDump(ctx context.Context, in *Nat44StaticMappingDump) (RPCService_Nat44StaticMappingDumpClient, error) {
449 stream, err := c.conn.NewStream(ctx)
453 x := &serviceClient_Nat44StaticMappingDumpClient{stream}
454 if err := x.Stream.SendMsg(in); err != nil {
457 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
463 type RPCService_Nat44StaticMappingDumpClient interface {
464 Recv() (*Nat44StaticMappingDetails, error)
468 type serviceClient_Nat44StaticMappingDumpClient struct {
472 func (c *serviceClient_Nat44StaticMappingDumpClient) Recv() (*Nat44StaticMappingDetails, error) {
473 msg, err := c.Stream.RecvMsg()
477 switch m := msg.(type) {
478 case *Nat44StaticMappingDetails:
480 case *vpe.ControlPingReply:
483 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
487 func (c *serviceClient) Nat44UserDump(ctx context.Context, in *Nat44UserDump) (RPCService_Nat44UserDumpClient, error) {
488 stream, err := c.conn.NewStream(ctx)
492 x := &serviceClient_Nat44UserDumpClient{stream}
493 if err := x.Stream.SendMsg(in); err != nil {
496 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
502 type RPCService_Nat44UserDumpClient interface {
503 Recv() (*Nat44UserDetails, error)
507 type serviceClient_Nat44UserDumpClient struct {
511 func (c *serviceClient_Nat44UserDumpClient) Recv() (*Nat44UserDetails, error) {
512 msg, err := c.Stream.RecvMsg()
516 switch m := msg.(type) {
517 case *Nat44UserDetails:
519 case *vpe.ControlPingReply:
522 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
526 func (c *serviceClient) Nat44UserSessionDump(ctx context.Context, in *Nat44UserSessionDump) (RPCService_Nat44UserSessionDumpClient, error) {
527 stream, err := c.conn.NewStream(ctx)
531 x := &serviceClient_Nat44UserSessionDumpClient{stream}
532 if err := x.Stream.SendMsg(in); err != nil {
535 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
541 type RPCService_Nat44UserSessionDumpClient interface {
542 Recv() (*Nat44UserSessionDetails, error)
546 type serviceClient_Nat44UserSessionDumpClient struct {
550 func (c *serviceClient_Nat44UserSessionDumpClient) Recv() (*Nat44UserSessionDetails, error) {
551 msg, err := c.Stream.RecvMsg()
555 switch m := msg.(type) {
556 case *Nat44UserSessionDetails:
558 case *vpe.ControlPingReply:
561 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
565 func (c *serviceClient) Nat64AddDelInterface(ctx context.Context, in *Nat64AddDelInterface) (*Nat64AddDelInterfaceReply, error) {
566 out := new(Nat64AddDelInterfaceReply)
567 err := c.conn.Invoke(ctx, in, out)
574 func (c *serviceClient) Nat64AddDelInterfaceAddr(ctx context.Context, in *Nat64AddDelInterfaceAddr) (*Nat64AddDelInterfaceAddrReply, error) {
575 out := new(Nat64AddDelInterfaceAddrReply)
576 err := c.conn.Invoke(ctx, in, out)
583 func (c *serviceClient) Nat64AddDelPoolAddrRange(ctx context.Context, in *Nat64AddDelPoolAddrRange) (*Nat64AddDelPoolAddrRangeReply, error) {
584 out := new(Nat64AddDelPoolAddrRangeReply)
585 err := c.conn.Invoke(ctx, in, out)
592 func (c *serviceClient) Nat64AddDelPrefix(ctx context.Context, in *Nat64AddDelPrefix) (*Nat64AddDelPrefixReply, error) {
593 out := new(Nat64AddDelPrefixReply)
594 err := c.conn.Invoke(ctx, in, out)
601 func (c *serviceClient) Nat64AddDelStaticBib(ctx context.Context, in *Nat64AddDelStaticBib) (*Nat64AddDelStaticBibReply, error) {
602 out := new(Nat64AddDelStaticBibReply)
603 err := c.conn.Invoke(ctx, in, out)
610 func (c *serviceClient) Nat64BibDump(ctx context.Context, in *Nat64BibDump) (RPCService_Nat64BibDumpClient, error) {
611 stream, err := c.conn.NewStream(ctx)
615 x := &serviceClient_Nat64BibDumpClient{stream}
616 if err := x.Stream.SendMsg(in); err != nil {
619 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
625 type RPCService_Nat64BibDumpClient interface {
626 Recv() (*Nat64BibDetails, error)
630 type serviceClient_Nat64BibDumpClient struct {
634 func (c *serviceClient_Nat64BibDumpClient) Recv() (*Nat64BibDetails, error) {
635 msg, err := c.Stream.RecvMsg()
639 switch m := msg.(type) {
640 case *Nat64BibDetails:
642 case *vpe.ControlPingReply:
645 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
649 func (c *serviceClient) Nat64InterfaceDump(ctx context.Context, in *Nat64InterfaceDump) (RPCService_Nat64InterfaceDumpClient, error) {
650 stream, err := c.conn.NewStream(ctx)
654 x := &serviceClient_Nat64InterfaceDumpClient{stream}
655 if err := x.Stream.SendMsg(in); err != nil {
658 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
664 type RPCService_Nat64InterfaceDumpClient interface {
665 Recv() (*Nat64InterfaceDetails, error)
669 type serviceClient_Nat64InterfaceDumpClient struct {
673 func (c *serviceClient_Nat64InterfaceDumpClient) Recv() (*Nat64InterfaceDetails, error) {
674 msg, err := c.Stream.RecvMsg()
678 switch m := msg.(type) {
679 case *Nat64InterfaceDetails:
681 case *vpe.ControlPingReply:
684 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
688 func (c *serviceClient) Nat64PoolAddrDump(ctx context.Context, in *Nat64PoolAddrDump) (RPCService_Nat64PoolAddrDumpClient, error) {
689 stream, err := c.conn.NewStream(ctx)
693 x := &serviceClient_Nat64PoolAddrDumpClient{stream}
694 if err := x.Stream.SendMsg(in); err != nil {
697 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
703 type RPCService_Nat64PoolAddrDumpClient interface {
704 Recv() (*Nat64PoolAddrDetails, error)
708 type serviceClient_Nat64PoolAddrDumpClient struct {
712 func (c *serviceClient_Nat64PoolAddrDumpClient) Recv() (*Nat64PoolAddrDetails, error) {
713 msg, err := c.Stream.RecvMsg()
717 switch m := msg.(type) {
718 case *Nat64PoolAddrDetails:
720 case *vpe.ControlPingReply:
723 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
727 func (c *serviceClient) Nat64PrefixDump(ctx context.Context, in *Nat64PrefixDump) (RPCService_Nat64PrefixDumpClient, error) {
728 stream, err := c.conn.NewStream(ctx)
732 x := &serviceClient_Nat64PrefixDumpClient{stream}
733 if err := x.Stream.SendMsg(in); err != nil {
736 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
742 type RPCService_Nat64PrefixDumpClient interface {
743 Recv() (*Nat64PrefixDetails, error)
747 type serviceClient_Nat64PrefixDumpClient struct {
751 func (c *serviceClient_Nat64PrefixDumpClient) Recv() (*Nat64PrefixDetails, error) {
752 msg, err := c.Stream.RecvMsg()
756 switch m := msg.(type) {
757 case *Nat64PrefixDetails:
759 case *vpe.ControlPingReply:
762 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
766 func (c *serviceClient) Nat64StDump(ctx context.Context, in *Nat64StDump) (RPCService_Nat64StDumpClient, error) {
767 stream, err := c.conn.NewStream(ctx)
771 x := &serviceClient_Nat64StDumpClient{stream}
772 if err := x.Stream.SendMsg(in); err != nil {
775 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
781 type RPCService_Nat64StDumpClient interface {
782 Recv() (*Nat64StDetails, error)
786 type serviceClient_Nat64StDumpClient struct {
790 func (c *serviceClient_Nat64StDumpClient) Recv() (*Nat64StDetails, error) {
791 msg, err := c.Stream.RecvMsg()
795 switch m := msg.(type) {
796 case *Nat64StDetails:
798 case *vpe.ControlPingReply:
801 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
805 func (c *serviceClient) Nat66AddDelInterface(ctx context.Context, in *Nat66AddDelInterface) (*Nat66AddDelInterfaceReply, error) {
806 out := new(Nat66AddDelInterfaceReply)
807 err := c.conn.Invoke(ctx, in, out)
814 func (c *serviceClient) Nat66AddDelStaticMapping(ctx context.Context, in *Nat66AddDelStaticMapping) (*Nat66AddDelStaticMappingReply, error) {
815 out := new(Nat66AddDelStaticMappingReply)
816 err := c.conn.Invoke(ctx, in, out)
823 func (c *serviceClient) Nat66InterfaceDump(ctx context.Context, in *Nat66InterfaceDump) (RPCService_Nat66InterfaceDumpClient, error) {
824 stream, err := c.conn.NewStream(ctx)
828 x := &serviceClient_Nat66InterfaceDumpClient{stream}
829 if err := x.Stream.SendMsg(in); err != nil {
832 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
838 type RPCService_Nat66InterfaceDumpClient interface {
839 Recv() (*Nat66InterfaceDetails, error)
843 type serviceClient_Nat66InterfaceDumpClient struct {
847 func (c *serviceClient_Nat66InterfaceDumpClient) Recv() (*Nat66InterfaceDetails, error) {
848 msg, err := c.Stream.RecvMsg()
852 switch m := msg.(type) {
853 case *Nat66InterfaceDetails:
855 case *vpe.ControlPingReply:
858 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
862 func (c *serviceClient) Nat66StaticMappingDump(ctx context.Context, in *Nat66StaticMappingDump) (RPCService_Nat66StaticMappingDumpClient, error) {
863 stream, err := c.conn.NewStream(ctx)
867 x := &serviceClient_Nat66StaticMappingDumpClient{stream}
868 if err := x.Stream.SendMsg(in); err != nil {
871 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
877 type RPCService_Nat66StaticMappingDumpClient interface {
878 Recv() (*Nat66StaticMappingDetails, error)
882 type serviceClient_Nat66StaticMappingDumpClient struct {
886 func (c *serviceClient_Nat66StaticMappingDumpClient) Recv() (*Nat66StaticMappingDetails, error) {
887 msg, err := c.Stream.RecvMsg()
891 switch m := msg.(type) {
892 case *Nat66StaticMappingDetails:
894 case *vpe.ControlPingReply:
897 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
901 func (c *serviceClient) NatControlPing(ctx context.Context, in *NatControlPing) (*NatControlPingReply, error) {
902 out := new(NatControlPingReply)
903 err := c.conn.Invoke(ctx, in, out)
910 func (c *serviceClient) NatDetAddDelMap(ctx context.Context, in *NatDetAddDelMap) (*NatDetAddDelMapReply, error) {
911 out := new(NatDetAddDelMapReply)
912 err := c.conn.Invoke(ctx, in, out)
919 func (c *serviceClient) NatDetCloseSessionIn(ctx context.Context, in *NatDetCloseSessionIn) (*NatDetCloseSessionInReply, error) {
920 out := new(NatDetCloseSessionInReply)
921 err := c.conn.Invoke(ctx, in, out)
928 func (c *serviceClient) NatDetCloseSessionOut(ctx context.Context, in *NatDetCloseSessionOut) (*NatDetCloseSessionOutReply, error) {
929 out := new(NatDetCloseSessionOutReply)
930 err := c.conn.Invoke(ctx, in, out)
937 func (c *serviceClient) NatDetForward(ctx context.Context, in *NatDetForward) (*NatDetForwardReply, error) {
938 out := new(NatDetForwardReply)
939 err := c.conn.Invoke(ctx, in, out)
946 func (c *serviceClient) NatDetMapDump(ctx context.Context, in *NatDetMapDump) (RPCService_NatDetMapDumpClient, error) {
947 stream, err := c.conn.NewStream(ctx)
951 x := &serviceClient_NatDetMapDumpClient{stream}
952 if err := x.Stream.SendMsg(in); err != nil {
955 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
961 type RPCService_NatDetMapDumpClient interface {
962 Recv() (*NatDetMapDetails, error)
966 type serviceClient_NatDetMapDumpClient struct {
970 func (c *serviceClient_NatDetMapDumpClient) Recv() (*NatDetMapDetails, error) {
971 msg, err := c.Stream.RecvMsg()
975 switch m := msg.(type) {
976 case *NatDetMapDetails:
978 case *vpe.ControlPingReply:
981 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
985 func (c *serviceClient) NatDetReverse(ctx context.Context, in *NatDetReverse) (*NatDetReverseReply, error) {
986 out := new(NatDetReverseReply)
987 err := c.conn.Invoke(ctx, in, out)
994 func (c *serviceClient) NatDetSessionDump(ctx context.Context, in *NatDetSessionDump) (RPCService_NatDetSessionDumpClient, error) {
995 stream, err := c.conn.NewStream(ctx)
999 x := &serviceClient_NatDetSessionDumpClient{stream}
1000 if err := x.Stream.SendMsg(in); err != nil {
1003 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
1009 type RPCService_NatDetSessionDumpClient interface {
1010 Recv() (*NatDetSessionDetails, error)
1014 type serviceClient_NatDetSessionDumpClient struct {
1018 func (c *serviceClient_NatDetSessionDumpClient) Recv() (*NatDetSessionDetails, error) {
1019 msg, err := c.Stream.RecvMsg()
1023 switch m := msg.(type) {
1024 case *NatDetSessionDetails:
1026 case *vpe.ControlPingReply:
1029 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
1033 func (c *serviceClient) NatGetAddrAndPortAllocAlg(ctx context.Context, in *NatGetAddrAndPortAllocAlg) (*NatGetAddrAndPortAllocAlgReply, error) {
1034 out := new(NatGetAddrAndPortAllocAlgReply)
1035 err := c.conn.Invoke(ctx, in, out)
1042 func (c *serviceClient) NatGetMssClamping(ctx context.Context, in *NatGetMssClamping) (*NatGetMssClampingReply, error) {
1043 out := new(NatGetMssClampingReply)
1044 err := c.conn.Invoke(ctx, in, out)
1051 func (c *serviceClient) NatGetTimeouts(ctx context.Context, in *NatGetTimeouts) (*NatGetTimeoutsReply, error) {
1052 out := new(NatGetTimeoutsReply)
1053 err := c.conn.Invoke(ctx, in, out)
1060 func (c *serviceClient) NatHaFlush(ctx context.Context, in *NatHaFlush) (*NatHaFlushReply, error) {
1061 out := new(NatHaFlushReply)
1062 err := c.conn.Invoke(ctx, in, out)
1069 func (c *serviceClient) NatHaGetFailover(ctx context.Context, in *NatHaGetFailover) (*NatHaGetFailoverReply, error) {
1070 out := new(NatHaGetFailoverReply)
1071 err := c.conn.Invoke(ctx, in, out)
1078 func (c *serviceClient) NatHaGetListener(ctx context.Context, in *NatHaGetListener) (*NatHaGetListenerReply, error) {
1079 out := new(NatHaGetListenerReply)
1080 err := c.conn.Invoke(ctx, in, out)
1087 func (c *serviceClient) NatHaResync(ctx context.Context, in *NatHaResync) (*NatHaResyncReply, error) {
1088 out := new(NatHaResyncReply)
1089 err := c.conn.Invoke(ctx, in, out)
1096 func (c *serviceClient) NatHaSetFailover(ctx context.Context, in *NatHaSetFailover) (*NatHaSetFailoverReply, error) {
1097 out := new(NatHaSetFailoverReply)
1098 err := c.conn.Invoke(ctx, in, out)
1105 func (c *serviceClient) NatHaSetListener(ctx context.Context, in *NatHaSetListener) (*NatHaSetListenerReply, error) {
1106 out := new(NatHaSetListenerReply)
1107 err := c.conn.Invoke(ctx, in, out)
1114 func (c *serviceClient) NatIpfixEnableDisable(ctx context.Context, in *NatIpfixEnableDisable) (*NatIpfixEnableDisableReply, error) {
1115 out := new(NatIpfixEnableDisableReply)
1116 err := c.conn.Invoke(ctx, in, out)
1123 func (c *serviceClient) NatSetAddrAndPortAllocAlg(ctx context.Context, in *NatSetAddrAndPortAllocAlg) (*NatSetAddrAndPortAllocAlgReply, error) {
1124 out := new(NatSetAddrAndPortAllocAlgReply)
1125 err := c.conn.Invoke(ctx, in, out)
1132 func (c *serviceClient) NatSetLogLevel(ctx context.Context, in *NatSetLogLevel) (*NatSetLogLevelReply, error) {
1133 out := new(NatSetLogLevelReply)
1134 err := c.conn.Invoke(ctx, in, out)
1141 func (c *serviceClient) NatSetMssClamping(ctx context.Context, in *NatSetMssClamping) (*NatSetMssClampingReply, error) {
1142 out := new(NatSetMssClampingReply)
1143 err := c.conn.Invoke(ctx, in, out)
1150 func (c *serviceClient) NatSetTimeouts(ctx context.Context, in *NatSetTimeouts) (*NatSetTimeoutsReply, error) {
1151 out := new(NatSetTimeoutsReply)
1152 err := c.conn.Invoke(ctx, in, out)
1159 func (c *serviceClient) NatSetWorkers(ctx context.Context, in *NatSetWorkers) (*NatSetWorkersReply, error) {
1160 out := new(NatSetWorkersReply)
1161 err := c.conn.Invoke(ctx, in, out)
1168 func (c *serviceClient) NatShowConfig(ctx context.Context, in *NatShowConfig) (*NatShowConfigReply, error) {
1169 out := new(NatShowConfigReply)
1170 err := c.conn.Invoke(ctx, in, out)
1177 func (c *serviceClient) NatWorkerDump(ctx context.Context, in *NatWorkerDump) (RPCService_NatWorkerDumpClient, error) {
1178 stream, err := c.conn.NewStream(ctx)
1182 x := &serviceClient_NatWorkerDumpClient{stream}
1183 if err := x.Stream.SendMsg(in); err != nil {
1186 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
1192 type RPCService_NatWorkerDumpClient interface {
1193 Recv() (*NatWorkerDetails, error)
1197 type serviceClient_NatWorkerDumpClient struct {
1201 func (c *serviceClient_NatWorkerDumpClient) Recv() (*NatWorkerDetails, error) {
1202 msg, err := c.Stream.RecvMsg()
1206 switch m := msg.(type) {
1207 case *NatWorkerDetails:
1209 case *vpe.ControlPingReply:
1212 return nil, fmt.Errorf("unexpected message: %T %v", m, m)