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                 return nil, io.EOF
  81         default:
  82                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  83         }
  84 }
  85
  86 func (c *serviceClient) IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error) {
  87         out := new(IpsecInterfaceAddDelSpdReply)
  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) IpsecItfCreate(ctx context.Context, in *IpsecItfCreate) (*IpsecItfCreateReply, error) {
  96         out := new(IpsecItfCreateReply)
  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) IpsecItfDelete(ctx context.Context, in *IpsecItfDelete) (*IpsecItfDeleteReply, error) {
 105         out := new(IpsecItfDeleteReply)
 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) IpsecItfDump(ctx context.Context, in *IpsecItfDump) (RPCService_IpsecItfDumpClient, error) {
 114         stream, err := c.conn.NewStream(ctx)
 115         if err != nil {
 116                 return nil, err
 117         }
 118         x := &serviceClient_IpsecItfDumpClient{stream}
 119         if err := x.Stream.SendMsg(in); err != nil {
 120                 return nil, err
 121         }
 122         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 123                 return nil, err
 124         }
 125         return x, nil
 126 }
 127
 128 type RPCService_IpsecItfDumpClient interface {
 129         Recv() (*IpsecItfDetails, error)
 130         api.Stream
 131 }
 132
 133 type serviceClient_IpsecItfDumpClient struct {
 134         api.Stream
 135 }
 136
 137 func (c *serviceClient_IpsecItfDumpClient) Recv() (*IpsecItfDetails, error) {
 138         msg, err := c.Stream.RecvMsg()
 139         if err != nil {
 140                 return nil, err
 141         }
 142         switch m := msg.(type) {
 143         case *IpsecItfDetails:
 144                 return m, nil
 145         case *vpe.ControlPingReply:
 146                 return nil, io.EOF
 147         default:
 148                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 149         }
 150 }
 151
 152 func (c *serviceClient) IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error) {
 153         stream, err := c.conn.NewStream(ctx)
 154         if err != nil {
 155                 return nil, err
 156         }
 157         x := &serviceClient_IpsecSaDumpClient{stream}
 158         if err := x.Stream.SendMsg(in); err != nil {
 159                 return nil, err
 160         }
 161         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 162                 return nil, err
 163         }
 164         return x, nil
 165 }
 166
 167 type RPCService_IpsecSaDumpClient interface {
 168         Recv() (*IpsecSaDetails, error)
 169         api.Stream
 170 }
 171
 172 type serviceClient_IpsecSaDumpClient struct {
 173         api.Stream
 174 }
 175
 176 func (c *serviceClient_IpsecSaDumpClient) Recv() (*IpsecSaDetails, error) {
 177         msg, err := c.Stream.RecvMsg()
 178         if err != nil {
 179                 return nil, err
 180         }
 181         switch m := msg.(type) {
 182         case *IpsecSaDetails:
 183                 return m, nil
 184         case *vpe.ControlPingReply:
 185                 return nil, io.EOF
 186         default:
 187                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 188         }
 189 }
 190
 191 func (c *serviceClient) IpsecSaV2Dump(ctx context.Context, in *IpsecSaV2Dump) (RPCService_IpsecSaV2DumpClient, error) {
 192         stream, err := c.conn.NewStream(ctx)
 193         if err != nil {
 194                 return nil, err
 195         }
 196         x := &serviceClient_IpsecSaV2DumpClient{stream}
 197         if err := x.Stream.SendMsg(in); err != nil {
 198                 return nil, err
 199         }
 200         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 201                 return nil, err
 202         }
 203         return x, nil
 204 }
 205
 206 type RPCService_IpsecSaV2DumpClient interface {
 207         Recv() (*IpsecSaV2Details, error)
 208         api.Stream
 209 }
 210
 211 type serviceClient_IpsecSaV2DumpClient struct {
 212         api.Stream
 213 }
 214
 215 func (c *serviceClient_IpsecSaV2DumpClient) Recv() (*IpsecSaV2Details, error) {
 216         msg, err := c.Stream.RecvMsg()
 217         if err != nil {
 218                 return nil, err
 219         }
 220         switch m := msg.(type) {
 221         case *IpsecSaV2Details:
 222                 return m, nil
 223         case *vpe.ControlPingReply:
 224                 return nil, io.EOF
 225         default:
 226                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 227         }
 228 }
 229
 230 func (c *serviceClient) IpsecSaV3Dump(ctx context.Context, in *IpsecSaV3Dump) (RPCService_IpsecSaV3DumpClient, error) {
 231         stream, err := c.conn.NewStream(ctx)
 232         if err != nil {
 233                 return nil, err
 234         }
 235         x := &serviceClient_IpsecSaV3DumpClient{stream}
 236         if err := x.Stream.SendMsg(in); err != nil {
 237                 return nil, err
 238         }
 239         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 240                 return nil, err
 241         }
 242         return x, nil
 243 }
 244
 245 type RPCService_IpsecSaV3DumpClient interface {
 246         Recv() (*IpsecSaV3Details, error)
 247         api.Stream
 248 }
 249
 250 type serviceClient_IpsecSaV3DumpClient struct {
 251         api.Stream
 252 }
 253
 254 func (c *serviceClient_IpsecSaV3DumpClient) Recv() (*IpsecSaV3Details, error) {
 255         msg, err := c.Stream.RecvMsg()
 256         if err != nil {
 257                 return nil, err
 258         }
 259         switch m := msg.(type) {
 260         case *IpsecSaV3Details:
 261                 return m, nil
 262         case *vpe.ControlPingReply:
 263                 return nil, io.EOF
 264         default:
 265                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 266         }
 267 }
 268
 269 func (c *serviceClient) IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error) {
 270         out := new(IpsecSadEntryAddDelReply)
 271         err := c.conn.Invoke(ctx, in, out)
 272         if err != nil {
 273                 return nil, err
 274         }
 275         return out, api.RetvalToVPPApiError(out.Retval)
 276 }
 277
 278 func (c *serviceClient) IpsecSadEntryAddDelV2(ctx context.Context, in *IpsecSadEntryAddDelV2) (*IpsecSadEntryAddDelV2Reply, error) {
 279         out := new(IpsecSadEntryAddDelV2Reply)
 280         err := c.conn.Invoke(ctx, in, out)
 281         if err != nil {
 282                 return nil, err
 283         }
 284         return out, api.RetvalToVPPApiError(out.Retval)
 285 }
 286
 287 func (c *serviceClient) IpsecSadEntryAddDelV3(ctx context.Context, in *IpsecSadEntryAddDelV3) (*IpsecSadEntryAddDelV3Reply, error) {
 288         out := new(IpsecSadEntryAddDelV3Reply)
 289         err := c.conn.Invoke(ctx, in, out)
 290         if err != nil {
 291                 return nil, err
 292         }
 293         return out, api.RetvalToVPPApiError(out.Retval)
 294 }
 295
 296 func (c *serviceClient) IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error) {
 297         out := new(IpsecSelectBackendReply)
 298         err := c.conn.Invoke(ctx, in, out)
 299         if err != nil {
 300                 return nil, err
 301         }
 302         return out, api.RetvalToVPPApiError(out.Retval)
 303 }
 304
 305 func (c *serviceClient) IpsecSetAsyncMode(ctx context.Context, in *IpsecSetAsyncMode) (*IpsecSetAsyncModeReply, error) {
 306         out := new(IpsecSetAsyncModeReply)
 307         err := c.conn.Invoke(ctx, in, out)
 308         if err != nil {
 309                 return nil, err
 310         }
 311         return out, api.RetvalToVPPApiError(out.Retval)
 312 }
 313
 314 func (c *serviceClient) IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error) {
 315         out := new(IpsecSpdAddDelReply)
 316         err := c.conn.Invoke(ctx, in, out)
 317         if err != nil {
 318                 return nil, err
 319         }
 320         return out, api.RetvalToVPPApiError(out.Retval)
 321 }
 322
 323 func (c *serviceClient) IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error) {
 324         stream, err := c.conn.NewStream(ctx)
 325         if err != nil {
 326                 return nil, err
 327         }
 328         x := &serviceClient_IpsecSpdDumpClient{stream}
 329         if err := x.Stream.SendMsg(in); err != nil {
 330                 return nil, err
 331         }
 332         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 333                 return nil, err
 334         }
 335         return x, nil
 336 }
 337
 338 type RPCService_IpsecSpdDumpClient interface {
 339         Recv() (*IpsecSpdDetails, error)
 340         api.Stream
 341 }
 342
 343 type serviceClient_IpsecSpdDumpClient struct {
 344         api.Stream
 345 }
 346
 347 func (c *serviceClient_IpsecSpdDumpClient) Recv() (*IpsecSpdDetails, error) {
 348         msg, err := c.Stream.RecvMsg()
 349         if err != nil {
 350                 return nil, err
 351         }
 352         switch m := msg.(type) {
 353         case *IpsecSpdDetails:
 354                 return m, nil
 355         case *vpe.ControlPingReply:
 356                 return nil, io.EOF
 357         default:
 358                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 359         }
 360 }
 361
 362 func (c *serviceClient) IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error) {
 363         out := new(IpsecSpdEntryAddDelReply)
 364         err := c.conn.Invoke(ctx, in, out)
 365         if err != nil {
 366                 return nil, err
 367         }
 368         return out, api.RetvalToVPPApiError(out.Retval)
 369 }
 370
 371 func (c *serviceClient) IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error) {
 372         stream, err := c.conn.NewStream(ctx)
 373         if err != nil {
 374                 return nil, err
 375         }
 376         x := &serviceClient_IpsecSpdInterfaceDumpClient{stream}
 377         if err := x.Stream.SendMsg(in); err != nil {
 378                 return nil, err
 379         }
 380         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 381                 return nil, err
 382         }
 383         return x, nil
 384 }
 385
 386 type RPCService_IpsecSpdInterfaceDumpClient interface {
 387         Recv() (*IpsecSpdInterfaceDetails, error)
 388         api.Stream
 389 }
 390
 391 type serviceClient_IpsecSpdInterfaceDumpClient struct {
 392         api.Stream
 393 }
 394
 395 func (c *serviceClient_IpsecSpdInterfaceDumpClient) Recv() (*IpsecSpdInterfaceDetails, error) {
 396         msg, err := c.Stream.RecvMsg()
 397         if err != nil {
 398                 return nil, err
 399         }
 400         switch m := msg.(type) {
 401         case *IpsecSpdInterfaceDetails:
 402                 return m, nil
 403         case *vpe.ControlPingReply:
 404                 return nil, io.EOF
 405         default:
 406                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 407         }
 408 }
 409
 410 func (c *serviceClient) IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error) {
 411         stream, err := c.conn.NewStream(ctx)
 412         if err != nil {
 413                 return nil, err
 414         }
 415         x := &serviceClient_IpsecSpdsDumpClient{stream}
 416         if err := x.Stream.SendMsg(in); err != nil {
 417                 return nil, err
 418         }
 419         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 420                 return nil, err
 421         }
 422         return x, nil
 423 }
 424
 425 type RPCService_IpsecSpdsDumpClient interface {
 426         Recv() (*IpsecSpdsDetails, error)
 427         api.Stream
 428 }
 429
 430 type serviceClient_IpsecSpdsDumpClient struct {
 431         api.Stream
 432 }
 433
 434 func (c *serviceClient_IpsecSpdsDumpClient) Recv() (*IpsecSpdsDetails, error) {
 435         msg, err := c.Stream.RecvMsg()
 436         if err != nil {
 437                 return nil, err
 438         }
 439         switch m := msg.(type) {
 440         case *IpsecSpdsDetails:
 441                 return m, nil
 442         case *vpe.ControlPingReply:
 443                 return nil, io.EOF
 444         default:
 445                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 446         }
 447 }
 448
 449 func (c *serviceClient) IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error) {
 450         out := new(IpsecTunnelProtectDelReply)
 451         err := c.conn.Invoke(ctx, in, out)
 452         if err != nil {
 453                 return nil, err
 454         }
 455         return out, api.RetvalToVPPApiError(out.Retval)
 456 }
 457
 458 func (c *serviceClient) IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error) {
 459         stream, err := c.conn.NewStream(ctx)
 460         if err != nil {
 461                 return nil, err
 462         }
 463         x := &serviceClient_IpsecTunnelProtectDumpClient{stream}
 464         if err := x.Stream.SendMsg(in); err != nil {
 465                 return nil, err
 466         }
 467         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 468                 return nil, err
 469         }
 470         return x, nil
 471 }
 472
 473 type RPCService_IpsecTunnelProtectDumpClient interface {
 474         Recv() (*IpsecTunnelProtectDetails, error)
 475         api.Stream
 476 }
 477
 478 type serviceClient_IpsecTunnelProtectDumpClient struct {
 479         api.Stream
 480 }
 481
 482 func (c *serviceClient_IpsecTunnelProtectDumpClient) Recv() (*IpsecTunnelProtectDetails, error) {
 483         msg, err := c.Stream.RecvMsg()
 484         if err != nil {
 485                 return nil, err
 486         }
 487         switch m := msg.(type) {
 488         case *IpsecTunnelProtectDetails:
 489                 return m, nil
 490         case *vpe.ControlPingReply:
 491                 return nil, io.EOF
 492         default:
 493                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 494         }
 495 }
 496
 497 func (c *serviceClient) IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error) {
 498         out := new(IpsecTunnelProtectUpdateReply)
 499         err := c.conn.Invoke(ctx, in, out)
 500         if err != nil {
 501                 return nil, err
 502         }
 503         return out, api.RetvalToVPPApiError(out.Retval)
 504 }