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         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                 return nil, io.EOF
  75         default:
  76                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  77         }
  78 }
  79
  80 func (c *serviceClient) IpsecInterfaceAddDelSpd(ctx context.Context, in *IpsecInterfaceAddDelSpd) (*IpsecInterfaceAddDelSpdReply, error) {
  81         out := new(IpsecInterfaceAddDelSpdReply)
  82         err := c.conn.Invoke(ctx, in, out)
  83         if err != nil {
  84                 return nil, err
  85         }
  86         return out, nil
  87 }
  88
  89 func (c *serviceClient) IpsecSaDump(ctx context.Context, in *IpsecSaDump) (RPCService_IpsecSaDumpClient, error) {
  90         stream, err := c.conn.NewStream(ctx)
  91         if err != nil {
  92                 return nil, err
  93         }
  94         x := &serviceClient_IpsecSaDumpClient{stream}
  95         if err := x.Stream.SendMsg(in); err != nil {
  96                 return nil, err
  97         }
  98         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  99                 return nil, err
 100         }
 101         return x, nil
 102 }
 103
 104 type RPCService_IpsecSaDumpClient interface {
 105         Recv() (*IpsecSaDetails, error)
 106         api.Stream
 107 }
 108
 109 type serviceClient_IpsecSaDumpClient struct {
 110         api.Stream
 111 }
 112
 113 func (c *serviceClient_IpsecSaDumpClient) Recv() (*IpsecSaDetails, error) {
 114         msg, err := c.Stream.RecvMsg()
 115         if err != nil {
 116                 return nil, err
 117         }
 118         switch m := msg.(type) {
 119         case *IpsecSaDetails:
 120                 return m, nil
 121         case *vpe.ControlPingReply:
 122                 return nil, io.EOF
 123         default:
 124                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 125         }
 126 }
 127
 128 func (c *serviceClient) IpsecSadEntryAddDel(ctx context.Context, in *IpsecSadEntryAddDel) (*IpsecSadEntryAddDelReply, error) {
 129         out := new(IpsecSadEntryAddDelReply)
 130         err := c.conn.Invoke(ctx, in, out)
 131         if err != nil {
 132                 return nil, err
 133         }
 134         return out, nil
 135 }
 136
 137 func (c *serviceClient) IpsecSelectBackend(ctx context.Context, in *IpsecSelectBackend) (*IpsecSelectBackendReply, error) {
 138         out := new(IpsecSelectBackendReply)
 139         err := c.conn.Invoke(ctx, in, out)
 140         if err != nil {
 141                 return nil, err
 142         }
 143         return out, nil
 144 }
 145
 146 func (c *serviceClient) IpsecSpdAddDel(ctx context.Context, in *IpsecSpdAddDel) (*IpsecSpdAddDelReply, error) {
 147         out := new(IpsecSpdAddDelReply)
 148         err := c.conn.Invoke(ctx, in, out)
 149         if err != nil {
 150                 return nil, err
 151         }
 152         return out, nil
 153 }
 154
 155 func (c *serviceClient) IpsecSpdDump(ctx context.Context, in *IpsecSpdDump) (RPCService_IpsecSpdDumpClient, error) {
 156         stream, err := c.conn.NewStream(ctx)
 157         if err != nil {
 158                 return nil, err
 159         }
 160         x := &serviceClient_IpsecSpdDumpClient{stream}
 161         if err := x.Stream.SendMsg(in); err != nil {
 162                 return nil, err
 163         }
 164         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 165                 return nil, err
 166         }
 167         return x, nil
 168 }
 169
 170 type RPCService_IpsecSpdDumpClient interface {
 171         Recv() (*IpsecSpdDetails, error)
 172         api.Stream
 173 }
 174
 175 type serviceClient_IpsecSpdDumpClient struct {
 176         api.Stream
 177 }
 178
 179 func (c *serviceClient_IpsecSpdDumpClient) Recv() (*IpsecSpdDetails, error) {
 180         msg, err := c.Stream.RecvMsg()
 181         if err != nil {
 182                 return nil, err
 183         }
 184         switch m := msg.(type) {
 185         case *IpsecSpdDetails:
 186                 return m, nil
 187         case *vpe.ControlPingReply:
 188                 return nil, io.EOF
 189         default:
 190                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 191         }
 192 }
 193
 194 func (c *serviceClient) IpsecSpdEntryAddDel(ctx context.Context, in *IpsecSpdEntryAddDel) (*IpsecSpdEntryAddDelReply, error) {
 195         out := new(IpsecSpdEntryAddDelReply)
 196         err := c.conn.Invoke(ctx, in, out)
 197         if err != nil {
 198                 return nil, err
 199         }
 200         return out, nil
 201 }
 202
 203 func (c *serviceClient) IpsecSpdInterfaceDump(ctx context.Context, in *IpsecSpdInterfaceDump) (RPCService_IpsecSpdInterfaceDumpClient, error) {
 204         stream, err := c.conn.NewStream(ctx)
 205         if err != nil {
 206                 return nil, err
 207         }
 208         x := &serviceClient_IpsecSpdInterfaceDumpClient{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_IpsecSpdInterfaceDumpClient interface {
 219         Recv() (*IpsecSpdInterfaceDetails, error)
 220         api.Stream
 221 }
 222
 223 type serviceClient_IpsecSpdInterfaceDumpClient struct {
 224         api.Stream
 225 }
 226
 227 func (c *serviceClient_IpsecSpdInterfaceDumpClient) Recv() (*IpsecSpdInterfaceDetails, error) {
 228         msg, err := c.Stream.RecvMsg()
 229         if err != nil {
 230                 return nil, err
 231         }
 232         switch m := msg.(type) {
 233         case *IpsecSpdInterfaceDetails:
 234                 return m, nil
 235         case *vpe.ControlPingReply:
 236                 return nil, io.EOF
 237         default:
 238                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 239         }
 240 }
 241
 242 func (c *serviceClient) IpsecSpdsDump(ctx context.Context, in *IpsecSpdsDump) (RPCService_IpsecSpdsDumpClient, error) {
 243         stream, err := c.conn.NewStream(ctx)
 244         if err != nil {
 245                 return nil, err
 246         }
 247         x := &serviceClient_IpsecSpdsDumpClient{stream}
 248         if err := x.Stream.SendMsg(in); err != nil {
 249                 return nil, err
 250         }
 251         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 252                 return nil, err
 253         }
 254         return x, nil
 255 }
 256
 257 type RPCService_IpsecSpdsDumpClient interface {
 258         Recv() (*IpsecSpdsDetails, error)
 259         api.Stream
 260 }
 261
 262 type serviceClient_IpsecSpdsDumpClient struct {
 263         api.Stream
 264 }
 265
 266 func (c *serviceClient_IpsecSpdsDumpClient) Recv() (*IpsecSpdsDetails, error) {
 267         msg, err := c.Stream.RecvMsg()
 268         if err != nil {
 269                 return nil, err
 270         }
 271         switch m := msg.(type) {
 272         case *IpsecSpdsDetails:
 273                 return m, nil
 274         case *vpe.ControlPingReply:
 275                 return nil, io.EOF
 276         default:
 277                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 278         }
 279 }
 280
 281 func (c *serviceClient) IpsecTunnelIfAddDel(ctx context.Context, in *IpsecTunnelIfAddDel) (*IpsecTunnelIfAddDelReply, error) {
 282         out := new(IpsecTunnelIfAddDelReply)
 283         err := c.conn.Invoke(ctx, in, out)
 284         if err != nil {
 285                 return nil, err
 286         }
 287         return out, nil
 288 }
 289
 290 func (c *serviceClient) IpsecTunnelIfSetSa(ctx context.Context, in *IpsecTunnelIfSetSa) (*IpsecTunnelIfSetSaReply, error) {
 291         out := new(IpsecTunnelIfSetSaReply)
 292         err := c.conn.Invoke(ctx, in, out)
 293         if err != nil {
 294                 return nil, err
 295         }
 296         return out, nil
 297 }
 298
 299 func (c *serviceClient) IpsecTunnelProtectDel(ctx context.Context, in *IpsecTunnelProtectDel) (*IpsecTunnelProtectDelReply, error) {
 300         out := new(IpsecTunnelProtectDelReply)
 301         err := c.conn.Invoke(ctx, in, out)
 302         if err != nil {
 303                 return nil, err
 304         }
 305         return out, nil
 306 }
 307
 308 func (c *serviceClient) IpsecTunnelProtectDump(ctx context.Context, in *IpsecTunnelProtectDump) (RPCService_IpsecTunnelProtectDumpClient, error) {
 309         stream, err := c.conn.NewStream(ctx)
 310         if err != nil {
 311                 return nil, err
 312         }
 313         x := &serviceClient_IpsecTunnelProtectDumpClient{stream}
 314         if err := x.Stream.SendMsg(in); err != nil {
 315                 return nil, err
 316         }
 317         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 318                 return nil, err
 319         }
 320         return x, nil
 321 }
 322
 323 type RPCService_IpsecTunnelProtectDumpClient interface {
 324         Recv() (*IpsecTunnelProtectDetails, error)
 325         api.Stream
 326 }
 327
 328 type serviceClient_IpsecTunnelProtectDumpClient struct {
 329         api.Stream
 330 }
 331
 332 func (c *serviceClient_IpsecTunnelProtectDumpClient) Recv() (*IpsecTunnelProtectDetails, error) {
 333         msg, err := c.Stream.RecvMsg()
 334         if err != nil {
 335                 return nil, err
 336         }
 337         switch m := msg.(type) {
 338         case *IpsecTunnelProtectDetails:
 339                 return m, nil
 340         case *vpe.ControlPingReply:
 341                 return nil, io.EOF
 342         default:
 343                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 344         }
 345 }
 346
 347 func (c *serviceClient) IpsecTunnelProtectUpdate(ctx context.Context, in *IpsecTunnelProtectUpdate) (*IpsecTunnelProtectUpdateReply, error) {
 348         out := new(IpsecTunnelProtectUpdateReply)
 349         err := c.conn.Invoke(ctx, in, out)
 350         if err != nil {
 351                 return nil, err
 352         }
 353         return out, nil
 354 }