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         memclnt "git.fd.io/govpp.git/binapi/memclnt"
  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(&memclnt.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 *memclnt.ControlPingReply:
  84                 err = c.Stream.Close()
  85                 if err != nil {
  86                         return nil, err
  87                 }
  88                 return nil, io.EOF
  89         default:
  90                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  91         }
  92 }
  93
  94 func (c *serviceClient) Ikev2InitiateDelChildSa(ctx context.Context, in *Ikev2InitiateDelChildSa) (*Ikev2InitiateDelChildSaReply, error) {
  95         out := new(Ikev2InitiateDelChildSaReply)
  96         err := c.conn.Invoke(ctx, in, out)
  97         if err != nil {
  98                 return nil, err
  99         }
 100         return out, api.RetvalToVPPApiError(out.Retval)
 101 }
 102
 103 func (c *serviceClient) Ikev2InitiateDelIkeSa(ctx context.Context, in *Ikev2InitiateDelIkeSa) (*Ikev2InitiateDelIkeSaReply, error) {
 104         out := new(Ikev2InitiateDelIkeSaReply)
 105         err := c.conn.Invoke(ctx, in, out)
 106         if err != nil {
 107                 return nil, err
 108         }
 109         return out, api.RetvalToVPPApiError(out.Retval)
 110 }
 111
 112 func (c *serviceClient) Ikev2InitiateRekeyChildSa(ctx context.Context, in *Ikev2InitiateRekeyChildSa) (*Ikev2InitiateRekeyChildSaReply, error) {
 113         out := new(Ikev2InitiateRekeyChildSaReply)
 114         err := c.conn.Invoke(ctx, in, out)
 115         if err != nil {
 116                 return nil, err
 117         }
 118         return out, api.RetvalToVPPApiError(out.Retval)
 119 }
 120
 121 func (c *serviceClient) Ikev2InitiateSaInit(ctx context.Context, in *Ikev2InitiateSaInit) (*Ikev2InitiateSaInitReply, error) {
 122         out := new(Ikev2InitiateSaInitReply)
 123         err := c.conn.Invoke(ctx, in, out)
 124         if err != nil {
 125                 return nil, err
 126         }
 127         return out, api.RetvalToVPPApiError(out.Retval)
 128 }
 129
 130 func (c *serviceClient) Ikev2NonceGet(ctx context.Context, in *Ikev2NonceGet) (*Ikev2NonceGetReply, error) {
 131         out := new(Ikev2NonceGetReply)
 132         err := c.conn.Invoke(ctx, in, out)
 133         if err != nil {
 134                 return nil, err
 135         }
 136         return out, api.RetvalToVPPApiError(out.Retval)
 137 }
 138
 139 func (c *serviceClient) Ikev2PluginGetVersion(ctx context.Context, in *Ikev2PluginGetVersion) (*Ikev2PluginGetVersionReply, error) {
 140         out := new(Ikev2PluginGetVersionReply)
 141         err := c.conn.Invoke(ctx, in, out)
 142         if err != nil {
 143                 return nil, err
 144         }
 145         return out, nil
 146 }
 147
 148 func (c *serviceClient) Ikev2ProfileAddDel(ctx context.Context, in *Ikev2ProfileAddDel) (*Ikev2ProfileAddDelReply, error) {
 149         out := new(Ikev2ProfileAddDelReply)
 150         err := c.conn.Invoke(ctx, in, out)
 151         if err != nil {
 152                 return nil, err
 153         }
 154         return out, api.RetvalToVPPApiError(out.Retval)
 155 }
 156
 157 func (c *serviceClient) Ikev2ProfileDisableNatt(ctx context.Context, in *Ikev2ProfileDisableNatt) (*Ikev2ProfileDisableNattReply, error) {
 158         out := new(Ikev2ProfileDisableNattReply)
 159         err := c.conn.Invoke(ctx, in, out)
 160         if err != nil {
 161                 return nil, err
 162         }
 163         return out, api.RetvalToVPPApiError(out.Retval)
 164 }
 165
 166 func (c *serviceClient) Ikev2ProfileDump(ctx context.Context, in *Ikev2ProfileDump) (RPCService_Ikev2ProfileDumpClient, error) {
 167         stream, err := c.conn.NewStream(ctx)
 168         if err != nil {
 169                 return nil, err
 170         }
 171         x := &serviceClient_Ikev2ProfileDumpClient{stream}
 172         if err := x.Stream.SendMsg(in); err != nil {
 173                 return nil, err
 174         }
 175         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 176                 return nil, err
 177         }
 178         return x, nil
 179 }
 180
 181 type RPCService_Ikev2ProfileDumpClient interface {
 182         Recv() (*Ikev2ProfileDetails, error)
 183         api.Stream
 184 }
 185
 186 type serviceClient_Ikev2ProfileDumpClient struct {
 187         api.Stream
 188 }
 189
 190 func (c *serviceClient_Ikev2ProfileDumpClient) Recv() (*Ikev2ProfileDetails, error) {
 191         msg, err := c.Stream.RecvMsg()
 192         if err != nil {
 193                 return nil, err
 194         }
 195         switch m := msg.(type) {
 196         case *Ikev2ProfileDetails:
 197                 return m, nil
 198         case *memclnt.ControlPingReply:
 199                 err = c.Stream.Close()
 200                 if err != nil {
 201                         return nil, err
 202                 }
 203                 return nil, io.EOF
 204         default:
 205                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 206         }
 207 }
 208
 209 func (c *serviceClient) Ikev2ProfileSetAuth(ctx context.Context, in *Ikev2ProfileSetAuth) (*Ikev2ProfileSetAuthReply, error) {
 210         out := new(Ikev2ProfileSetAuthReply)
 211         err := c.conn.Invoke(ctx, in, out)
 212         if err != nil {
 213                 return nil, err
 214         }
 215         return out, api.RetvalToVPPApiError(out.Retval)
 216 }
 217
 218 func (c *serviceClient) Ikev2ProfileSetID(ctx context.Context, in *Ikev2ProfileSetID) (*Ikev2ProfileSetIDReply, error) {
 219         out := new(Ikev2ProfileSetIDReply)
 220         err := c.conn.Invoke(ctx, in, out)
 221         if err != nil {
 222                 return nil, err
 223         }
 224         return out, api.RetvalToVPPApiError(out.Retval)
 225 }
 226
 227 func (c *serviceClient) Ikev2ProfileSetIpsecUDPPort(ctx context.Context, in *Ikev2ProfileSetIpsecUDPPort) (*Ikev2ProfileSetIpsecUDPPortReply, error) {
 228         out := new(Ikev2ProfileSetIpsecUDPPortReply)
 229         err := c.conn.Invoke(ctx, in, out)
 230         if err != nil {
 231                 return nil, err
 232         }
 233         return out, api.RetvalToVPPApiError(out.Retval)
 234 }
 235
 236 func (c *serviceClient) Ikev2ProfileSetLiveness(ctx context.Context, in *Ikev2ProfileSetLiveness) (*Ikev2ProfileSetLivenessReply, error) {
 237         out := new(Ikev2ProfileSetLivenessReply)
 238         err := c.conn.Invoke(ctx, in, out)
 239         if err != nil {
 240                 return nil, err
 241         }
 242         return out, api.RetvalToVPPApiError(out.Retval)
 243 }
 244
 245 func (c *serviceClient) Ikev2ProfileSetTs(ctx context.Context, in *Ikev2ProfileSetTs) (*Ikev2ProfileSetTsReply, error) {
 246         out := new(Ikev2ProfileSetTsReply)
 247         err := c.conn.Invoke(ctx, in, out)
 248         if err != nil {
 249                 return nil, err
 250         }
 251         return out, api.RetvalToVPPApiError(out.Retval)
 252 }
 253
 254 func (c *serviceClient) Ikev2ProfileSetUDPEncap(ctx context.Context, in *Ikev2ProfileSetUDPEncap) (*Ikev2ProfileSetUDPEncapReply, error) {
 255         out := new(Ikev2ProfileSetUDPEncapReply)
 256         err := c.conn.Invoke(ctx, in, out)
 257         if err != nil {
 258                 return nil, err
 259         }
 260         return out, api.RetvalToVPPApiError(out.Retval)
 261 }
 262
 263 func (c *serviceClient) Ikev2SaDump(ctx context.Context, in *Ikev2SaDump) (RPCService_Ikev2SaDumpClient, error) {
 264         stream, err := c.conn.NewStream(ctx)
 265         if err != nil {
 266                 return nil, err
 267         }
 268         x := &serviceClient_Ikev2SaDumpClient{stream}
 269         if err := x.Stream.SendMsg(in); err != nil {
 270                 return nil, err
 271         }
 272         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 273                 return nil, err
 274         }
 275         return x, nil
 276 }
 277
 278 type RPCService_Ikev2SaDumpClient interface {
 279         Recv() (*Ikev2SaDetails, error)
 280         api.Stream
 281 }
 282
 283 type serviceClient_Ikev2SaDumpClient struct {
 284         api.Stream
 285 }
 286
 287 func (c *serviceClient_Ikev2SaDumpClient) Recv() (*Ikev2SaDetails, error) {
 288         msg, err := c.Stream.RecvMsg()
 289         if err != nil {
 290                 return nil, err
 291         }
 292         switch m := msg.(type) {
 293         case *Ikev2SaDetails:
 294                 return m, nil
 295         case *memclnt.ControlPingReply:
 296                 err = c.Stream.Close()
 297                 if err != nil {
 298                         return nil, err
 299                 }
 300                 return nil, io.EOF
 301         default:
 302                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 303         }
 304 }
 305
 306 func (c *serviceClient) Ikev2SetEspTransforms(ctx context.Context, in *Ikev2SetEspTransforms) (*Ikev2SetEspTransformsReply, error) {
 307         out := new(Ikev2SetEspTransformsReply)
 308         err := c.conn.Invoke(ctx, in, out)
 309         if err != nil {
 310                 return nil, err
 311         }
 312         return out, api.RetvalToVPPApiError(out.Retval)
 313 }
 314
 315 func (c *serviceClient) Ikev2SetIkeTransforms(ctx context.Context, in *Ikev2SetIkeTransforms) (*Ikev2SetIkeTransformsReply, error) {
 316         out := new(Ikev2SetIkeTransformsReply)
 317         err := c.conn.Invoke(ctx, in, out)
 318         if err != nil {
 319                 return nil, err
 320         }
 321         return out, api.RetvalToVPPApiError(out.Retval)
 322 }
 323
 324 func (c *serviceClient) Ikev2SetLocalKey(ctx context.Context, in *Ikev2SetLocalKey) (*Ikev2SetLocalKeyReply, error) {
 325         out := new(Ikev2SetLocalKeyReply)
 326         err := c.conn.Invoke(ctx, in, out)
 327         if err != nil {
 328                 return nil, err
 329         }
 330         return out, api.RetvalToVPPApiError(out.Retval)
 331 }
 332
 333 func (c *serviceClient) Ikev2SetResponder(ctx context.Context, in *Ikev2SetResponder) (*Ikev2SetResponderReply, error) {
 334         out := new(Ikev2SetResponderReply)
 335         err := c.conn.Invoke(ctx, in, out)
 336         if err != nil {
 337                 return nil, err
 338         }
 339         return out, api.RetvalToVPPApiError(out.Retval)
 340 }
 341
 342 func (c *serviceClient) Ikev2SetResponderHostname(ctx context.Context, in *Ikev2SetResponderHostname) (*Ikev2SetResponderHostnameReply, error) {
 343         out := new(Ikev2SetResponderHostnameReply)
 344         err := c.conn.Invoke(ctx, in, out)
 345         if err != nil {
 346                 return nil, err
 347         }
 348         return out, api.RetvalToVPPApiError(out.Retval)
 349 }
 350
 351 func (c *serviceClient) Ikev2SetSaLifetime(ctx context.Context, in *Ikev2SetSaLifetime) (*Ikev2SetSaLifetimeReply, error) {
 352         out := new(Ikev2SetSaLifetimeReply)
 353         err := c.conn.Invoke(ctx, in, out)
 354         if err != nil {
 355                 return nil, err
 356         }
 357         return out, api.RetvalToVPPApiError(out.Retval)
 358 }
 359
 360 func (c *serviceClient) Ikev2SetTunnelInterface(ctx context.Context, in *Ikev2SetTunnelInterface) (*Ikev2SetTunnelInterfaceReply, error) {
 361         out := new(Ikev2SetTunnelInterfaceReply)
 362         err := c.conn.Invoke(ctx, in, out)
 363         if err != nil {
 364                 return nil, err
 365         }
 366         return out, api.RetvalToVPPApiError(out.Retval)
 367 }
 368
 369 func (c *serviceClient) Ikev2TrafficSelectorDump(ctx context.Context, in *Ikev2TrafficSelectorDump) (RPCService_Ikev2TrafficSelectorDumpClient, error) {
 370         stream, err := c.conn.NewStream(ctx)
 371         if err != nil {
 372                 return nil, err
 373         }
 374         x := &serviceClient_Ikev2TrafficSelectorDumpClient{stream}
 375         if err := x.Stream.SendMsg(in); err != nil {
 376                 return nil, err
 377         }
 378         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
 379                 return nil, err
 380         }
 381         return x, nil
 382 }
 383
 384 type RPCService_Ikev2TrafficSelectorDumpClient interface {
 385         Recv() (*Ikev2TrafficSelectorDetails, error)
 386         api.Stream
 387 }
 388
 389 type serviceClient_Ikev2TrafficSelectorDumpClient struct {
 390         api.Stream
 391 }
 392
 393 func (c *serviceClient_Ikev2TrafficSelectorDumpClient) Recv() (*Ikev2TrafficSelectorDetails, error) {
 394         msg, err := c.Stream.RecvMsg()
 395         if err != nil {
 396                 return nil, err
 397         }
 398         switch m := msg.(type) {
 399         case *Ikev2TrafficSelectorDetails:
 400                 return m, nil
 401         case *memclnt.ControlPingReply:
 402                 err = c.Stream.Close()
 403                 if err != nil {
 404                         return nil, err
 405                 }
 406                 return nil, io.EOF
 407         default:
 408                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 409         }
 410 }