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