binapi/nat44_ed/nat44_ed_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package nat44_ed
   4
   5 import (
   6         "context"
   7         "fmt"
   8         "io"
   9
  10         api "git.fd.io/govpp.git/api"
  11         memclnt "git.fd.io/govpp.git/binapi/memclnt"
  12 )
  13
  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)
  67 }
  68
  69 type serviceClient struct {
  70         conn api.Connection
  71 }
  72
  73 func NewServiceClient(conn api.Connection) RPCService {
  74         return &serviceClient{conn}
  75 }
  76
  77 func (c *serviceClient) Nat44AddDelAddressRange(ctx context.Context, in *Nat44AddDelAddressRange) (*Nat44AddDelAddressRangeReply, error) {
  78         out := new(Nat44AddDelAddressRangeReply)
  79         err := c.conn.Invoke(ctx, in, out)
  80         if err != nil {
  81                 return nil, err
  82         }
  83         return out, api.RetvalToVPPApiError(out.Retval)
  84 }
  85
  86 func (c *serviceClient) Nat44AddDelIdentityMapping(ctx context.Context, in *Nat44AddDelIdentityMapping) (*Nat44AddDelIdentityMappingReply, error) {
  87         out := new(Nat44AddDelIdentityMappingReply)
  88         err := c.conn.Invoke(ctx, in, out)
  89         if err != nil {
  90                 return nil, err
  91         }
  92         return out, api.RetvalToVPPApiError(out.Retval)
  93 }
  94
  95 func (c *serviceClient) Nat44AddDelInterfaceAddr(ctx context.Context, in *Nat44AddDelInterfaceAddr) (*Nat44AddDelInterfaceAddrReply, error) {
  96         out := new(Nat44AddDelInterfaceAddrReply)
  97         err := c.conn.Invoke(ctx, in, out)
  98         if err != nil {
  99                 return nil, err
 100         }
 101         return out, api.RetvalToVPPApiError(out.Retval)
 102 }
 103
 104 func (c *serviceClient) Nat44AddDelLbStaticMapping(ctx context.Context, in *Nat44AddDelLbStaticMapping) (*Nat44AddDelLbStaticMappingReply, error) {
 105         out := new(Nat44AddDelLbStaticMappingReply)
 106         err := c.conn.Invoke(ctx, in, out)
 107         if err != nil {
 108                 return nil, err
 109         }
 110         return out, api.RetvalToVPPApiError(out.Retval)
 111 }
 112
 113 func (c *serviceClient) Nat44AddDelStaticMapping(ctx context.Context, in *Nat44AddDelStaticMapping) (*Nat44AddDelStaticMappingReply, error) {
 114         out := new(Nat44AddDelStaticMappingReply)
 115         err := c.conn.Invoke(ctx, in, out)
 116         if err != nil {
 117                 return nil, err
 118         }
 119         return out, api.RetvalToVPPApiError(out.Retval)
 120 }
 121
 122 func (c *serviceClient) Nat44AddDelStaticMappingV2(ctx context.Context, in *Nat44AddDelStaticMappingV2) (*Nat44AddDelStaticMappingV2Reply, error) {
 123         out := new(Nat44AddDelStaticMappingV2Reply)
 124         err := c.conn.Invoke(ctx, in, out)
 125         if err != nil {
 126                 return nil, err
 127         }
 128         return out, api.RetvalToVPPApiError(out.Retval)
 129 }
 130
 131 func (c *serviceClient) Nat44AddressDump(ctx context.Context, in *Nat44AddressDump) (RPCService_Nat44AddressDumpClient, error) {
 132         stream, err := c.conn.NewStream(ctx)
 133         if err != nil {
 134                 return nil, err
 135         }
 136         x := &serviceClient_Nat44AddressDumpClient{stream}
 137         if err := x.Stream.SendMsg(in); err != nil {
 138                 return nil, err
 139         }
 140         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 141                 return nil, err
 142         }
 143         return x, nil
 144 }
 145
 146 type RPCService_Nat44AddressDumpClient interface {
 147         Recv() (*Nat44AddressDetails, error)
 148         api.Stream
 149 }
 150
 151 type serviceClient_Nat44AddressDumpClient struct {
 152         api.Stream
 153 }
 154
 155 func (c *serviceClient_Nat44AddressDumpClient) Recv() (*Nat44AddressDetails, error) {
 156         msg, err := c.Stream.RecvMsg()
 157         if err != nil {
 158                 return nil, err
 159         }
 160         switch m := msg.(type) {
 161         case *Nat44AddressDetails:
 162                 return m, nil
 163         case *memclnt.ControlPingReply:
 164                 err = c.Stream.Close()
 165                 if err != nil {
 166                         return nil, err
 167                 }
 168                 return nil, io.EOF
 169         default:
 170                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 171         }
 172 }
 173
 174 func (c *serviceClient) Nat44DelSession(ctx context.Context, in *Nat44DelSession) (*Nat44DelSessionReply, error) {
 175         out := new(Nat44DelSessionReply)
 176         err := c.conn.Invoke(ctx, in, out)
 177         if err != nil {
 178                 return nil, err
 179         }
 180         return out, api.RetvalToVPPApiError(out.Retval)
 181 }
 182
 183 func (c *serviceClient) Nat44DelUser(ctx context.Context, in *Nat44DelUser) (*Nat44DelUserReply, error) {
 184         out := new(Nat44DelUserReply)
 185         err := c.conn.Invoke(ctx, in, out)
 186         if err != nil {
 187                 return nil, err
 188         }
 189         return out, api.RetvalToVPPApiError(out.Retval)
 190 }
 191
 192 func (c *serviceClient) Nat44EdAddDelOutputInterface(ctx context.Context, in *Nat44EdAddDelOutputInterface) (*Nat44EdAddDelOutputInterfaceReply, error) {
 193         out := new(Nat44EdAddDelOutputInterfaceReply)
 194         err := c.conn.Invoke(ctx, in, out)
 195         if err != nil {
 196                 return nil, err
 197         }
 198         return out, api.RetvalToVPPApiError(out.Retval)
 199 }
 200
 201 func (c *serviceClient) Nat44EdOutputInterfaceGet(ctx context.Context, in *Nat44EdOutputInterfaceGet) (RPCService_Nat44EdOutputInterfaceGetClient, error) {
 202         stream, err := c.conn.NewStream(ctx)
 203         if err != nil {
 204                 return nil, err
 205         }
 206         x := &serviceClient_Nat44EdOutputInterfaceGetClient{stream}
 207         if err := x.Stream.SendMsg(in); err != nil {
 208                 return nil, err
 209         }
 210         return x, nil
 211 }
 212
 213 type RPCService_Nat44EdOutputInterfaceGetClient interface {
 214         Recv() (*Nat44EdOutputInterfaceDetails, error)
 215         api.Stream
 216 }
 217
 218 type serviceClient_Nat44EdOutputInterfaceGetClient struct {
 219         api.Stream
 220 }
 221
 222 func (c *serviceClient_Nat44EdOutputInterfaceGetClient) Recv() (*Nat44EdOutputInterfaceDetails, error) {
 223         msg, err := c.Stream.RecvMsg()
 224         if err != nil {
 225                 return nil, err
 226         }
 227         switch m := msg.(type) {
 228         case *Nat44EdOutputInterfaceDetails:
 229                 return m, nil
 230         case *Nat44EdOutputInterfaceGetReply:
 231                 err = c.Stream.Close()
 232                 if err != nil {
 233                         return nil, err
 234                 }
 235                 return nil, io.EOF
 236         default:
 237                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 238         }
 239 }
 240
 241 func (c *serviceClient) Nat44EdPluginEnableDisable(ctx context.Context, in *Nat44EdPluginEnableDisable) (*Nat44EdPluginEnableDisableReply, error) {
 242         out := new(Nat44EdPluginEnableDisableReply)
 243         err := c.conn.Invoke(ctx, in, out)
 244         if err != nil {
 245                 return nil, err
 246         }
 247         return out, api.RetvalToVPPApiError(out.Retval)
 248 }
 249
 250 func (c *serviceClient) Nat44EdSetFqOptions(ctx context.Context, in *Nat44EdSetFqOptions) (*Nat44EdSetFqOptionsReply, error) {
 251         out := new(Nat44EdSetFqOptionsReply)
 252         err := c.conn.Invoke(ctx, in, out)
 253         if err != nil {
 254                 return nil, err
 255         }
 256         return out, api.RetvalToVPPApiError(out.Retval)
 257 }
 258
 259 func (c *serviceClient) Nat44EdShowFqOptions(ctx context.Context, in *Nat44EdShowFqOptions) (*Nat44EdShowFqOptionsReply, error) {
 260         out := new(Nat44EdShowFqOptionsReply)
 261         err := c.conn.Invoke(ctx, in, out)
 262         if err != nil {
 263                 return nil, err
 264         }
 265         return out, api.RetvalToVPPApiError(out.Retval)
 266 }
 267
 268 func (c *serviceClient) Nat44ForwardingEnableDisable(ctx context.Context, in *Nat44ForwardingEnableDisable) (*Nat44ForwardingEnableDisableReply, error) {
 269         out := new(Nat44ForwardingEnableDisableReply)
 270         err := c.conn.Invoke(ctx, in, out)
 271         if err != nil {
 272                 return nil, err
 273         }
 274         return out, api.RetvalToVPPApiError(out.Retval)
 275 }
 276
 277 func (c *serviceClient) Nat44ForwardingIsEnabled(ctx context.Context, in *Nat44ForwardingIsEnabled) (*Nat44ForwardingIsEnabledReply, error) {
 278         out := new(Nat44ForwardingIsEnabledReply)
 279         err := c.conn.Invoke(ctx, in, out)
 280         if err != nil {
 281                 return nil, err
 282         }
 283         return out, nil
 284 }
 285
 286 func (c *serviceClient) Nat44IdentityMappingDump(ctx context.Context, in *Nat44IdentityMappingDump) (RPCService_Nat44IdentityMappingDumpClient, error) {
 287         stream, err := c.conn.NewStream(ctx)
 288         if err != nil {
 289                 return nil, err
 290         }
 291         x := &serviceClient_Nat44IdentityMappingDumpClient{stream}
 292         if err := x.Stream.SendMsg(in); err != nil {
 293                 return nil, err
 294         }
 295         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 296                 return nil, err
 297         }
 298         return x, nil
 299 }
 300
 301 type RPCService_Nat44IdentityMappingDumpClient interface {
 302         Recv() (*Nat44IdentityMappingDetails, error)
 303         api.Stream
 304 }
 305
 306 type serviceClient_Nat44IdentityMappingDumpClient struct {
 307         api.Stream
 308 }
 309
 310 func (c *serviceClient_Nat44IdentityMappingDumpClient) Recv() (*Nat44IdentityMappingDetails, error) {
 311         msg, err := c.Stream.RecvMsg()
 312         if err != nil {
 313                 return nil, err
 314         }
 315         switch m := msg.(type) {
 316         case *Nat44IdentityMappingDetails:
 317                 return m, nil
 318         case *memclnt.ControlPingReply:
 319                 err = c.Stream.Close()
 320                 if err != nil {
 321                         return nil, err
 322                 }
 323                 return nil, io.EOF
 324         default:
 325                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 326         }
 327 }
 328
 329 func (c *serviceClient) Nat44InterfaceAddDelFeature(ctx context.Context, in *Nat44InterfaceAddDelFeature) (*Nat44InterfaceAddDelFeatureReply, error) {
 330         out := new(Nat44InterfaceAddDelFeatureReply)
 331         err := c.conn.Invoke(ctx, in, out)
 332         if err != nil {
 333                 return nil, err
 334         }
 335         return out, api.RetvalToVPPApiError(out.Retval)
 336 }
 337
 338 func (c *serviceClient) Nat44InterfaceAddDelOutputFeature(ctx context.Context, in *Nat44InterfaceAddDelOutputFeature) (*Nat44InterfaceAddDelOutputFeatureReply, error) {
 339         out := new(Nat44InterfaceAddDelOutputFeatureReply)
 340         err := c.conn.Invoke(ctx, in, out)
 341         if err != nil {
 342                 return nil, err
 343         }
 344         return out, api.RetvalToVPPApiError(out.Retval)
 345 }
 346
 347 func (c *serviceClient) Nat44InterfaceAddrDump(ctx context.Context, in *Nat44InterfaceAddrDump) (RPCService_Nat44InterfaceAddrDumpClient, error) {
 348         stream, err := c.conn.NewStream(ctx)
 349         if err != nil {
 350                 return nil, err
 351         }
 352         x := &serviceClient_Nat44InterfaceAddrDumpClient{stream}
 353         if err := x.Stream.SendMsg(in); err != nil {
 354                 return nil, err
 355         }
 356         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 357                 return nil, err
 358         }
 359         return x, nil
 360 }
 361
 362 type RPCService_Nat44InterfaceAddrDumpClient interface {
 363         Recv() (*Nat44InterfaceAddrDetails, error)
 364         api.Stream
 365 }
 366
 367 type serviceClient_Nat44InterfaceAddrDumpClient struct {
 368         api.Stream
 369 }
 370
 371 func (c *serviceClient_Nat44InterfaceAddrDumpClient) Recv() (*Nat44InterfaceAddrDetails, error) {
 372         msg, err := c.Stream.RecvMsg()
 373         if err != nil {
 374                 return nil, err
 375         }
 376         switch m := msg.(type) {
 377         case *Nat44InterfaceAddrDetails:
 378                 return m, nil
 379         case *memclnt.ControlPingReply:
 380                 err = c.Stream.Close()
 381                 if err != nil {
 382                         return nil, err
 383                 }
 384                 return nil, io.EOF
 385         default:
 386                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 387         }
 388 }
 389
 390 func (c *serviceClient) Nat44InterfaceDump(ctx context.Context, in *Nat44InterfaceDump) (RPCService_Nat44InterfaceDumpClient, error) {
 391         stream, err := c.conn.NewStream(ctx)
 392         if err != nil {
 393                 return nil, err
 394         }
 395         x := &serviceClient_Nat44InterfaceDumpClient{stream}
 396         if err := x.Stream.SendMsg(in); err != nil {
 397                 return nil, err
 398         }
 399         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 400                 return nil, err
 401         }
 402         return x, nil
 403 }
 404
 405 type RPCService_Nat44InterfaceDumpClient interface {
 406         Recv() (*Nat44InterfaceDetails, error)
 407         api.Stream
 408 }
 409
 410 type serviceClient_Nat44InterfaceDumpClient struct {
 411         api.Stream
 412 }
 413
 414 func (c *serviceClient_Nat44InterfaceDumpClient) Recv() (*Nat44InterfaceDetails, error) {
 415         msg, err := c.Stream.RecvMsg()
 416         if err != nil {
 417                 return nil, err
 418         }
 419         switch m := msg.(type) {
 420         case *Nat44InterfaceDetails:
 421                 return m, nil
 422         case *memclnt.ControlPingReply:
 423                 err = c.Stream.Close()
 424                 if err != nil {
 425                         return nil, err
 426                 }
 427                 return nil, io.EOF
 428         default:
 429                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 430         }
 431 }
 432
 433 func (c *serviceClient) Nat44InterfaceOutputFeatureDump(ctx context.Context, in *Nat44InterfaceOutputFeatureDump) (RPCService_Nat44InterfaceOutputFeatureDumpClient, error) {
 434         stream, err := c.conn.NewStream(ctx)
 435         if err != nil {
 436                 return nil, err
 437         }
 438         x := &serviceClient_Nat44InterfaceOutputFeatureDumpClient{stream}
 439         if err := x.Stream.SendMsg(in); err != nil {
 440                 return nil, err
 441         }
 442         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 443                 return nil, err
 444         }
 445         return x, nil
 446 }
 447
 448 type RPCService_Nat44InterfaceOutputFeatureDumpClient interface {
 449         Recv() (*Nat44InterfaceOutputFeatureDetails, error)
 450         api.Stream
 451 }
 452
 453 type serviceClient_Nat44InterfaceOutputFeatureDumpClient struct {
 454         api.Stream
 455 }
 456
 457 func (c *serviceClient_Nat44InterfaceOutputFeatureDumpClient) Recv() (*Nat44InterfaceOutputFeatureDetails, error) {
 458         msg, err := c.Stream.RecvMsg()
 459         if err != nil {
 460                 return nil, err
 461         }
 462         switch m := msg.(type) {
 463         case *Nat44InterfaceOutputFeatureDetails:
 464                 return m, nil
 465         case *memclnt.ControlPingReply:
 466                 err = c.Stream.Close()
 467                 if err != nil {
 468                         return nil, err
 469                 }
 470                 return nil, io.EOF
 471         default:
 472                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 473         }
 474 }
 475
 476 func (c *serviceClient) Nat44LbStaticMappingAddDelLocal(ctx context.Context, in *Nat44LbStaticMappingAddDelLocal) (*Nat44LbStaticMappingAddDelLocalReply, error) {
 477         out := new(Nat44LbStaticMappingAddDelLocalReply)
 478         err := c.conn.Invoke(ctx, in, out)
 479         if err != nil {
 480                 return nil, err
 481         }
 482         return out, api.RetvalToVPPApiError(out.Retval)
 483 }
 484
 485 func (c *serviceClient) Nat44LbStaticMappingDump(ctx context.Context, in *Nat44LbStaticMappingDump) (RPCService_Nat44LbStaticMappingDumpClient, error) {
 486         stream, err := c.conn.NewStream(ctx)
 487         if err != nil {
 488                 return nil, err
 489         }
 490         x := &serviceClient_Nat44LbStaticMappingDumpClient{stream}
 491         if err := x.Stream.SendMsg(in); err != nil {
 492                 return nil, err
 493         }
 494         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 495                 return nil, err
 496         }
 497         return x, nil
 498 }
 499
 500 type RPCService_Nat44LbStaticMappingDumpClient interface {
 501         Recv() (*Nat44LbStaticMappingDetails, error)
 502         api.Stream
 503 }
 504
 505 type serviceClient_Nat44LbStaticMappingDumpClient struct {
 506         api.Stream
 507 }
 508
 509 func (c *serviceClient_Nat44LbStaticMappingDumpClient) Recv() (*Nat44LbStaticMappingDetails, error) {
 510         msg, err := c.Stream.RecvMsg()
 511         if err != nil {
 512                 return nil, err
 513         }
 514         switch m := msg.(type) {
 515         case *Nat44LbStaticMappingDetails:
 516                 return m, nil
 517         case *memclnt.ControlPingReply:
 518                 err = c.Stream.Close()
 519                 if err != nil {
 520                         return nil, err
 521                 }
 522                 return nil, io.EOF
 523         default:
 524                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 525         }
 526 }
 527
 528 func (c *serviceClient) Nat44PluginEnableDisable(ctx context.Context, in *Nat44PluginEnableDisable) (*Nat44PluginEnableDisableReply, error) {
 529         out := new(Nat44PluginEnableDisableReply)
 530         err := c.conn.Invoke(ctx, in, out)
 531         if err != nil {
 532                 return nil, err
 533         }
 534         return out, api.RetvalToVPPApiError(out.Retval)
 535 }
 536
 537 func (c *serviceClient) Nat44SessionCleanup(ctx context.Context, in *Nat44SessionCleanup) (*Nat44SessionCleanupReply, error) {
 538         out := new(Nat44SessionCleanupReply)
 539         err := c.conn.Invoke(ctx, in, out)
 540         if err != nil {
 541                 return nil, err
 542         }
 543         return out, api.RetvalToVPPApiError(out.Retval)
 544 }
 545
 546 func (c *serviceClient) Nat44SetSessionLimit(ctx context.Context, in *Nat44SetSessionLimit) (*Nat44SetSessionLimitReply, error) {
 547         out := new(Nat44SetSessionLimitReply)
 548         err := c.conn.Invoke(ctx, in, out)
 549         if err != nil {
 550                 return nil, err
 551         }
 552         return out, api.RetvalToVPPApiError(out.Retval)
 553 }
 554
 555 func (c *serviceClient) Nat44ShowRunningConfig(ctx context.Context, in *Nat44ShowRunningConfig) (*Nat44ShowRunningConfigReply, error) {
 556         out := new(Nat44ShowRunningConfigReply)
 557         err := c.conn.Invoke(ctx, in, out)
 558         if err != nil {
 559                 return nil, err
 560         }
 561         return out, api.RetvalToVPPApiError(out.Retval)
 562 }
 563
 564 func (c *serviceClient) Nat44StaticMappingDump(ctx context.Context, in *Nat44StaticMappingDump) (RPCService_Nat44StaticMappingDumpClient, error) {
 565         stream, err := c.conn.NewStream(ctx)
 566         if err != nil {
 567                 return nil, err
 568         }
 569         x := &serviceClient_Nat44StaticMappingDumpClient{stream}
 570         if err := x.Stream.SendMsg(in); err != nil {
 571                 return nil, err
 572         }
 573         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 574                 return nil, err
 575         }
 576         return x, nil
 577 }
 578
 579 type RPCService_Nat44StaticMappingDumpClient interface {
 580         Recv() (*Nat44StaticMappingDetails, error)
 581         api.Stream
 582 }
 583
 584 type serviceClient_Nat44StaticMappingDumpClient struct {
 585         api.Stream
 586 }
 587
 588 func (c *serviceClient_Nat44StaticMappingDumpClient) Recv() (*Nat44StaticMappingDetails, error) {
 589         msg, err := c.Stream.RecvMsg()
 590         if err != nil {
 591                 return nil, err
 592         }
 593         switch m := msg.(type) {
 594         case *Nat44StaticMappingDetails:
 595                 return m, nil
 596         case *memclnt.ControlPingReply:
 597                 err = c.Stream.Close()
 598                 if err != nil {
 599                         return nil, err
 600                 }
 601                 return nil, io.EOF
 602         default:
 603                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 604         }
 605 }
 606
 607 func (c *serviceClient) Nat44UserDump(ctx context.Context, in *Nat44UserDump) (RPCService_Nat44UserDumpClient, error) {
 608         stream, err := c.conn.NewStream(ctx)
 609         if err != nil {
 610                 return nil, err
 611         }
 612         x := &serviceClient_Nat44UserDumpClient{stream}
 613         if err := x.Stream.SendMsg(in); err != nil {
 614                 return nil, err
 615         }
 616         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 617                 return nil, err
 618         }
 619         return x, nil
 620 }
 621
 622 type RPCService_Nat44UserDumpClient interface {
 623         Recv() (*Nat44UserDetails, error)
 624         api.Stream
 625 }
 626
 627 type serviceClient_Nat44UserDumpClient struct {
 628         api.Stream
 629 }
 630
 631 func (c *serviceClient_Nat44UserDumpClient) Recv() (*Nat44UserDetails, error) {
 632         msg, err := c.Stream.RecvMsg()
 633         if err != nil {
 634                 return nil, err
 635         }
 636         switch m := msg.(type) {
 637         case *Nat44UserDetails:
 638                 return m, nil
 639         case *memclnt.ControlPingReply:
 640                 err = c.Stream.Close()
 641                 if err != nil {
 642                         return nil, err
 643                 }
 644                 return nil, io.EOF
 645         default:
 646                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 647         }
 648 }
 649
 650 func (c *serviceClient) Nat44UserSessionDump(ctx context.Context, in *Nat44UserSessionDump) (RPCService_Nat44UserSessionDumpClient, error) {
 651         stream, err := c.conn.NewStream(ctx)
 652         if err != nil {
 653                 return nil, err
 654         }
 655         x := &serviceClient_Nat44UserSessionDumpClient{stream}
 656         if err := x.Stream.SendMsg(in); err != nil {
 657                 return nil, err
 658         }
 659         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 660                 return nil, err
 661         }
 662         return x, nil
 663 }
 664
 665 type RPCService_Nat44UserSessionDumpClient interface {
 666         Recv() (*Nat44UserSessionDetails, error)
 667         api.Stream
 668 }
 669
 670 type serviceClient_Nat44UserSessionDumpClient struct {
 671         api.Stream
 672 }
 673
 674 func (c *serviceClient_Nat44UserSessionDumpClient) Recv() (*Nat44UserSessionDetails, error) {
 675         msg, err := c.Stream.RecvMsg()
 676         if err != nil {
 677                 return nil, err
 678         }
 679         switch m := msg.(type) {
 680         case *Nat44UserSessionDetails:
 681                 return m, nil
 682         case *memclnt.ControlPingReply:
 683                 err = c.Stream.Close()
 684                 if err != nil {
 685                         return nil, err
 686                 }
 687                 return nil, io.EOF
 688         default:
 689                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 690         }
 691 }
 692
 693 func (c *serviceClient) Nat44UserSessionV2Dump(ctx context.Context, in *Nat44UserSessionV2Dump) (RPCService_Nat44UserSessionV2DumpClient, error) {
 694         stream, err := c.conn.NewStream(ctx)
 695         if err != nil {
 696                 return nil, err
 697         }
 698         x := &serviceClient_Nat44UserSessionV2DumpClient{stream}
 699         if err := x.Stream.SendMsg(in); err != nil {
 700                 return nil, err
 701         }
 702         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 703                 return nil, err
 704         }
 705         return x, nil
 706 }
 707
 708 type RPCService_Nat44UserSessionV2DumpClient interface {
 709         Recv() (*Nat44UserSessionV2Details, error)
 710         api.Stream
 711 }
 712
 713 type serviceClient_Nat44UserSessionV2DumpClient struct {
 714         api.Stream
 715 }
 716
 717 func (c *serviceClient_Nat44UserSessionV2DumpClient) Recv() (*Nat44UserSessionV2Details, error) {
 718         msg, err := c.Stream.RecvMsg()
 719         if err != nil {
 720                 return nil, err
 721         }
 722         switch m := msg.(type) {
 723         case *Nat44UserSessionV2Details:
 724                 return m, nil
 725         case *memclnt.ControlPingReply:
 726                 err = c.Stream.Close()
 727                 if err != nil {
 728                         return nil, err
 729                 }
 730                 return nil, io.EOF
 731         default:
 732                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 733         }
 734 }
 735
 736 func (c *serviceClient) NatControlPing(ctx context.Context, in *NatControlPing) (*NatControlPingReply, error) {
 737         out := new(NatControlPingReply)
 738         err := c.conn.Invoke(ctx, in, out)
 739         if err != nil {
 740                 return nil, err
 741         }
 742         return out, api.RetvalToVPPApiError(out.Retval)
 743 }
 744
 745 func (c *serviceClient) NatGetAddrAndPortAllocAlg(ctx context.Context, in *NatGetAddrAndPortAllocAlg) (*NatGetAddrAndPortAllocAlgReply, error) {
 746         out := new(NatGetAddrAndPortAllocAlgReply)
 747         err := c.conn.Invoke(ctx, in, out)
 748         if err != nil {
 749                 return nil, err
 750         }
 751         return out, api.RetvalToVPPApiError(out.Retval)
 752 }
 753
 754 func (c *serviceClient) NatGetMssClamping(ctx context.Context, in *NatGetMssClamping) (*NatGetMssClampingReply, error) {
 755         out := new(NatGetMssClampingReply)
 756         err := c.conn.Invoke(ctx, in, out)
 757         if err != nil {
 758                 return nil, err
 759         }
 760         return out, api.RetvalToVPPApiError(out.Retval)
 761 }
 762
 763 func (c *serviceClient) NatGetTimeouts(ctx context.Context, in *NatGetTimeouts) (*NatGetTimeoutsReply, error) {
 764         out := new(NatGetTimeoutsReply)
 765         err := c.conn.Invoke(ctx, in, out)
 766         if err != nil {
 767                 return nil, err
 768         }
 769         return out, api.RetvalToVPPApiError(out.Retval)
 770 }
 771
 772 func (c *serviceClient) NatHaFlush(ctx context.Context, in *NatHaFlush) (*NatHaFlushReply, error) {
 773         out := new(NatHaFlushReply)
 774         err := c.conn.Invoke(ctx, in, out)
 775         if err != nil {
 776                 return nil, err
 777         }
 778         return out, api.RetvalToVPPApiError(out.Retval)
 779 }
 780
 781 func (c *serviceClient) NatHaGetFailover(ctx context.Context, in *NatHaGetFailover) (*NatHaGetFailoverReply, error) {
 782         out := new(NatHaGetFailoverReply)
 783         err := c.conn.Invoke(ctx, in, out)
 784         if err != nil {
 785                 return nil, err
 786         }
 787         return out, api.RetvalToVPPApiError(out.Retval)
 788 }
 789
 790 func (c *serviceClient) NatHaGetListener(ctx context.Context, in *NatHaGetListener) (*NatHaGetListenerReply, error) {
 791         out := new(NatHaGetListenerReply)
 792         err := c.conn.Invoke(ctx, in, out)
 793         if err != nil {
 794                 return nil, err
 795         }
 796         return out, api.RetvalToVPPApiError(out.Retval)
 797 }
 798
 799 func (c *serviceClient) NatHaResync(ctx context.Context, in *NatHaResync) (*NatHaResyncReply, error) {
 800         out := new(NatHaResyncReply)
 801         err := c.conn.Invoke(ctx, in, out)
 802         if err != nil {
 803                 return nil, err
 804         }
 805         return out, api.RetvalToVPPApiError(out.Retval)
 806 }
 807
 808 func (c *serviceClient) NatHaSetFailover(ctx context.Context, in *NatHaSetFailover) (*NatHaSetFailoverReply, error) {
 809         out := new(NatHaSetFailoverReply)
 810         err := c.conn.Invoke(ctx, in, out)
 811         if err != nil {
 812                 return nil, err
 813         }
 814         return out, api.RetvalToVPPApiError(out.Retval)
 815 }
 816
 817 func (c *serviceClient) NatHaSetListener(ctx context.Context, in *NatHaSetListener) (*NatHaSetListenerReply, error) {
 818         out := new(NatHaSetListenerReply)
 819         err := c.conn.Invoke(ctx, in, out)
 820         if err != nil {
 821                 return nil, err
 822         }
 823         return out, api.RetvalToVPPApiError(out.Retval)
 824 }
 825
 826 func (c *serviceClient) NatIpfixEnableDisable(ctx context.Context, in *NatIpfixEnableDisable) (*NatIpfixEnableDisableReply, error) {
 827         out := new(NatIpfixEnableDisableReply)
 828         err := c.conn.Invoke(ctx, in, out)
 829         if err != nil {
 830                 return nil, err
 831         }
 832         return out, api.RetvalToVPPApiError(out.Retval)
 833 }
 834
 835 func (c *serviceClient) NatSetAddrAndPortAllocAlg(ctx context.Context, in *NatSetAddrAndPortAllocAlg) (*NatSetAddrAndPortAllocAlgReply, error) {
 836         out := new(NatSetAddrAndPortAllocAlgReply)
 837         err := c.conn.Invoke(ctx, in, out)
 838         if err != nil {
 839                 return nil, err
 840         }
 841         return out, api.RetvalToVPPApiError(out.Retval)
 842 }
 843
 844 func (c *serviceClient) NatSetLogLevel(ctx context.Context, in *NatSetLogLevel) (*NatSetLogLevelReply, error) {
 845         out := new(NatSetLogLevelReply)
 846         err := c.conn.Invoke(ctx, in, out)
 847         if err != nil {
 848                 return nil, err
 849         }
 850         return out, api.RetvalToVPPApiError(out.Retval)
 851 }
 852
 853 func (c *serviceClient) NatSetMssClamping(ctx context.Context, in *NatSetMssClamping) (*NatSetMssClampingReply, error) {
 854         out := new(NatSetMssClampingReply)
 855         err := c.conn.Invoke(ctx, in, out)
 856         if err != nil {
 857                 return nil, err
 858         }
 859         return out, api.RetvalToVPPApiError(out.Retval)
 860 }
 861
 862 func (c *serviceClient) NatSetTimeouts(ctx context.Context, in *NatSetTimeouts) (*NatSetTimeoutsReply, error) {
 863         out := new(NatSetTimeoutsReply)
 864         err := c.conn.Invoke(ctx, in, out)
 865         if err != nil {
 866                 return nil, err
 867         }
 868         return out, api.RetvalToVPPApiError(out.Retval)
 869 }
 870
 871 func (c *serviceClient) NatSetWorkers(ctx context.Context, in *NatSetWorkers) (*NatSetWorkersReply, error) {
 872         out := new(NatSetWorkersReply)
 873         err := c.conn.Invoke(ctx, in, out)
 874         if err != nil {
 875                 return nil, err
 876         }
 877         return out, api.RetvalToVPPApiError(out.Retval)
 878 }
 879
 880 func (c *serviceClient) NatShowConfig(ctx context.Context, in *NatShowConfig) (*NatShowConfigReply, error) {
 881         out := new(NatShowConfigReply)
 882         err := c.conn.Invoke(ctx, in, out)
 883         if err != nil {
 884                 return nil, err
 885         }
 886         return out, api.RetvalToVPPApiError(out.Retval)
 887 }
 888
 889 func (c *serviceClient) NatShowConfig2(ctx context.Context, in *NatShowConfig2) (*NatShowConfig2Reply, error) {
 890         out := new(NatShowConfig2Reply)
 891         err := c.conn.Invoke(ctx, in, out)
 892         if err != nil {
 893                 return nil, err
 894         }
 895         return out, api.RetvalToVPPApiError(out.Retval)
 896 }
 897
 898 func (c *serviceClient) NatWorkerDump(ctx context.Context, in *NatWorkerDump) (RPCService_NatWorkerDumpClient, error) {
 899         stream, err := c.conn.NewStream(ctx)
 900         if err != nil {
 901                 return nil, err
 902         }
 903         x := &serviceClient_NatWorkerDumpClient{stream}
 904         if err := x.Stream.SendMsg(in); err != nil {
 905                 return nil, err
 906         }
 907         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 908                 return nil, err
 909         }
 910         return x, nil
 911 }
 912
 913 type RPCService_NatWorkerDumpClient interface {
 914         Recv() (*NatWorkerDetails, error)
 915         api.Stream
 916 }
 917
 918 type serviceClient_NatWorkerDumpClient struct {
 919         api.Stream
 920 }
 921
 922 func (c *serviceClient_NatWorkerDumpClient) Recv() (*NatWorkerDetails, error) {
 923         msg, err := c.Stream.RecvMsg()
 924         if err != nil {
 925                 return nil, err
 926         }
 927         switch m := msg.(type) {
 928         case *NatWorkerDetails:
 929                 return m, nil
 930         case *memclnt.ControlPingReply:
 931                 err = c.Stream.Close()
 932                 if err != nil {
 933                         return nil, err
 934                 }
 935                 return nil, io.EOF
 936         default:
 937                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 938         }
 939 }