binapi/ipsec/ipsec_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package ipsec
   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 ipsec.
  15 type RPCService interface {
  16         IpsecBackendDump(ctx context.Context, in *IpsecBackendDump) (RPCService_IpsecBackendDumpClient, error)
  17         IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error)
  18         IpsecItfCreate(ctx context.Context, in *IpsecItfCreate) (*IpsecItfCreateReply, error)
  19         IpsecItfDelete(ctx context.Context, in *IpsecItfDelete) (*IpsecItfDeleteReply, error)
  20         IpsecItfDump(ctx context.Context, in *IpsecItfDump) (RPCService_IpsecItfDumpClient, error)
  21         IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error)
  22         IpsecSaV2Dump(ctx context.Context, in *IpsecSaV2Dump) (RPCService_IpsecSaV2DumpClient, error)
  23         IpsecSaV3Dump(ctx context.Context, in *IpsecSaV3Dump) (RPCService_IpsecSaV3DumpClient, error)
  24         IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error)
  25         IpsecSadEntryAddDelV2(ctx context.Context, in *IpsecSadEntryAddDelV2) (*IpsecSadEntryAddDelV2Reply, error)
  26         IpsecSadEntryAddDelV3(ctx context.Context, in *IpsecSadEntryAddDelV3) (*IpsecSadEntryAddDelV3Reply, error)
  27         IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error)
  28         IpsecSetAsyncMode(ctx context.Context, in *IpsecSetAsyncMode) (*IpsecSetAsyncModeReply, error)
  29         IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error)
  30         IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error)
  31         IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error)
  32         IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error)
  33         IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error)
  34         IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error)
  35         IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error)
  36         IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error)
  37 }
  38
  39 type serviceClient struct {
  40         conn api.Connection
  41 }
  42
  43 func NewServiceClient(conn api.Connection) RPCService {
  44         return &serviceClient{conn}
  45 }
  46
  47 func (c *serviceClient) IpsecBackendDump(ctx context.Context, in *IpsecBackendDump) (RPCService_IpsecBackendDumpClient, error) {
  48         stream, err := c.conn.NewStream(ctx)
  49         if err != nil {
  50                 return nil, err
  51         }
  52         x := &serviceClient_IpsecBackendDumpClient{stream}
  53         if err := x.Stream.SendMsg(in); err != nil {
  54                 return nil, err
  55         }
  56         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  57                 return nil, err
  58         }
  59         return x, nil
  60 }
  61
  62 type RPCService_IpsecBackendDumpClient interface {
  63         Recv() (*IpsecBackendDetails, error)
  64         api.Stream
  65 }
  66
  67 type serviceClient_IpsecBackendDumpClient struct {
  68         api.Stream
  69 }
  70
  71 func (c *serviceClient_IpsecBackendDumpClient) Recv() (*IpsecBackendDetails, error) {
  72         msg, err := c.Stream.RecvMsg()
  73         if err != nil {
  74                 return nil, err
  75         }
  76         switch m := msg.(type) {
  77         case *IpsecBackendDetails:
  78                 return m, nil
  79         case *vpe.ControlPingReply:
  80                 err = c.Stream.Close()
  81                 if err != nil {
  82                         return nil, err
  83                 }
  84                 return nil, io.EOF
  85         default:
  86                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  87         }
  88 }
  89
  90 func (c *serviceClient) IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error) {
  91         out := new(IpsecInterfaceAddDelSpdReply)
  92         err := c.conn.Invoke(ctx, in, out)
  93         if err != nil {
  94                 return nil, err
  95         }
  96         return out, api.RetvalToVPPApiError(out.Retval)
  97 }
  98
  99 func (c *serviceClient) IpsecItfCreate(ctx context.Context, in *IpsecItfCreate) (*IpsecItfCreateReply, error) {
 100         out := new(IpsecItfCreateReply)
 101         err := c.conn.Invoke(ctx, in, out)
 102         if err != nil {
 103                 return nil, err
 104         }
 105         return out, api.RetvalToVPPApiError(out.Retval)
 106 }
 107
 108 func (c *serviceClient) IpsecItfDelete(ctx context.Context, in *IpsecItfDelete) (*IpsecItfDeleteReply, error) {
 109         out := new(IpsecItfDeleteReply)
 110         err := c.conn.Invoke(ctx, in, out)
 111         if err != nil {
 112                 return nil, err
 113         }
 114         return out, api.RetvalToVPPApiError(out.Retval)
 115 }
 116
 117 func (c *serviceClient) IpsecItfDump(ctx context.Context, in *IpsecItfDump) (RPCService_IpsecItfDumpClient, error) {
 118         stream, err := c.conn.NewStream(ctx)
 119         if err != nil {
 120                 return nil, err
 121         }
 122         x := &serviceClient_IpsecItfDumpClient{stream}
 123         if err := x.Stream.SendMsg(in); err != nil {
 124                 return nil, err
 125         }
 126         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 127                 return nil, err
 128         }
 129         return x, nil
 130 }
 131
 132 type RPCService_IpsecItfDumpClient interface {
 133         Recv() (*IpsecItfDetails, error)
 134         api.Stream
 135 }
 136
 137 type serviceClient_IpsecItfDumpClient struct {
 138         api.Stream
 139 }
 140
 141 func (c *serviceClient_IpsecItfDumpClient) Recv() (*IpsecItfDetails, error) {
 142         msg, err := c.Stream.RecvMsg()
 143         if err != nil {
 144                 return nil, err
 145         }
 146         switch m := msg.(type) {
 147         case *IpsecItfDetails:
 148                 return m, nil
 149         case *vpe.ControlPingReply:
 150                 err = c.Stream.Close()
 151                 if err != nil {
 152                         return nil, err
 153                 }
 154                 return nil, io.EOF
 155         default:
 156                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 157         }
 158 }
 159
 160 func (c *serviceClient) IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error) {
 161         stream, err := c.conn.NewStream(ctx)
 162         if err != nil {
 163                 return nil, err
 164         }
 165         x := &serviceClient_IpsecSaDumpClient{stream}
 166         if err := x.Stream.SendMsg(in); err != nil {
 167                 return nil, err
 168         }
 169         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 170                 return nil, err
 171         }
 172         return x, nil
 173 }
 174
 175 type RPCService_IpsecSaDumpClient interface {
 176         Recv() (*IpsecSaDetails, error)
 177         api.Stream
 178 }
 179
 180 type serviceClient_IpsecSaDumpClient struct {
 181         api.Stream
 182 }
 183
 184 func (c *serviceClient_IpsecSaDumpClient) Recv() (*IpsecSaDetails, error) {
 185         msg, err := c.Stream.RecvMsg()
 186         if err != nil {
 187                 return nil, err
 188         }
 189         switch m := msg.(type) {
 190         case *IpsecSaDetails:
 191                 return m, nil
 192         case *vpe.ControlPingReply:
 193                 err = c.Stream.Close()
 194                 if err != nil {
 195                         return nil, err
 196                 }
 197                 return nil, io.EOF
 198         default:
 199                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 200         }
 201 }
 202
 203 func (c *serviceClient) IpsecSaV2Dump(ctx context.Context, in *IpsecSaV2Dump) (RPCService_IpsecSaV2DumpClient, error) {
 204         stream, err := c.conn.NewStream(ctx)
 205         if err != nil {
 206                 return nil, err
 207         }
 208         x := &serviceClient_IpsecSaV2DumpClient{stream}
 209         if err := x.Stream.SendMsg(in); err != nil {
 210                 return nil, err
 211         }
 212         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 213                 return nil, err
 214         }
 215         return x, nil
 216 }
 217
 218 type RPCService_IpsecSaV2DumpClient interface {
 219         Recv() (*IpsecSaV2Details, error)
 220         api.Stream
 221 }
 222
 223 type serviceClient_IpsecSaV2DumpClient struct {
 224         api.Stream
 225 }
 226
 227 func (c *serviceClient_IpsecSaV2DumpClient) Recv() (*IpsecSaV2Details, error) {
 228         msg, err := c.Stream.RecvMsg()
 229         if err != nil {
 230                 return nil, err
 231         }
 232         switch m := msg.(type) {
 233         case *IpsecSaV2Details:
 234                 return m, nil
 235         case *vpe.ControlPingReply:
 236                 err = c.Stream.Close()
 237                 if err != nil {
 238                         return nil, err
 239                 }
 240                 return nil, io.EOF
 241         default:
 242                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 243         }
 244 }
 245
 246 func (c *serviceClient) IpsecSaV3Dump(ctx context.Context, in *IpsecSaV3Dump) (RPCService_IpsecSaV3DumpClient, error) {
 247         stream, err := c.conn.NewStream(ctx)
 248         if err != nil {
 249                 return nil, err
 250         }
 251         x := &serviceClient_IpsecSaV3DumpClient{stream}
 252         if err := x.Stream.SendMsg(in); err != nil {
 253                 return nil, err
 254         }
 255         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 256                 return nil, err
 257         }
 258         return x, nil
 259 }
 260
 261 type RPCService_IpsecSaV3DumpClient interface {
 262         Recv() (*IpsecSaV3Details, error)
 263         api.Stream
 264 }
 265
 266 type serviceClient_IpsecSaV3DumpClient struct {
 267         api.Stream
 268 }
 269
 270 func (c *serviceClient_IpsecSaV3DumpClient) Recv() (*IpsecSaV3Details, error) {
 271         msg, err := c.Stream.RecvMsg()
 272         if err != nil {
 273                 return nil, err
 274         }
 275         switch m := msg.(type) {
 276         case *IpsecSaV3Details:
 277                 return m, nil
 278         case *vpe.ControlPingReply:
 279                 err = c.Stream.Close()
 280                 if err != nil {
 281                         return nil, err
 282                 }
 283                 return nil, io.EOF
 284         default:
 285                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 286         }
 287 }
 288
 289 func (c *serviceClient) IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error) {
 290         out := new(IpsecSadEntryAddDelReply)
 291         err := c.conn.Invoke(ctx, in, out)
 292         if err != nil {
 293                 return nil, err
 294         }
 295         return out, api.RetvalToVPPApiError(out.Retval)
 296 }
 297
 298 func (c *serviceClient) IpsecSadEntryAddDelV2(ctx context.Context, in *IpsecSadEntryAddDelV2) (*IpsecSadEntryAddDelV2Reply, error) {
 299         out := new(IpsecSadEntryAddDelV2Reply)
 300         err := c.conn.Invoke(ctx, in, out)
 301         if err != nil {
 302                 return nil, err
 303         }
 304         return out, api.RetvalToVPPApiError(out.Retval)
 305 }
 306
 307 func (c *serviceClient) IpsecSadEntryAddDelV3(ctx context.Context, in *IpsecSadEntryAddDelV3) (*IpsecSadEntryAddDelV3Reply, error) {
 308         out := new(IpsecSadEntryAddDelV3Reply)
 309         err := c.conn.Invoke(ctx, in, out)
 310         if err != nil {
 311                 return nil, err
 312         }
 313         return out, api.RetvalToVPPApiError(out.Retval)
 314 }
 315
 316 func (c *serviceClient) IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error) {
 317         out := new(IpsecSelectBackendReply)
 318         err := c.conn.Invoke(ctx, in, out)
 319         if err != nil {
 320                 return nil, err
 321         }
 322         return out, api.RetvalToVPPApiError(out.Retval)
 323 }
 324
 325 func (c *serviceClient) IpsecSetAsyncMode(ctx context.Context, in *IpsecSetAsyncMode) (*IpsecSetAsyncModeReply, error) {
 326         out := new(IpsecSetAsyncModeReply)
 327         err := c.conn.Invoke(ctx, in, out)
 328         if err != nil {
 329                 return nil, err
 330         }
 331         return out, api.RetvalToVPPApiError(out.Retval)
 332 }
 333
 334 func (c *serviceClient) IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error) {
 335         out := new(IpsecSpdAddDelReply)
 336         err := c.conn.Invoke(ctx, in, out)
 337         if err != nil {
 338                 return nil, err
 339         }
 340         return out, api.RetvalToVPPApiError(out.Retval)
 341 }
 342
 343 func (c *serviceClient) IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error) {
 344         stream, err := c.conn.NewStream(ctx)
 345         if err != nil {
 346                 return nil, err
 347         }
 348         x := &serviceClient_IpsecSpdDumpClient{stream}
 349         if err := x.Stream.SendMsg(in); err != nil {
 350                 return nil, err
 351         }
 352         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 353                 return nil, err
 354         }
 355         return x, nil
 356 }
 357
 358 type RPCService_IpsecSpdDumpClient interface {
 359         Recv() (*IpsecSpdDetails, error)
 360         api.Stream
 361 }
 362
 363 type serviceClient_IpsecSpdDumpClient struct {
 364         api.Stream
 365 }
 366
 367 func (c *serviceClient_IpsecSpdDumpClient) Recv() (*IpsecSpdDetails, error) {
 368         msg, err := c.Stream.RecvMsg()
 369         if err != nil {
 370                 return nil, err
 371         }
 372         switch m := msg.(type) {
 373         case *IpsecSpdDetails:
 374                 return m, nil
 375         case *vpe.ControlPingReply:
 376                 err = c.Stream.Close()
 377                 if err != nil {
 378                         return nil, err
 379                 }
 380                 return nil, io.EOF
 381         default:
 382                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 383         }
 384 }
 385
 386 func (c *serviceClient) IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error) {
 387         out := new(IpsecSpdEntryAddDelReply)
 388         err := c.conn.Invoke(ctx, in, out)
 389         if err != nil {
 390                 return nil, err
 391         }
 392         return out, api.RetvalToVPPApiError(out.Retval)
 393 }
 394
 395 func (c *serviceClient) IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error) {
 396         stream, err := c.conn.NewStream(ctx)
 397         if err != nil {
 398                 return nil, err
 399         }
 400         x := &serviceClient_IpsecSpdInterfaceDumpClient{stream}
 401         if err := x.Stream.SendMsg(in); err != nil {
 402                 return nil, err
 403         }
 404         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 405                 return nil, err
 406         }
 407         return x, nil
 408 }
 409
 410 type RPCService_IpsecSpdInterfaceDumpClient interface {
 411         Recv() (*IpsecSpdInterfaceDetails, error)
 412         api.Stream
 413 }
 414
 415 type serviceClient_IpsecSpdInterfaceDumpClient struct {
 416         api.Stream
 417 }
 418
 419 func (c *serviceClient_IpsecSpdInterfaceDumpClient) Recv() (*IpsecSpdInterfaceDetails, error) {
 420         msg, err := c.Stream.RecvMsg()
 421         if err != nil {
 422                 return nil, err
 423         }
 424         switch m := msg.(type) {
 425         case *IpsecSpdInterfaceDetails:
 426                 return m, nil
 427         case *vpe.ControlPingReply:
 428                 err = c.Stream.Close()
 429                 if err != nil {
 430                         return nil, err
 431                 }
 432                 return nil, io.EOF
 433         default:
 434                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 435         }
 436 }
 437
 438 func (c *serviceClient) IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error) {
 439         stream, err := c.conn.NewStream(ctx)
 440         if err != nil {
 441                 return nil, err
 442         }
 443         x := &serviceClient_IpsecSpdsDumpClient{stream}
 444         if err := x.Stream.SendMsg(in); err != nil {
 445                 return nil, err
 446         }
 447         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 448                 return nil, err
 449         }
 450         return x, nil
 451 }
 452
 453 type RPCService_IpsecSpdsDumpClient interface {
 454         Recv() (*IpsecSpdsDetails, error)
 455         api.Stream
 456 }
 457
 458 type serviceClient_IpsecSpdsDumpClient struct {
 459         api.Stream
 460 }
 461
 462 func (c *serviceClient_IpsecSpdsDumpClient) Recv() (*IpsecSpdsDetails, error) {
 463         msg, err := c.Stream.RecvMsg()
 464         if err != nil {
 465                 return nil, err
 466         }
 467         switch m := msg.(type) {
 468         case *IpsecSpdsDetails:
 469                 return m, nil
 470         case *vpe.ControlPingReply:
 471                 err = c.Stream.Close()
 472                 if err != nil {
 473                         return nil, err
 474                 }
 475                 return nil, io.EOF
 476         default:
 477                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 478         }
 479 }
 480
 481 func (c *serviceClient) IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error) {
 482         out := new(IpsecTunnelProtectDelReply)
 483         err := c.conn.Invoke(ctx, in, out)
 484         if err != nil {
 485                 return nil, err
 486         }
 487         return out, api.RetvalToVPPApiError(out.Retval)
 488 }
 489
 490 func (c *serviceClient) IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error) {
 491         stream, err := c.conn.NewStream(ctx)
 492         if err != nil {
 493                 return nil, err
 494         }
 495         x := &serviceClient_IpsecTunnelProtectDumpClient{stream}
 496         if err := x.Stream.SendMsg(in); err != nil {
 497                 return nil, err
 498         }
 499         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 500                 return nil, err
 501         }
 502         return x, nil
 503 }
 504
 505 type RPCService_IpsecTunnelProtectDumpClient interface {
 506         Recv() (*IpsecTunnelProtectDetails, error)
 507         api.Stream
 508 }
 509
 510 type serviceClient_IpsecTunnelProtectDumpClient struct {
 511         api.Stream
 512 }
 513
 514 func (c *serviceClient_IpsecTunnelProtectDumpClient) Recv() (*IpsecTunnelProtectDetails, error) {
 515         msg, err := c.Stream.RecvMsg()
 516         if err != nil {
 517                 return nil, err
 518         }
 519         switch m := msg.(type) {
 520         case *IpsecTunnelProtectDetails:
 521                 return m, nil
 522         case *vpe.ControlPingReply:
 523                 err = c.Stream.Close()
 524                 if err != nil {
 525                         return nil, err
 526                 }
 527                 return nil, io.EOF
 528         default:
 529                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 530         }
 531 }
 532
 533 func (c *serviceClient) IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error) {
 534         out := new(IpsecTunnelProtectUpdateReply)
 535         err := c.conn.Invoke(ctx, in, out)
 536         if err != nil {
 537                 return nil, err
 538         }
 539         return out, api.RetvalToVPPApiError(out.Retval)
 540 }