codec/testdata/binapi2001/ip/ip_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package ip
   4
   5 import (
   6         "context"
   7         "io"
   8
   9         api "git.fd.io/govpp.git/api"
  10 )
  11
  12 // RPCService represents RPC service API for ip module.
  13 type RPCService interface {
  14         DumpIPAddress(ctx context.Context, in *IPAddressDump) (RPCService_DumpIPAddressClient, error)
  15         DumpIPContainerProxy(ctx context.Context, in *IPContainerProxyDump) (RPCService_DumpIPContainerProxyClient, error)
  16         DumpIP(ctx context.Context, in *IPDump) (RPCService_DumpIPClient, error)
  17         DumpIPMroute(ctx context.Context, in *IPMrouteDump) (RPCService_DumpIPMrouteClient, error)
  18         DumpIPMtable(ctx context.Context, in *IPMtableDump) (RPCService_DumpIPMtableClient, error)
  19         DumpIPPuntRedirect(ctx context.Context, in *IPPuntRedirectDump) (RPCService_DumpIPPuntRedirectClient, error)
  20         DumpIPRoute(ctx context.Context, in *IPRouteDump) (RPCService_DumpIPRouteClient, error)
  21         DumpIPTable(ctx context.Context, in *IPTableDump) (RPCService_DumpIPTableClient, error)
  22         DumpIPUnnumbered(ctx context.Context, in *IPUnnumberedDump) (RPCService_DumpIPUnnumberedClient, error)
  23         DumpMfibSignal(ctx context.Context, in *MfibSignalDump) (RPCService_DumpMfibSignalClient, error)
  24         IoamDisable(ctx context.Context, in *IoamDisable) (*IoamDisableReply, error)
  25         IoamEnable(ctx context.Context, in *IoamEnable) (*IoamEnableReply, error)
  26         IPContainerProxyAddDel(ctx context.Context, in *IPContainerProxyAddDel) (*IPContainerProxyAddDelReply, error)
  27         IPMrouteAddDel(ctx context.Context, in *IPMrouteAddDel) (*IPMrouteAddDelReply, error)
  28         IPPuntPolice(ctx context.Context, in *IPPuntPolice) (*IPPuntPoliceReply, error)
  29         IPPuntRedirect(ctx context.Context, in *IPPuntRedirect) (*IPPuntRedirectReply, error)
  30         IPReassemblyEnableDisable(ctx context.Context, in *IPReassemblyEnableDisable) (*IPReassemblyEnableDisableReply, error)
  31         IPReassemblyGet(ctx context.Context, in *IPReassemblyGet) (*IPReassemblyGetReply, error)
  32         IPReassemblySet(ctx context.Context, in *IPReassemblySet) (*IPReassemblySetReply, error)
  33         IPRouteAddDel(ctx context.Context, in *IPRouteAddDel) (*IPRouteAddDelReply, error)
  34         IPSourceAndPortRangeCheckAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckAddDel) (*IPSourceAndPortRangeCheckAddDelReply, error)
  35         IPSourceAndPortRangeCheckInterfaceAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckInterfaceAddDel) (*IPSourceAndPortRangeCheckInterfaceAddDelReply, error)
  36         IPSourceCheckInterfaceAddDel(ctx context.Context, in *IPSourceCheckInterfaceAddDel) (*IPSourceCheckInterfaceAddDelReply, error)
  37         IPTableAddDel(ctx context.Context, in *IPTableAddDel) (*IPTableAddDelReply, error)
  38         IPTableFlush(ctx context.Context, in *IPTableFlush) (*IPTableFlushReply, error)
  39         IPTableReplaceBegin(ctx context.Context, in *IPTableReplaceBegin) (*IPTableReplaceBeginReply, error)
  40         IPTableReplaceEnd(ctx context.Context, in *IPTableReplaceEnd) (*IPTableReplaceEndReply, error)
  41         SetIPFlowHash(ctx context.Context, in *SetIPFlowHash) (*SetIPFlowHashReply, error)
  42         SwInterfaceIP6EnableDisable(ctx context.Context, in *SwInterfaceIP6EnableDisable) (*SwInterfaceIP6EnableDisableReply, error)
  43         SwInterfaceIP6SetLinkLocalAddress(ctx context.Context, in *SwInterfaceIP6SetLinkLocalAddress) (*SwInterfaceIP6SetLinkLocalAddressReply, error)
  44 }
  45
  46 type serviceClient struct {
  47         ch api.Channel
  48 }
  49
  50 func NewServiceClient(ch api.Channel) RPCService {
  51         return &serviceClient{ch}
  52 }
  53
  54 func (c *serviceClient) DumpIPAddress(ctx context.Context, in *IPAddressDump) (RPCService_DumpIPAddressClient, error) {
  55         stream := c.ch.SendMultiRequest(in)
  56         x := &serviceClient_DumpIPAddressClient{stream}
  57         return x, nil
  58 }
  59
  60 type RPCService_DumpIPAddressClient interface {
  61         Recv() (*IPAddressDetails, error)
  62 }
  63
  64 type serviceClient_DumpIPAddressClient struct {
  65         api.MultiRequestCtx
  66 }
  67
  68 func (c *serviceClient_DumpIPAddressClient) Recv() (*IPAddressDetails, error) {
  69         m := new(IPAddressDetails)
  70         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  71         if err != nil {
  72                 return nil, err
  73         }
  74         if stop {
  75                 return nil, io.EOF
  76         }
  77         return m, nil
  78 }
  79
  80 func (c *serviceClient) DumpIPContainerProxy(ctx context.Context, in *IPContainerProxyDump) (RPCService_DumpIPContainerProxyClient, error) {
  81         stream := c.ch.SendMultiRequest(in)
  82         x := &serviceClient_DumpIPContainerProxyClient{stream}
  83         return x, nil
  84 }
  85
  86 type RPCService_DumpIPContainerProxyClient interface {
  87         Recv() (*IPContainerProxyDetails, error)
  88 }
  89
  90 type serviceClient_DumpIPContainerProxyClient struct {
  91         api.MultiRequestCtx
  92 }
  93
  94 func (c *serviceClient_DumpIPContainerProxyClient) Recv() (*IPContainerProxyDetails, error) {
  95         m := new(IPContainerProxyDetails)
  96         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  97         if err != nil {
  98                 return nil, err
  99         }
 100         if stop {
 101                 return nil, io.EOF
 102         }
 103         return m, nil
 104 }
 105
 106 func (c *serviceClient) DumpIP(ctx context.Context, in *IPDump) (RPCService_DumpIPClient, error) {
 107         stream := c.ch.SendMultiRequest(in)
 108         x := &serviceClient_DumpIPClient{stream}
 109         return x, nil
 110 }
 111
 112 type RPCService_DumpIPClient interface {
 113         Recv() (*IPDetails, error)
 114 }
 115
 116 type serviceClient_DumpIPClient struct {
 117         api.MultiRequestCtx
 118 }
 119
 120 func (c *serviceClient_DumpIPClient) Recv() (*IPDetails, error) {
 121         m := new(IPDetails)
 122         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 123         if err != nil {
 124                 return nil, err
 125         }
 126         if stop {
 127                 return nil, io.EOF
 128         }
 129         return m, nil
 130 }
 131
 132 func (c *serviceClient) DumpIPMroute(ctx context.Context, in *IPMrouteDump) (RPCService_DumpIPMrouteClient, error) {
 133         stream := c.ch.SendMultiRequest(in)
 134         x := &serviceClient_DumpIPMrouteClient{stream}
 135         return x, nil
 136 }
 137
 138 type RPCService_DumpIPMrouteClient interface {
 139         Recv() (*IPMrouteDetails, error)
 140 }
 141
 142 type serviceClient_DumpIPMrouteClient struct {
 143         api.MultiRequestCtx
 144 }
 145
 146 func (c *serviceClient_DumpIPMrouteClient) Recv() (*IPMrouteDetails, error) {
 147         m := new(IPMrouteDetails)
 148         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 149         if err != nil {
 150                 return nil, err
 151         }
 152         if stop {
 153                 return nil, io.EOF
 154         }
 155         return m, nil
 156 }
 157
 158 func (c *serviceClient) DumpIPMtable(ctx context.Context, in *IPMtableDump) (RPCService_DumpIPMtableClient, error) {
 159         stream := c.ch.SendMultiRequest(in)
 160         x := &serviceClient_DumpIPMtableClient{stream}
 161         return x, nil
 162 }
 163
 164 type RPCService_DumpIPMtableClient interface {
 165         Recv() (*IPMtableDetails, error)
 166 }
 167
 168 type serviceClient_DumpIPMtableClient struct {
 169         api.MultiRequestCtx
 170 }
 171
 172 func (c *serviceClient_DumpIPMtableClient) Recv() (*IPMtableDetails, error) {
 173         m := new(IPMtableDetails)
 174         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 175         if err != nil {
 176                 return nil, err
 177         }
 178         if stop {
 179                 return nil, io.EOF
 180         }
 181         return m, nil
 182 }
 183
 184 func (c *serviceClient) DumpIPPuntRedirect(ctx context.Context, in *IPPuntRedirectDump) (RPCService_DumpIPPuntRedirectClient, error) {
 185         stream := c.ch.SendMultiRequest(in)
 186         x := &serviceClient_DumpIPPuntRedirectClient{stream}
 187         return x, nil
 188 }
 189
 190 type RPCService_DumpIPPuntRedirectClient interface {
 191         Recv() (*IPPuntRedirectDetails, error)
 192 }
 193
 194 type serviceClient_DumpIPPuntRedirectClient struct {
 195         api.MultiRequestCtx
 196 }
 197
 198 func (c *serviceClient_DumpIPPuntRedirectClient) Recv() (*IPPuntRedirectDetails, error) {
 199         m := new(IPPuntRedirectDetails)
 200         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 201         if err != nil {
 202                 return nil, err
 203         }
 204         if stop {
 205                 return nil, io.EOF
 206         }
 207         return m, nil
 208 }
 209
 210 func (c *serviceClient) DumpIPRoute(ctx context.Context, in *IPRouteDump) (RPCService_DumpIPRouteClient, error) {
 211         stream := c.ch.SendMultiRequest(in)
 212         x := &serviceClient_DumpIPRouteClient{stream}
 213         return x, nil
 214 }
 215
 216 type RPCService_DumpIPRouteClient interface {
 217         Recv() (*IPRouteDetails, error)
 218 }
 219
 220 type serviceClient_DumpIPRouteClient struct {
 221         api.MultiRequestCtx
 222 }
 223
 224 func (c *serviceClient_DumpIPRouteClient) Recv() (*IPRouteDetails, error) {
 225         m := new(IPRouteDetails)
 226         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 227         if err != nil {
 228                 return nil, err
 229         }
 230         if stop {
 231                 return nil, io.EOF
 232         }
 233         return m, nil
 234 }
 235
 236 func (c *serviceClient) DumpIPTable(ctx context.Context, in *IPTableDump) (RPCService_DumpIPTableClient, error) {
 237         stream := c.ch.SendMultiRequest(in)
 238         x := &serviceClient_DumpIPTableClient{stream}
 239         return x, nil
 240 }
 241
 242 type RPCService_DumpIPTableClient interface {
 243         Recv() (*IPTableDetails, error)
 244 }
 245
 246 type serviceClient_DumpIPTableClient struct {
 247         api.MultiRequestCtx
 248 }
 249
 250 func (c *serviceClient_DumpIPTableClient) Recv() (*IPTableDetails, error) {
 251         m := new(IPTableDetails)
 252         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 253         if err != nil {
 254                 return nil, err
 255         }
 256         if stop {
 257                 return nil, io.EOF
 258         }
 259         return m, nil
 260 }
 261
 262 func (c *serviceClient) DumpIPUnnumbered(ctx context.Context, in *IPUnnumberedDump) (RPCService_DumpIPUnnumberedClient, error) {
 263         stream := c.ch.SendMultiRequest(in)
 264         x := &serviceClient_DumpIPUnnumberedClient{stream}
 265         return x, nil
 266 }
 267
 268 type RPCService_DumpIPUnnumberedClient interface {
 269         Recv() (*IPUnnumberedDetails, error)
 270 }
 271
 272 type serviceClient_DumpIPUnnumberedClient struct {
 273         api.MultiRequestCtx
 274 }
 275
 276 func (c *serviceClient_DumpIPUnnumberedClient) Recv() (*IPUnnumberedDetails, error) {
 277         m := new(IPUnnumberedDetails)
 278         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 279         if err != nil {
 280                 return nil, err
 281         }
 282         if stop {
 283                 return nil, io.EOF
 284         }
 285         return m, nil
 286 }
 287
 288 func (c *serviceClient) DumpMfibSignal(ctx context.Context, in *MfibSignalDump) (RPCService_DumpMfibSignalClient, error) {
 289         stream := c.ch.SendMultiRequest(in)
 290         x := &serviceClient_DumpMfibSignalClient{stream}
 291         return x, nil
 292 }
 293
 294 type RPCService_DumpMfibSignalClient interface {
 295         Recv() (*MfibSignalDetails, error)
 296 }
 297
 298 type serviceClient_DumpMfibSignalClient struct {
 299         api.MultiRequestCtx
 300 }
 301
 302 func (c *serviceClient_DumpMfibSignalClient) Recv() (*MfibSignalDetails, error) {
 303         m := new(MfibSignalDetails)
 304         stop, err := c.MultiRequestCtx.ReceiveReply(m)
 305         if err != nil {
 306                 return nil, err
 307         }
 308         if stop {
 309                 return nil, io.EOF
 310         }
 311         return m, nil
 312 }
 313
 314 func (c *serviceClient) IoamDisable(ctx context.Context, in *IoamDisable) (*IoamDisableReply, error) {
 315         out := new(IoamDisableReply)
 316         err := c.ch.SendRequest(in).ReceiveReply(out)
 317         if err != nil {
 318                 return nil, err
 319         }
 320         return out, nil
 321 }
 322
 323 func (c *serviceClient) IoamEnable(ctx context.Context, in *IoamEnable) (*IoamEnableReply, error) {
 324         out := new(IoamEnableReply)
 325         err := c.ch.SendRequest(in).ReceiveReply(out)
 326         if err != nil {
 327                 return nil, err
 328         }
 329         return out, nil
 330 }
 331
 332 func (c *serviceClient) IPContainerProxyAddDel(ctx context.Context, in *IPContainerProxyAddDel) (*IPContainerProxyAddDelReply, error) {
 333         out := new(IPContainerProxyAddDelReply)
 334         err := c.ch.SendRequest(in).ReceiveReply(out)
 335         if err != nil {
 336                 return nil, err
 337         }
 338         return out, nil
 339 }
 340
 341 func (c *serviceClient) IPMrouteAddDel(ctx context.Context, in *IPMrouteAddDel) (*IPMrouteAddDelReply, error) {
 342         out := new(IPMrouteAddDelReply)
 343         err := c.ch.SendRequest(in).ReceiveReply(out)
 344         if err != nil {
 345                 return nil, err
 346         }
 347         return out, nil
 348 }
 349
 350 func (c *serviceClient) IPPuntPolice(ctx context.Context, in *IPPuntPolice) (*IPPuntPoliceReply, error) {
 351         out := new(IPPuntPoliceReply)
 352         err := c.ch.SendRequest(in).ReceiveReply(out)
 353         if err != nil {
 354                 return nil, err
 355         }
 356         return out, nil
 357 }
 358
 359 func (c *serviceClient) IPPuntRedirect(ctx context.Context, in *IPPuntRedirect) (*IPPuntRedirectReply, error) {
 360         out := new(IPPuntRedirectReply)
 361         err := c.ch.SendRequest(in).ReceiveReply(out)
 362         if err != nil {
 363                 return nil, err
 364         }
 365         return out, nil
 366 }
 367
 368 func (c *serviceClient) IPReassemblyEnableDisable(ctx context.Context, in *IPReassemblyEnableDisable) (*IPReassemblyEnableDisableReply, error) {
 369         out := new(IPReassemblyEnableDisableReply)
 370         err := c.ch.SendRequest(in).ReceiveReply(out)
 371         if err != nil {
 372                 return nil, err
 373         }
 374         return out, nil
 375 }
 376
 377 func (c *serviceClient) IPReassemblyGet(ctx context.Context, in *IPReassemblyGet) (*IPReassemblyGetReply, error) {
 378         out := new(IPReassemblyGetReply)
 379         err := c.ch.SendRequest(in).ReceiveReply(out)
 380         if err != nil {
 381                 return nil, err
 382         }
 383         return out, nil
 384 }
 385
 386 func (c *serviceClient) IPReassemblySet(ctx context.Context, in *IPReassemblySet) (*IPReassemblySetReply, error) {
 387         out := new(IPReassemblySetReply)
 388         err := c.ch.SendRequest(in).ReceiveReply(out)
 389         if err != nil {
 390                 return nil, err
 391         }
 392         return out, nil
 393 }
 394
 395 func (c *serviceClient) IPRouteAddDel(ctx context.Context, in *IPRouteAddDel) (*IPRouteAddDelReply, error) {
 396         out := new(IPRouteAddDelReply)
 397         err := c.ch.SendRequest(in).ReceiveReply(out)
 398         if err != nil {
 399                 return nil, err
 400         }
 401         return out, nil
 402 }
 403
 404 func (c *serviceClient) IPSourceAndPortRangeCheckAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckAddDel) (*IPSourceAndPortRangeCheckAddDelReply, error) {
 405         out := new(IPSourceAndPortRangeCheckAddDelReply)
 406         err := c.ch.SendRequest(in).ReceiveReply(out)
 407         if err != nil {
 408                 return nil, err
 409         }
 410         return out, nil
 411 }
 412
 413 func (c *serviceClient) IPSourceAndPortRangeCheckInterfaceAddDel(ctx context.Context, in *IPSourceAndPortRangeCheckInterfaceAddDel) (*IPSourceAndPortRangeCheckInterfaceAddDelReply, error) {
 414         out := new(IPSourceAndPortRangeCheckInterfaceAddDelReply)
 415         err := c.ch.SendRequest(in).ReceiveReply(out)
 416         if err != nil {
 417                 return nil, err
 418         }
 419         return out, nil
 420 }
 421
 422 func (c *serviceClient) IPSourceCheckInterfaceAddDel(ctx context.Context, in *IPSourceCheckInterfaceAddDel) (*IPSourceCheckInterfaceAddDelReply, error) {
 423         out := new(IPSourceCheckInterfaceAddDelReply)
 424         err := c.ch.SendRequest(in).ReceiveReply(out)
 425         if err != nil {
 426                 return nil, err
 427         }
 428         return out, nil
 429 }
 430
 431 func (c *serviceClient) IPTableAddDel(ctx context.Context, in *IPTableAddDel) (*IPTableAddDelReply, error) {
 432         out := new(IPTableAddDelReply)
 433         err := c.ch.SendRequest(in).ReceiveReply(out)
 434         if err != nil {
 435                 return nil, err
 436         }
 437         return out, nil
 438 }
 439
 440 func (c *serviceClient) IPTableFlush(ctx context.Context, in *IPTableFlush) (*IPTableFlushReply, error) {
 441         out := new(IPTableFlushReply)
 442         err := c.ch.SendRequest(in).ReceiveReply(out)
 443         if err != nil {
 444                 return nil, err
 445         }
 446         return out, nil
 447 }
 448
 449 func (c *serviceClient) IPTableReplaceBegin(ctx context.Context, in *IPTableReplaceBegin) (*IPTableReplaceBeginReply, error) {
 450         out := new(IPTableReplaceBeginReply)
 451         err := c.ch.SendRequest(in).ReceiveReply(out)
 452         if err != nil {
 453                 return nil, err
 454         }
 455         return out, nil
 456 }
 457
 458 func (c *serviceClient) IPTableReplaceEnd(ctx context.Context, in *IPTableReplaceEnd) (*IPTableReplaceEndReply, error) {
 459         out := new(IPTableReplaceEndReply)
 460         err := c.ch.SendRequest(in).ReceiveReply(out)
 461         if err != nil {
 462                 return nil, err
 463         }
 464         return out, nil
 465 }
 466
 467 func (c *serviceClient) SetIPFlowHash(ctx context.Context, in *SetIPFlowHash) (*SetIPFlowHashReply, error) {
 468         out := new(SetIPFlowHashReply)
 469         err := c.ch.SendRequest(in).ReceiveReply(out)
 470         if err != nil {
 471                 return nil, err
 472         }
 473         return out, nil
 474 }
 475
 476 func (c *serviceClient) SwInterfaceIP6EnableDisable(ctx context.Context, in *SwInterfaceIP6EnableDisable) (*SwInterfaceIP6EnableDisableReply, error) {
 477         out := new(SwInterfaceIP6EnableDisableReply)
 478         err := c.ch.SendRequest(in).ReceiveReply(out)
 479         if err != nil {
 480                 return nil, err
 481         }
 482         return out, nil
 483 }
 484
 485 func (c *serviceClient) SwInterfaceIP6SetLinkLocalAddress(ctx context.Context, in *SwInterfaceIP6SetLinkLocalAddress) (*SwInterfaceIP6SetLinkLocalAddressReply, error) {
 486         out := new(SwInterfaceIP6SetLinkLocalAddressReply)
 487         err := c.ch.SendRequest(in).ReceiveReply(out)
 488         if err != nil {
 489                 return nil, err
 490         }
 491         return out, nil
 492 }
 493
 494 // Reference imports to suppress errors if they are not otherwise used.
 495 var _ = api.RegisterMessage
 496 var _ = context.Background
 497 var _ = io.Copy