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