binapi/interface/interface_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package interfaces
   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 interface.
  15 type RPCService interface {
  16         CollectDetailedInterfaceStats(ctx context.Context, in *CollectDetailedInterfaceStats) (*CollectDetailedInterfaceStatsReply, error)
  17         CreateLoopback(ctx context.Context, in *CreateLoopback) (*CreateLoopbackReply, error)
  18         CreateLoopbackInstance(ctx context.Context, in *CreateLoopbackInstance) (*CreateLoopbackInstanceReply, error)
  19         CreateSubif(ctx context.Context, in *CreateSubif) (*CreateSubifReply, error)
  20         CreateVlanSubif(ctx context.Context, in *CreateVlanSubif) (*CreateVlanSubifReply, error)
  21         DeleteLoopback(ctx context.Context, in *DeleteLoopback) (*DeleteLoopbackReply, error)
  22         DeleteSubif(ctx context.Context, in *DeleteSubif) (*DeleteSubifReply, error)
  23         HwInterfaceSetMtu(ctx context.Context, in *HwInterfaceSetMtu) (*HwInterfaceSetMtuReply, error)
  24         InterfaceNameRenumber(ctx context.Context, in *InterfaceNameRenumber) (*InterfaceNameRenumberReply, error)
  25         SwInterfaceAddDelAddress(ctx context.Context, in *SwInterfaceAddDelAddress) (*SwInterfaceAddDelAddressReply, error)
  26         SwInterfaceAddDelMacAddress(ctx context.Context, in *SwInterfaceAddDelMacAddress) (*SwInterfaceAddDelMacAddressReply, error)
  27         SwInterfaceAddressReplaceBegin(ctx context.Context, in *SwInterfaceAddressReplaceBegin) (*SwInterfaceAddressReplaceBeginReply, error)
  28         SwInterfaceAddressReplaceEnd(ctx context.Context, in *SwInterfaceAddressReplaceEnd) (*SwInterfaceAddressReplaceEndReply, error)
  29         SwInterfaceClearStats(ctx context.Context, in *SwInterfaceClearStats) (*SwInterfaceClearStatsReply, error)
  30         SwInterfaceDump(ctx context.Context, in *SwInterfaceDump) (RPCService_SwInterfaceDumpClient, error)
  31         SwInterfaceGetMacAddress(ctx context.Context, in *SwInterfaceGetMacAddress) (*SwInterfaceGetMacAddressReply, error)
  32         SwInterfaceGetTable(ctx context.Context, in *SwInterfaceGetTable) (*SwInterfaceGetTableReply, error)
  33         SwInterfaceRxPlacementDump(ctx context.Context, in *SwInterfaceRxPlacementDump) (RPCService_SwInterfaceRxPlacementDumpClient, error)
  34         SwInterfaceSetFlags(ctx context.Context, in *SwInterfaceSetFlags) (*SwInterfaceSetFlagsReply, error)
  35         SwInterfaceSetIPDirectedBroadcast(ctx context.Context, in *SwInterfaceSetIPDirectedBroadcast) (*SwInterfaceSetIPDirectedBroadcastReply, error)
  36         SwInterfaceSetMacAddress(ctx context.Context, in *SwInterfaceSetMacAddress) (*SwInterfaceSetMacAddressReply, error)
  37         SwInterfaceSetMtu(ctx context.Context, in *SwInterfaceSetMtu) (*SwInterfaceSetMtuReply, error)
  38         SwInterfaceSetPromisc(ctx context.Context, in *SwInterfaceSetPromisc) (*SwInterfaceSetPromiscReply, error)
  39         SwInterfaceSetRxMode(ctx context.Context, in *SwInterfaceSetRxMode) (*SwInterfaceSetRxModeReply, error)
  40         SwInterfaceSetRxPlacement(ctx context.Context, in *SwInterfaceSetRxPlacement) (*SwInterfaceSetRxPlacementReply, error)
  41         SwInterfaceSetTable(ctx context.Context, in *SwInterfaceSetTable) (*SwInterfaceSetTableReply, error)
  42         SwInterfaceSetUnnumbered(ctx context.Context, in *SwInterfaceSetUnnumbered) (*SwInterfaceSetUnnumberedReply, error)
  43         SwInterfaceTagAddDel(ctx context.Context, in *SwInterfaceTagAddDel) (*SwInterfaceTagAddDelReply, error)
  44         WantInterfaceEvents(ctx context.Context, in *WantInterfaceEvents) (*WantInterfaceEventsReply, error)
  45 }
  46
  47 type serviceClient struct {
  48         conn api.Connection
  49 }
  50
  51 func NewServiceClient(conn api.Connection) RPCService {
  52         return &serviceClient{conn}
  53 }
  54
  55 func (c *serviceClient) CollectDetailedInterfaceStats(ctx context.Context, in *CollectDetailedInterfaceStats) (*CollectDetailedInterfaceStatsReply, error) {
  56         out := new(CollectDetailedInterfaceStatsReply)
  57         err := c.conn.Invoke(ctx, in, out)
  58         if err != nil {
  59                 return nil, err
  60         }
  61         return out, api.RetvalToVPPApiError(out.Retval)
  62 }
  63
  64 func (c *serviceClient) CreateLoopback(ctx context.Context, in *CreateLoopback) (*CreateLoopbackReply, error) {
  65         out := new(CreateLoopbackReply)
  66         err := c.conn.Invoke(ctx, in, out)
  67         if err != nil {
  68                 return nil, err
  69         }
  70         return out, api.RetvalToVPPApiError(out.Retval)
  71 }
  72
  73 func (c *serviceClient) CreateLoopbackInstance(ctx context.Context, in *CreateLoopbackInstance) (*CreateLoopbackInstanceReply, error) {
  74         out := new(CreateLoopbackInstanceReply)
  75         err := c.conn.Invoke(ctx, in, out)
  76         if err != nil {
  77                 return nil, err
  78         }
  79         return out, api.RetvalToVPPApiError(out.Retval)
  80 }
  81
  82 func (c *serviceClient) CreateSubif(ctx context.Context, in *CreateSubif) (*CreateSubifReply, error) {
  83         out := new(CreateSubifReply)
  84         err := c.conn.Invoke(ctx, in, out)
  85         if err != nil {
  86                 return nil, err
  87         }
  88         return out, api.RetvalToVPPApiError(out.Retval)
  89 }
  90
  91 func (c *serviceClient) CreateVlanSubif(ctx context.Context, in *CreateVlanSubif) (*CreateVlanSubifReply, error) {
  92         out := new(CreateVlanSubifReply)
  93         err := c.conn.Invoke(ctx, in, out)
  94         if err != nil {
  95                 return nil, err
  96         }
  97         return out, api.RetvalToVPPApiError(out.Retval)
  98 }
  99
 100 func (c *serviceClient) DeleteLoopback(ctx context.Context, in *DeleteLoopback) (*DeleteLoopbackReply, error) {
 101         out := new(DeleteLoopbackReply)
 102         err := c.conn.Invoke(ctx, in, out)
 103         if err != nil {
 104                 return nil, err
 105         }
 106         return out, api.RetvalToVPPApiError(out.Retval)
 107 }
 108
 109 func (c *serviceClient) DeleteSubif(ctx context.Context, in *DeleteSubif) (*DeleteSubifReply, error) {
 110         out := new(DeleteSubifReply)
 111         err := c.conn.Invoke(ctx, in, out)
 112         if err != nil {
 113                 return nil, err
 114         }
 115         return out, api.RetvalToVPPApiError(out.Retval)
 116 }
 117
 118 func (c *serviceClient) HwInterfaceSetMtu(ctx context.Context, in *HwInterfaceSetMtu) (*HwInterfaceSetMtuReply, error) {
 119         out := new(HwInterfaceSetMtuReply)
 120         err := c.conn.Invoke(ctx, in, out)
 121         if err != nil {
 122                 return nil, err
 123         }
 124         return out, api.RetvalToVPPApiError(out.Retval)
 125 }
 126
 127 func (c *serviceClient) InterfaceNameRenumber(ctx context.Context, in *InterfaceNameRenumber) (*InterfaceNameRenumberReply, error) {
 128         out := new(InterfaceNameRenumberReply)
 129         err := c.conn.Invoke(ctx, in, out)
 130         if err != nil {
 131                 return nil, err
 132         }
 133         return out, api.RetvalToVPPApiError(out.Retval)
 134 }
 135
 136 func (c *serviceClient) SwInterfaceAddDelAddress(ctx context.Context, in *SwInterfaceAddDelAddress) (*SwInterfaceAddDelAddressReply, error) {
 137         out := new(SwInterfaceAddDelAddressReply)
 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) SwInterfaceAddDelMacAddress(ctx context.Context, in *SwInterfaceAddDelMacAddress) (*SwInterfaceAddDelMacAddressReply, error) {
 146         out := new(SwInterfaceAddDelMacAddressReply)
 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) SwInterfaceAddressReplaceBegin(ctx context.Context, in *SwInterfaceAddressReplaceBegin) (*SwInterfaceAddressReplaceBeginReply, error) {
 155         out := new(SwInterfaceAddressReplaceBeginReply)
 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) SwInterfaceAddressReplaceEnd(ctx context.Context, in *SwInterfaceAddressReplaceEnd) (*SwInterfaceAddressReplaceEndReply, error) {
 164         out := new(SwInterfaceAddressReplaceEndReply)
 165         err := c.conn.Invoke(ctx, in, out)
 166         if err != nil {
 167                 return nil, err
 168         }
 169         return out, api.RetvalToVPPApiError(out.Retval)
 170 }
 171
 172 func (c *serviceClient) SwInterfaceClearStats(ctx context.Context, in *SwInterfaceClearStats) (*SwInterfaceClearStatsReply, error) {
 173         out := new(SwInterfaceClearStatsReply)
 174         err := c.conn.Invoke(ctx, in, out)
 175         if err != nil {
 176                 return nil, err
 177         }
 178         return out, api.RetvalToVPPApiError(out.Retval)
 179 }
 180
 181 func (c *serviceClient) SwInterfaceDump(ctx context.Context, in *SwInterfaceDump) (RPCService_SwInterfaceDumpClient, error) {
 182         stream, err := c.conn.NewStream(ctx)
 183         if err != nil {
 184                 return nil, err
 185         }
 186         x := &serviceClient_SwInterfaceDumpClient{stream}
 187         if err := x.Stream.SendMsg(in); err != nil {
 188                 return nil, err
 189         }
 190         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 191                 return nil, err
 192         }
 193         return x, nil
 194 }
 195
 196 type RPCService_SwInterfaceDumpClient interface {
 197         Recv() (*SwInterfaceDetails, error)
 198         api.Stream
 199 }
 200
 201 type serviceClient_SwInterfaceDumpClient struct {
 202         api.Stream
 203 }
 204
 205 func (c *serviceClient_SwInterfaceDumpClient) Recv() (*SwInterfaceDetails, error) {
 206         msg, err := c.Stream.RecvMsg()
 207         if err != nil {
 208                 return nil, err
 209         }
 210         switch m := msg.(type) {
 211         case *SwInterfaceDetails:
 212                 return m, nil
 213         case *vpe.ControlPingReply:
 214                 err = c.Stream.Close()
 215                 if err != nil {
 216                         return nil, err
 217                 }
 218                 return nil, io.EOF
 219         default:
 220                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 221         }
 222 }
 223
 224 func (c *serviceClient) SwInterfaceGetMacAddress(ctx context.Context, in *SwInterfaceGetMacAddress) (*SwInterfaceGetMacAddressReply, error) {
 225         out := new(SwInterfaceGetMacAddressReply)
 226         err := c.conn.Invoke(ctx, in, out)
 227         if err != nil {
 228                 return nil, err
 229         }
 230         return out, api.RetvalToVPPApiError(out.Retval)
 231 }
 232
 233 func (c *serviceClient) SwInterfaceGetTable(ctx context.Context, in *SwInterfaceGetTable) (*SwInterfaceGetTableReply, error) {
 234         out := new(SwInterfaceGetTableReply)
 235         err := c.conn.Invoke(ctx, in, out)
 236         if err != nil {
 237                 return nil, err
 238         }
 239         return out, api.RetvalToVPPApiError(out.Retval)
 240 }
 241
 242 func (c *serviceClient) SwInterfaceRxPlacementDump(ctx context.Context, in *SwInterfaceRxPlacementDump) (RPCService_SwInterfaceRxPlacementDumpClient, error) {
 243         stream, err := c.conn.NewStream(ctx)
 244         if err != nil {
 245                 return nil, err
 246         }
 247         x := &serviceClient_SwInterfaceRxPlacementDumpClient{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_SwInterfaceRxPlacementDumpClient interface {
 258         Recv() (*SwInterfaceRxPlacementDetails, error)
 259         api.Stream
 260 }
 261
 262 type serviceClient_SwInterfaceRxPlacementDumpClient struct {
 263         api.Stream
 264 }
 265
 266 func (c *serviceClient_SwInterfaceRxPlacementDumpClient) Recv() (*SwInterfaceRxPlacementDetails, error) {
 267         msg, err := c.Stream.RecvMsg()
 268         if err != nil {
 269                 return nil, err
 270         }
 271         switch m := msg.(type) {
 272         case *SwInterfaceRxPlacementDetails:
 273                 return m, nil
 274         case *vpe.ControlPingReply:
 275                 err = c.Stream.Close()
 276                 if err != nil {
 277                         return nil, err
 278                 }
 279                 return nil, io.EOF
 280         default:
 281                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 282         }
 283 }
 284
 285 func (c *serviceClient) SwInterfaceSetFlags(ctx context.Context, in *SwInterfaceSetFlags) (*SwInterfaceSetFlagsReply, error) {
 286         out := new(SwInterfaceSetFlagsReply)
 287         err := c.conn.Invoke(ctx, in, out)
 288         if err != nil {
 289                 return nil, err
 290         }
 291         return out, api.RetvalToVPPApiError(out.Retval)
 292 }
 293
 294 func (c *serviceClient) SwInterfaceSetIPDirectedBroadcast(ctx context.Context, in *SwInterfaceSetIPDirectedBroadcast) (*SwInterfaceSetIPDirectedBroadcastReply, error) {
 295         out := new(SwInterfaceSetIPDirectedBroadcastReply)
 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) SwInterfaceSetMacAddress(ctx context.Context, in *SwInterfaceSetMacAddress) (*SwInterfaceSetMacAddressReply, error) {
 304         out := new(SwInterfaceSetMacAddressReply)
 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) SwInterfaceSetMtu(ctx context.Context, in *SwInterfaceSetMtu) (*SwInterfaceSetMtuReply, error) {
 313         out := new(SwInterfaceSetMtuReply)
 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) SwInterfaceSetPromisc(ctx context.Context, in *SwInterfaceSetPromisc) (*SwInterfaceSetPromiscReply, error) {
 322         out := new(SwInterfaceSetPromiscReply)
 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) SwInterfaceSetRxMode(ctx context.Context, in *SwInterfaceSetRxMode) (*SwInterfaceSetRxModeReply, error) {
 331         out := new(SwInterfaceSetRxModeReply)
 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) SwInterfaceSetRxPlacement(ctx context.Context, in *SwInterfaceSetRxPlacement) (*SwInterfaceSetRxPlacementReply, error) {
 340         out := new(SwInterfaceSetRxPlacementReply)
 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) SwInterfaceSetTable(ctx context.Context, in *SwInterfaceSetTable) (*SwInterfaceSetTableReply, error) {
 349         out := new(SwInterfaceSetTableReply)
 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) SwInterfaceSetUnnumbered(ctx context.Context, in *SwInterfaceSetUnnumbered) (*SwInterfaceSetUnnumberedReply, error) {
 358         out := new(SwInterfaceSetUnnumberedReply)
 359         err := c.conn.Invoke(ctx, in, out)
 360         if err != nil {
 361                 return nil, err
 362         }
 363         return out, api.RetvalToVPPApiError(out.Retval)
 364 }
 365
 366 func (c *serviceClient) SwInterfaceTagAddDel(ctx context.Context, in *SwInterfaceTagAddDel) (*SwInterfaceTagAddDelReply, error) {
 367         out := new(SwInterfaceTagAddDelReply)
 368         err := c.conn.Invoke(ctx, in, out)
 369         if err != nil {
 370                 return nil, err
 371         }
 372         return out, api.RetvalToVPPApiError(out.Retval)
 373 }
 374
 375 func (c *serviceClient) WantInterfaceEvents(ctx context.Context, in *WantInterfaceEvents) (*WantInterfaceEventsReply, error) {
 376         out := new(WantInterfaceEventsReply)
 377         err := c.conn.Invoke(ctx, in, out)
 378         if err != nil {
 379                 return nil, err
 380         }
 381         return out, api.RetvalToVPPApiError(out.Retval)
 382 }