binapi/ikev2/ikev2_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package ikev2
   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 ikev2.
  15 type RPCService interface {
  16         Ikev2ChildSaDump(ctx context.Context, in *Ikev2ChildSaDump) (RPCService_Ikev2ChildSaDumpClient, error)
  17         Ikev2InitiateDelChildSa(ctx context.Context, in *Ikev2InitiateDelChildSa) (*Ikev2InitiateDelChildSaReply, error)
  18         Ikev2InitiateDelIkeSa(ctx context.Context, in *Ikev2InitiateDelIkeSa) (*Ikev2InitiateDelIkeSaReply, error)
  19         Ikev2InitiateRekeyChildSa(ctx context.Context, in *Ikev2InitiateRekeyChildSa) (*Ikev2InitiateRekeyChildSaReply, error)
  20         Ikev2InitiateSaInit(ctx context.Context, in *Ikev2InitiateSaInit) (*Ikev2InitiateSaInitReply, error)
  21         Ikev2NonceGet(ctx context.Context, in *Ikev2NonceGet) (*Ikev2NonceGetReply, error)
  22         Ikev2PluginGetVersion(ctx context.Context, in *Ikev2PluginGetVersion) (*Ikev2PluginGetVersionReply, error)
  23         Ikev2ProfileAddDel(ctx context.Context, in *Ikev2ProfileAddDel) (*Ikev2ProfileAddDelReply, error)
  24         Ikev2ProfileDisableNatt(ctx context.Context, in *Ikev2ProfileDisableNatt) (*Ikev2ProfileDisableNattReply, error)
  25         Ikev2ProfileDump(ctx context.Context, in *Ikev2ProfileDump) (RPCService_Ikev2ProfileDumpClient, error)
  26         Ikev2ProfileSetAuth(ctx context.Context, in *Ikev2ProfileSetAuth) (*Ikev2ProfileSetAuthReply, error)
  27         Ikev2ProfileSetID(ctx context.Context, in *Ikev2ProfileSetID) (*Ikev2ProfileSetIDReply, error)
  28         Ikev2ProfileSetIpsecUDPPort(ctx context.Context, in *Ikev2ProfileSetIpsecUDPPort) (*Ikev2ProfileSetIpsecUDPPortReply, error)
  29         Ikev2ProfileSetLiveness(ctx context.Context, in *Ikev2ProfileSetLiveness) (*Ikev2ProfileSetLivenessReply, error)
  30         Ikev2ProfileSetTs(ctx context.Context, in *Ikev2ProfileSetTs) (*Ikev2ProfileSetTsReply, error)
  31         Ikev2ProfileSetUDPEncap(ctx context.Context, in *Ikev2ProfileSetUDPEncap) (*Ikev2ProfileSetUDPEncapReply, error)
  32         Ikev2SaDump(ctx context.Context, in *Ikev2SaDump) (RPCService_Ikev2SaDumpClient, error)
  33         Ikev2SetEspTransforms(ctx context.Context, in *Ikev2SetEspTransforms) (*Ikev2SetEspTransformsReply, error)
  34         Ikev2SetIkeTransforms(ctx context.Context, in *Ikev2SetIkeTransforms) (*Ikev2SetIkeTransformsReply, error)
  35         Ikev2SetLocalKey(ctx context.Context, in *Ikev2SetLocalKey) (*Ikev2SetLocalKeyReply, error)
  36         Ikev2SetResponder(ctx context.Context, in *Ikev2SetResponder) (*Ikev2SetResponderReply, error)
  37         Ikev2SetResponderHostname(ctx context.Context, in *Ikev2SetResponderHostname) (*Ikev2SetResponderHostnameReply, error)
  38         Ikev2SetSaLifetime(ctx context.Context, in *Ikev2SetSaLifetime) (*Ikev2SetSaLifetimeReply, error)
  39         Ikev2SetTunnelInterface(ctx context.Context, in *Ikev2SetTunnelInterface) (*Ikev2SetTunnelInterfaceReply, error)
  40         Ikev2TrafficSelectorDump(ctx context.Context, in *Ikev2TrafficSelectorDump) (RPCService_Ikev2TrafficSelectorDumpClient, error)
  41 }
  42
  43 type serviceClient struct {
  44         conn api.Connection
  45 }
  46
  47 func NewServiceClient(conn api.Connection) RPCService {
  48         return &serviceClient{conn}
  49 }
  50
  51 func (c *serviceClient) Ikev2ChildSaDump(ctx context.Context, in *Ikev2ChildSaDump) (RPCService_Ikev2ChildSaDumpClient, error) {
  52         stream, err := c.conn.NewStream(ctx)
  53         if err != nil {
  54                 return nil, err
  55         }
  56         x := &serviceClient_Ikev2ChildSaDumpClient{stream}
  57         if err := x.Stream.SendMsg(in); err != nil {
  58                 return nil, err
  59         }
  60         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  61                 return nil, err
  62         }
  63         return x, nil
  64 }
  65
  66 type RPCService_Ikev2ChildSaDumpClient interface {
  67         Recv() (*Ikev2ChildSaDetails, error)
  68         api.Stream
  69 }
  70
  71 type serviceClient_Ikev2ChildSaDumpClient struct {
  72         api.Stream
  73 }
  74
  75 func (c *serviceClient_Ikev2ChildSaDumpClient) Recv() (*Ikev2ChildSaDetails, error) {
  76         msg, err := c.Stream.RecvMsg()
  77         if err != nil {
  78                 return nil, err
  79         }
  80         switch m := msg.(type) {
  81         case *Ikev2ChildSaDetails:
  82                 return m, nil
  83         case *vpe.ControlPingReply:
  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) Ikev2InitiateDelChildSa(ctx context.Context, in *Ikev2InitiateDelChildSa) (*Ikev2InitiateDelChildSaReply, error) {
  91         out := new(Ikev2InitiateDelChildSaReply)
  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) Ikev2InitiateDelIkeSa(ctx context.Context, in *Ikev2InitiateDelIkeSa) (*Ikev2InitiateDelIkeSaReply, error) {
 100         out := new(Ikev2InitiateDelIkeSaReply)
 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) Ikev2InitiateRekeyChildSa(ctx context.Context, in *Ikev2InitiateRekeyChildSa) (*Ikev2InitiateRekeyChildSaReply, error) {
 109         out := new(Ikev2InitiateRekeyChildSaReply)
 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) Ikev2InitiateSaInit(ctx context.Context, in *Ikev2InitiateSaInit) (*Ikev2InitiateSaInitReply, error) {
 118         out := new(Ikev2InitiateSaInitReply)
 119         err := c.conn.Invoke(ctx, in, out)
 120         if err != nil {
 121                 return nil, err
 122         }
 123         return out, api.RetvalToVPPApiError(out.Retval)
 124 }
 125
 126 func (c *serviceClient) Ikev2NonceGet(ctx context.Context, in *Ikev2NonceGet) (*Ikev2NonceGetReply, error) {
 127         out := new(Ikev2NonceGetReply)
 128         err := c.conn.Invoke(ctx, in, out)
 129         if err != nil {
 130                 return nil, err
 131         }
 132         return out, api.RetvalToVPPApiError(out.Retval)
 133 }
 134
 135 func (c *serviceClient) Ikev2PluginGetVersion(ctx context.Context, in *Ikev2PluginGetVersion) (*Ikev2PluginGetVersionReply, error) {
 136         out := new(Ikev2PluginGetVersionReply)
 137         err := c.conn.Invoke(ctx, in, out)
 138         if err != nil {
 139                 return nil, err
 140         }
 141         return out, nil
 142 }
 143
 144 func (c *serviceClient) Ikev2ProfileAddDel(ctx context.Context, in *Ikev2ProfileAddDel) (*Ikev2ProfileAddDelReply, error) {
 145         out := new(Ikev2ProfileAddDelReply)
 146         err := c.conn.Invoke(ctx, in, out)
 147         if err != nil {
 148                 return nil, err
 149         }
 150         return out, api.RetvalToVPPApiError(out.Retval)
 151 }
 152
 153 func (c *serviceClient) Ikev2ProfileDisableNatt(ctx context.Context, in *Ikev2ProfileDisableNatt) (*Ikev2ProfileDisableNattReply, error) {
 154         out := new(Ikev2ProfileDisableNattReply)
 155         err := c.conn.Invoke(ctx, in, out)
 156         if err != nil {
 157                 return nil, err
 158         }
 159         return out, api.RetvalToVPPApiError(out.Retval)
 160 }
 161
 162 func (c *serviceClient) Ikev2ProfileDump(ctx context.Context, in *Ikev2ProfileDump) (RPCService_Ikev2ProfileDumpClient, error) {
 163         stream, err := c.conn.NewStream(ctx)
 164         if err != nil {
 165                 return nil, err
 166         }
 167         x := &serviceClient_Ikev2ProfileDumpClient{stream}
 168         if err := x.Stream.SendMsg(in); err != nil {
 169                 return nil, err
 170         }
 171         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 172                 return nil, err
 173         }
 174         return x, nil
 175 }
 176
 177 type RPCService_Ikev2ProfileDumpClient interface {
 178         Recv() (*Ikev2ProfileDetails, error)
 179         api.Stream
 180 }
 181
 182 type serviceClient_Ikev2ProfileDumpClient struct {
 183         api.Stream
 184 }
 185
 186 func (c *serviceClient_Ikev2ProfileDumpClient) Recv() (*Ikev2ProfileDetails, error) {
 187         msg, err := c.Stream.RecvMsg()
 188         if err != nil {
 189                 return nil, err
 190         }
 191         switch m := msg.(type) {
 192         case *Ikev2ProfileDetails:
 193                 return m, nil
 194         case *vpe.ControlPingReply:
 195                 return nil, io.EOF
 196         default:
 197                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 198         }
 199 }
 200
 201 func (c *serviceClient) Ikev2ProfileSetAuth(ctx context.Context, in *Ikev2ProfileSetAuth) (*Ikev2ProfileSetAuthReply, error) {
 202         out := new(Ikev2ProfileSetAuthReply)
 203         err := c.conn.Invoke(ctx, in, out)
 204         if err != nil {
 205                 return nil, err
 206         }
 207         return out, api.RetvalToVPPApiError(out.Retval)
 208 }
 209
 210 func (c *serviceClient) Ikev2ProfileSetID(ctx context.Context, in *Ikev2ProfileSetID) (*Ikev2ProfileSetIDReply, error) {
 211         out := new(Ikev2ProfileSetIDReply)
 212         err := c.conn.Invoke(ctx, in, out)
 213         if err != nil {
 214                 return nil, err
 215         }
 216         return out, api.RetvalToVPPApiError(out.Retval)
 217 }
 218
 219 func (c *serviceClient) Ikev2ProfileSetIpsecUDPPort(ctx context.Context, in *Ikev2ProfileSetIpsecUDPPort) (*Ikev2ProfileSetIpsecUDPPortReply, error) {
 220         out := new(Ikev2ProfileSetIpsecUDPPortReply)
 221         err := c.conn.Invoke(ctx, in, out)
 222         if err != nil {
 223                 return nil, err
 224         }
 225         return out, api.RetvalToVPPApiError(out.Retval)
 226 }
 227
 228 func (c *serviceClient) Ikev2ProfileSetLiveness(ctx context.Context, in *Ikev2ProfileSetLiveness) (*Ikev2ProfileSetLivenessReply, error) {
 229         out := new(Ikev2ProfileSetLivenessReply)
 230         err := c.conn.Invoke(ctx, in, out)
 231         if err != nil {
 232                 return nil, err
 233         }
 234         return out, api.RetvalToVPPApiError(out.Retval)
 235 }
 236
 237 func (c *serviceClient) Ikev2ProfileSetTs(ctx context.Context, in *Ikev2ProfileSetTs) (*Ikev2ProfileSetTsReply, error) {
 238         out := new(Ikev2ProfileSetTsReply)
 239         err := c.conn.Invoke(ctx, in, out)
 240         if err != nil {
 241                 return nil, err
 242         }
 243         return out, api.RetvalToVPPApiError(out.Retval)
 244 }
 245
 246 func (c *serviceClient) Ikev2ProfileSetUDPEncap(ctx context.Context, in *Ikev2ProfileSetUDPEncap) (*Ikev2ProfileSetUDPEncapReply, error) {
 247         out := new(Ikev2ProfileSetUDPEncapReply)
 248         err := c.conn.Invoke(ctx, in, out)
 249         if err != nil {
 250                 return nil, err
 251         }
 252         return out, api.RetvalToVPPApiError(out.Retval)
 253 }
 254
 255 func (c *serviceClient) Ikev2SaDump(ctx context.Context, in *Ikev2SaDump) (RPCService_Ikev2SaDumpClient, error) {
 256         stream, err := c.conn.NewStream(ctx)
 257         if err != nil {
 258                 return nil, err
 259         }
 260         x := &serviceClient_Ikev2SaDumpClient{stream}
 261         if err := x.Stream.SendMsg(in); err != nil {
 262                 return nil, err
 263         }
 264         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 265                 return nil, err
 266         }
 267         return x, nil
 268 }
 269
 270 type RPCService_Ikev2SaDumpClient interface {
 271         Recv() (*Ikev2SaDetails, error)
 272         api.Stream
 273 }
 274
 275 type serviceClient_Ikev2SaDumpClient struct {
 276         api.Stream
 277 }
 278
 279 func (c *serviceClient_Ikev2SaDumpClient) Recv() (*Ikev2SaDetails, error) {
 280         msg, err := c.Stream.RecvMsg()
 281         if err != nil {
 282                 return nil, err
 283         }
 284         switch m := msg.(type) {
 285         case *Ikev2SaDetails:
 286                 return m, nil
 287         case *vpe.ControlPingReply:
 288                 return nil, io.EOF
 289         default:
 290                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 291         }
 292 }
 293
 294 func (c *serviceClient) Ikev2SetEspTransforms(ctx context.Context, in *Ikev2SetEspTransforms) (*Ikev2SetEspTransformsReply, error) {
 295         out := new(Ikev2SetEspTransformsReply)
 296         err := c.conn.Invoke(ctx, in, out)
 297         if err != nil {
 298                 return nil, err
 299         }
 300         return out, api.RetvalToVPPApiError(out.Retval)
 301 }
 302
 303 func (c *serviceClient) Ikev2SetIkeTransforms(ctx context.Context, in *Ikev2SetIkeTransforms) (*Ikev2SetIkeTransformsReply, error) {
 304         out := new(Ikev2SetIkeTransformsReply)
 305         err := c.conn.Invoke(ctx, in, out)
 306         if err != nil {
 307                 return nil, err
 308         }
 309         return out, api.RetvalToVPPApiError(out.Retval)
 310 }
 311
 312 func (c *serviceClient) Ikev2SetLocalKey(ctx context.Context, in *Ikev2SetLocalKey) (*Ikev2SetLocalKeyReply, error) {
 313         out := new(Ikev2SetLocalKeyReply)
 314         err := c.conn.Invoke(ctx, in, out)
 315         if err != nil {
 316                 return nil, err
 317         }
 318         return out, api.RetvalToVPPApiError(out.Retval)
 319 }
 320
 321 func (c *serviceClient) Ikev2SetResponder(ctx context.Context, in *Ikev2SetResponder) (*Ikev2SetResponderReply, error) {
 322         out := new(Ikev2SetResponderReply)
 323         err := c.conn.Invoke(ctx, in, out)
 324         if err != nil {
 325                 return nil, err
 326         }
 327         return out, api.RetvalToVPPApiError(out.Retval)
 328 }
 329
 330 func (c *serviceClient) Ikev2SetResponderHostname(ctx context.Context, in *Ikev2SetResponderHostname) (*Ikev2SetResponderHostnameReply, error) {
 331         out := new(Ikev2SetResponderHostnameReply)
 332         err := c.conn.Invoke(ctx, in, out)
 333         if err != nil {
 334                 return nil, err
 335         }
 336         return out, api.RetvalToVPPApiError(out.Retval)
 337 }
 338
 339 func (c *serviceClient) Ikev2SetSaLifetime(ctx context.Context, in *Ikev2SetSaLifetime) (*Ikev2SetSaLifetimeReply, error) {
 340         out := new(Ikev2SetSaLifetimeReply)
 341         err := c.conn.Invoke(ctx, in, out)
 342         if err != nil {
 343                 return nil, err
 344         }
 345         return out, api.RetvalToVPPApiError(out.Retval)
 346 }
 347
 348 func (c *serviceClient) Ikev2SetTunnelInterface(ctx context.Context, in *Ikev2SetTunnelInterface) (*Ikev2SetTunnelInterfaceReply, error) {
 349         out := new(Ikev2SetTunnelInterfaceReply)
 350         err := c.conn.Invoke(ctx, in, out)
 351         if err != nil {
 352                 return nil, err
 353         }
 354         return out, api.RetvalToVPPApiError(out.Retval)
 355 }
 356
 357 func (c *serviceClient) Ikev2TrafficSelectorDump(ctx context.Context, in *Ikev2TrafficSelectorDump) (RPCService_Ikev2TrafficSelectorDumpClient, error) {
 358         stream, err := c.conn.NewStream(ctx)
 359         if err != nil {
 360                 return nil, err
 361         }
 362         x := &serviceClient_Ikev2TrafficSelectorDumpClient{stream}
 363         if err := x.Stream.SendMsg(in); err != nil {
 364                 return nil, err
 365         }
 366         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 367                 return nil, err
 368         }
 369         return x, nil
 370 }
 371
 372 type RPCService_Ikev2TrafficSelectorDumpClient interface {
 373         Recv() (*Ikev2TrafficSelectorDetails, error)
 374         api.Stream
 375 }
 376
 377 type serviceClient_Ikev2TrafficSelectorDumpClient struct {
 378         api.Stream
 379 }
 380
 381 func (c *serviceClient_Ikev2TrafficSelectorDumpClient) Recv() (*Ikev2TrafficSelectorDetails, error) {
 382         msg, err := c.Stream.RecvMsg()
 383         if err != nil {
 384                 return nil, err
 385         }
 386         switch m := msg.(type) {
 387         case *Ikev2TrafficSelectorDetails:
 388                 return m, nil
 389         case *vpe.ControlPingReply:
 390                 return nil, io.EOF
 391         default:
 392                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 393         }
 394 }