internal/testbinapi/binapi2001/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/internal/testbinapi/binapi2001/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         IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error)
  19         IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error)
  20         IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error)
  21         IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error)
  22         IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error)
  23         IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error)
  24         IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error)
  25         IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error)
  26         IpsecTunnelIfAddDel(ctx context.Context, in *IpsecTunnelIfAddDel) (*IpsecTunnelIfAddDelReply, error)
  27         IpsecTunnelIfSetSa(ctx context.Context, in *IpsecTunnelIfSetSa) (*IpsecTunnelIfSetSaReply, error)
  28         IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error)
  29         IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error)
  30         IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error)
  31 }
  32
  33 type serviceClient struct {
  34         conn api.Connection
  35 }
  36
  37 func NewServiceClient(conn api.Connection) RPCService {
  38         return &serviceClient{conn}
  39 }
  40
  41 func (c *serviceClient) IpsecBackendDump(ctx context.Context, in *IpsecBackendDump) (RPCService_IpsecBackendDumpClient, error) {
  42         stream, err := c.conn.NewStream(ctx)
  43         if err != nil {
  44                 return nil, err
  45         }
  46         x := &serviceClient_IpsecBackendDumpClient{stream}
  47         if err := x.Stream.SendMsg(in); err != nil {
  48                 return nil, err
  49         }
  50         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  51                 return nil, err
  52         }
  53         return x, nil
  54 }
  55
  56 type RPCService_IpsecBackendDumpClient interface {
  57         Recv() (*IpsecBackendDetails, error)
  58         api.Stream
  59 }
  60
  61 type serviceClient_IpsecBackendDumpClient struct {
  62         api.Stream
  63 }
  64
  65 func (c *serviceClient_IpsecBackendDumpClient) Recv() (*IpsecBackendDetails, error) {
  66         msg, err := c.Stream.RecvMsg()
  67         if err != nil {
  68                 return nil, err
  69         }
  70         switch m := msg.(type) {
  71         case *IpsecBackendDetails:
  72                 return m, nil
  73         case *vpe.ControlPingReply:
  74                 err = c.Stream.Close()
  75                 if err != nil {
  76                         return nil, err
  77                 }
  78                 return nil, io.EOF
  79         default:
  80                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  81         }
  82 }
  83
  84 func (c *serviceClient) IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error) {
  85         out := new(IpsecInterfaceAddDelSpdReply)
  86         err := c.conn.Invoke(ctx, in, out)
  87         if err != nil {
  88                 return nil, err
  89         }
  90         return out, api.RetvalToVPPApiError(out.Retval)
  91 }
  92
  93 func (c *serviceClient) IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error) {
  94         stream, err := c.conn.NewStream(ctx)
  95         if err != nil {
  96                 return nil, err
  97         }
  98         x := &serviceClient_IpsecSaDumpClient{stream}
  99         if err := x.Stream.SendMsg(in); err != nil {
 100                 return nil, err
 101         }
 102         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 103                 return nil, err
 104         }
 105         return x, nil
 106 }
 107
 108 type RPCService_IpsecSaDumpClient interface {
 109         Recv() (*IpsecSaDetails, error)
 110         api.Stream
 111 }
 112
 113 type serviceClient_IpsecSaDumpClient struct {
 114         api.Stream
 115 }
 116
 117 func (c *serviceClient_IpsecSaDumpClient) Recv() (*IpsecSaDetails, error) {
 118         msg, err := c.Stream.RecvMsg()
 119         if err != nil {
 120                 return nil, err
 121         }
 122         switch m := msg.(type) {
 123         case *IpsecSaDetails:
 124                 return m, nil
 125         case *vpe.ControlPingReply:
 126                 err = c.Stream.Close()
 127                 if err != nil {
 128                         return nil, err
 129                 }
 130                 return nil, io.EOF
 131         default:
 132                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 133         }
 134 }
 135
 136 func (c *serviceClient) IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error) {
 137         out := new(IpsecSadEntryAddDelReply)
 138         err := c.conn.Invoke(ctx, in, out)
 139         if err != nil {
 140                 return nil, err
 141         }
 142         return out, api.RetvalToVPPApiError(out.Retval)
 143 }
 144
 145 func (c *serviceClient) IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error) {
 146         out := new(IpsecSelectBackendReply)
 147         err := c.conn.Invoke(ctx, in, out)
 148         if err != nil {
 149                 return nil, err
 150         }
 151         return out, api.RetvalToVPPApiError(out.Retval)
 152 }
 153
 154 func (c *serviceClient) IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error) {
 155         out := new(IpsecSpdAddDelReply)
 156         err := c.conn.Invoke(ctx, in, out)
 157         if err != nil {
 158                 return nil, err
 159         }
 160         return out, api.RetvalToVPPApiError(out.Retval)
 161 }
 162
 163 func (c *serviceClient) IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error) {
 164         stream, err := c.conn.NewStream(ctx)
 165         if err != nil {
 166                 return nil, err
 167         }
 168         x := &serviceClient_IpsecSpdDumpClient{stream}
 169         if err := x.Stream.SendMsg(in); err != nil {
 170                 return nil, err
 171         }
 172         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 173                 return nil, err
 174         }
 175         return x, nil
 176 }
 177
 178 type RPCService_IpsecSpdDumpClient interface {
 179         Recv() (*IpsecSpdDetails, error)
 180         api.Stream
 181 }
 182
 183 type serviceClient_IpsecSpdDumpClient struct {
 184         api.Stream
 185 }
 186
 187 func (c *serviceClient_IpsecSpdDumpClient) Recv() (*IpsecSpdDetails, error) {
 188         msg, err := c.Stream.RecvMsg()
 189         if err != nil {
 190                 return nil, err
 191         }
 192         switch m := msg.(type) {
 193         case *IpsecSpdDetails:
 194                 return m, nil
 195         case *vpe.ControlPingReply:
 196                 err = c.Stream.Close()
 197                 if err != nil {
 198                         return nil, err
 199                 }
 200                 return nil, io.EOF
 201         default:
 202                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 203         }
 204 }
 205
 206 func (c *serviceClient) IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error) {
 207         out := new(IpsecSpdEntryAddDelReply)
 208         err := c.conn.Invoke(ctx, in, out)
 209         if err != nil {
 210                 return nil, err
 211         }
 212         return out, api.RetvalToVPPApiError(out.Retval)
 213 }
 214
 215 func (c *serviceClient) IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error) {
 216         stream, err := c.conn.NewStream(ctx)
 217         if err != nil {
 218                 return nil, err
 219         }
 220         x := &serviceClient_IpsecSpdInterfaceDumpClient{stream}
 221         if err := x.Stream.SendMsg(in); err != nil {
 222                 return nil, err
 223         }
 224         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 225                 return nil, err
 226         }
 227         return x, nil
 228 }
 229
 230 type RPCService_IpsecSpdInterfaceDumpClient interface {
 231         Recv() (*IpsecSpdInterfaceDetails, error)
 232         api.Stream
 233 }
 234
 235 type serviceClient_IpsecSpdInterfaceDumpClient struct {
 236         api.Stream
 237 }
 238
 239 func (c *serviceClient_IpsecSpdInterfaceDumpClient) Recv() (*IpsecSpdInterfaceDetails, error) {
 240         msg, err := c.Stream.RecvMsg()
 241         if err != nil {
 242                 return nil, err
 243         }
 244         switch m := msg.(type) {
 245         case *IpsecSpdInterfaceDetails:
 246                 return m, nil
 247         case *vpe.ControlPingReply:
 248                 err = c.Stream.Close()
 249                 if err != nil {
 250                         return nil, err
 251                 }
 252                 return nil, io.EOF
 253         default:
 254                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 255         }
 256 }
 257
 258 func (c *serviceClient) IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error) {
 259         stream, err := c.conn.NewStream(ctx)
 260         if err != nil {
 261                 return nil, err
 262         }
 263         x := &serviceClient_IpsecSpdsDumpClient{stream}
 264         if err := x.Stream.SendMsg(in); err != nil {
 265                 return nil, err
 266         }
 267         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 268                 return nil, err
 269         }
 270         return x, nil
 271 }
 272
 273 type RPCService_IpsecSpdsDumpClient interface {
 274         Recv() (*IpsecSpdsDetails, error)
 275         api.Stream
 276 }
 277
 278 type serviceClient_IpsecSpdsDumpClient struct {
 279         api.Stream
 280 }
 281
 282 func (c *serviceClient_IpsecSpdsDumpClient) Recv() (*IpsecSpdsDetails, error) {
 283         msg, err := c.Stream.RecvMsg()
 284         if err != nil {
 285                 return nil, err
 286         }
 287         switch m := msg.(type) {
 288         case *IpsecSpdsDetails:
 289                 return m, nil
 290         case *vpe.ControlPingReply:
 291                 err = c.Stream.Close()
 292                 if err != nil {
 293                         return nil, err
 294                 }
 295                 return nil, io.EOF
 296         default:
 297                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 298         }
 299 }
 300
 301 func (c *serviceClient) IpsecTunnelIfAddDel(ctx context.Context, in *IpsecTunnelIfAddDel) (*IpsecTunnelIfAddDelReply, error) {
 302         out := new(IpsecTunnelIfAddDelReply)
 303         err := c.conn.Invoke(ctx, in, out)
 304         if err != nil {
 305                 return nil, err
 306         }
 307         return out, api.RetvalToVPPApiError(out.Retval)
 308 }
 309
 310 func (c *serviceClient) IpsecTunnelIfSetSa(ctx context.Context, in *IpsecTunnelIfSetSa) (*IpsecTunnelIfSetSaReply, error) {
 311         out := new(IpsecTunnelIfSetSaReply)
 312         err := c.conn.Invoke(ctx, in, out)
 313         if err != nil {
 314                 return nil, err
 315         }
 316         return out, api.RetvalToVPPApiError(out.Retval)
 317 }
 318
 319 func (c *serviceClient) IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error) {
 320         out := new(IpsecTunnelProtectDelReply)
 321         err := c.conn.Invoke(ctx, in, out)
 322         if err != nil {
 323                 return nil, err
 324         }
 325         return out, api.RetvalToVPPApiError(out.Retval)
 326 }
 327
 328 func (c *serviceClient) IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error) {
 329         stream, err := c.conn.NewStream(ctx)
 330         if err != nil {
 331                 return nil, err
 332         }
 333         x := &serviceClient_IpsecTunnelProtectDumpClient{stream}
 334         if err := x.Stream.SendMsg(in); err != nil {
 335                 return nil, err
 336         }
 337         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 338                 return nil, err
 339         }
 340         return x, nil
 341 }
 342
 343 type RPCService_IpsecTunnelProtectDumpClient interface {
 344         Recv() (*IpsecTunnelProtectDetails, error)
 345         api.Stream
 346 }
 347
 348 type serviceClient_IpsecTunnelProtectDumpClient struct {
 349         api.Stream
 350 }
 351
 352 func (c *serviceClient_IpsecTunnelProtectDumpClient) Recv() (*IpsecTunnelProtectDetails, error) {
 353         msg, err := c.Stream.RecvMsg()
 354         if err != nil {
 355                 return nil, err
 356         }
 357         switch m := msg.(type) {
 358         case *IpsecTunnelProtectDetails:
 359                 return m, nil
 360         case *vpe.ControlPingReply:
 361                 err = c.Stream.Close()
 362                 if err != nil {
 363                         return nil, err
 364                 }
 365                 return nil, io.EOF
 366         default:
 367                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 368         }
 369 }
 370
 371 func (c *serviceClient) IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error) {
 372         out := new(IpsecTunnelProtectUpdateReply)
 373         err := c.conn.Invoke(ctx, in, out)
 374         if err != nil {
 375                 return nil, err
 376         }
 377         return out, api.RetvalToVPPApiError(out.Retval)
 378 }