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         SwInterfaceSetRxMode(ctx context.Context, in *SwInterfaceSetRxMode) (*SwInterfaceSetRxModeReply, error)
  39         SwInterfaceSetRxPlacement(ctx context.Context, in *SwInterfaceSetRxPlacement) (*SwInterfaceSetRxPlacementReply, error)
  40         SwInterfaceSetTable(ctx context.Context, in *SwInterfaceSetTable) (*SwInterfaceSetTableReply, error)
  41         SwInterfaceSetUnnumbered(ctx context.Context, in *SwInterfaceSetUnnumbered) (*SwInterfaceSetUnnumberedReply, error)
  42         SwInterfaceTagAddDel(ctx context.Context, in *SwInterfaceTagAddDel) (*SwInterfaceTagAddDelReply, error)
  43         WantInterfaceEvents(ctx context.Context, in *WantInterfaceEvents) (*WantInterfaceEventsReply, error)
  44 }
  45
  46 type serviceClient struct {
  47         conn api.Connection
  48 }
  49
  50 func NewServiceClient(conn api.Connection) RPCService {
  51         return &serviceClient{conn}
  52 }
  53
  54 func (c *serviceClient) CollectDetailedInterfaceStats(ctx context.Context, in *CollectDetailedInterfaceStats) (*CollectDetailedInterfaceStatsReply, error) {
  55         out := new(CollectDetailedInterfaceStatsReply)
  56         err := c.conn.Invoke(ctx, in, out)
  57         if err != nil {
  58                 return nil, err
  59         }
  60         return out, nil
  61 }
  62
  63 func (c *serviceClient) CreateLoopback(ctx context.Context, in *CreateLoopback) (*CreateLoopbackReply, error) {
  64         out := new(CreateLoopbackReply)
  65         err := c.conn.Invoke(ctx, in, out)
  66         if err != nil {
  67                 return nil, err
  68         }
  69         return out, nil
  70 }
  71
  72 func (c *serviceClient) CreateLoopbackInstance(ctx context.Context, in *CreateLoopbackInstance) (*CreateLoopbackInstanceReply, error) {
  73         out := new(CreateLoopbackInstanceReply)
  74         err := c.conn.Invoke(ctx, in, out)
  75         if err != nil {
  76                 return nil, err
  77         }
  78         return out, nil
  79 }
  80
  81 func (c *serviceClient) CreateSubif(ctx context.Context, in *CreateSubif) (*CreateSubifReply, error) {
  82         out := new(CreateSubifReply)
  83         err := c.conn.Invoke(ctx, in, out)
  84         if err != nil {
  85                 return nil, err
  86         }
  87         return out, nil
  88 }
  89
  90 func (c *serviceClient) CreateVlanSubif(ctx context.Context, in *CreateVlanSubif) (*CreateVlanSubifReply, error) {
  91         out := new(CreateVlanSubifReply)
  92         err := c.conn.Invoke(ctx, in, out)
  93         if err != nil {
  94                 return nil, err
  95         }
  96         return out, nil
  97 }
  98
  99 func (c *serviceClient) DeleteLoopback(ctx context.Context, in *DeleteLoopback) (*DeleteLoopbackReply, error) {
 100         out := new(DeleteLoopbackReply)
 101         err := c.conn.Invoke(ctx, in, out)
 102         if err != nil {
 103                 return nil, err
 104         }
 105         return out, nil
 106 }
 107
 108 func (c *serviceClient) DeleteSubif(ctx context.Context, in *DeleteSubif) (*DeleteSubifReply, error) {
 109         out := new(DeleteSubifReply)
 110         err := c.conn.Invoke(ctx, in, out)
 111         if err != nil {
 112                 return nil, err
 113         }
 114         return out, nil
 115 }
 116
 117 func (c *serviceClient) HwInterfaceSetMtu(ctx context.Context, in *HwInterfaceSetMtu) (*HwInterfaceSetMtuReply, error) {
 118         out := new(HwInterfaceSetMtuReply)
 119         err := c.conn.Invoke(ctx, in, out)
 120         if err != nil {
 121                 return nil, err
 122         }
 123         return out, nil
 124 }
 125
 126 func (c *serviceClient) InterfaceNameRenumber(ctx context.Context, in *InterfaceNameRenumber) (*InterfaceNameRenumberReply, error) {
 127         out := new(InterfaceNameRenumberReply)
 128         err := c.conn.Invoke(ctx, in, out)
 129         if err != nil {
 130                 return nil, err
 131         }
 132         return out, nil
 133 }
 134
 135 func (c *serviceClient) SwInterfaceAddDelAddress(ctx context.Context, in *SwInterfaceAddDelAddress) (*SwInterfaceAddDelAddressReply, error) {
 136         out := new(SwInterfaceAddDelAddressReply)
 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) SwInterfaceAddDelMacAddress(ctx context.Context, in *SwInterfaceAddDelMacAddress) (*SwInterfaceAddDelMacAddressReply, error) {
 145         out := new(SwInterfaceAddDelMacAddressReply)
 146         err := c.conn.Invoke(ctx, in, out)
 147         if err != nil {
 148                 return nil, err
 149         }
 150         return out, nil
 151 }
 152
 153 func (c *serviceClient) SwInterfaceAddressReplaceBegin(ctx context.Context, in *SwInterfaceAddressReplaceBegin) (*SwInterfaceAddressReplaceBeginReply, error) {
 154         out := new(SwInterfaceAddressReplaceBeginReply)
 155         err := c.conn.Invoke(ctx, in, out)
 156         if err != nil {
 157                 return nil, err
 158         }
 159         return out, nil
 160 }
 161
 162 func (c *serviceClient) SwInterfaceAddressReplaceEnd(ctx context.Context, in *SwInterfaceAddressReplaceEnd) (*SwInterfaceAddressReplaceEndReply, error) {
 163         out := new(SwInterfaceAddressReplaceEndReply)
 164         err := c.conn.Invoke(ctx, in, out)
 165         if err != nil {
 166                 return nil, err
 167         }
 168         return out, nil
 169 }
 170
 171 func (c *serviceClient) SwInterfaceClearStats(ctx context.Context, in *SwInterfaceClearStats) (*SwInterfaceClearStatsReply, error) {
 172         out := new(SwInterfaceClearStatsReply)
 173         err := c.conn.Invoke(ctx, in, out)
 174         if err != nil {
 175                 return nil, err
 176         }
 177         return out, nil
 178 }
 179
 180 func (c *serviceClient) SwInterfaceDump(ctx context.Context, in *SwInterfaceDump) (RPCService_SwInterfaceDumpClient, error) {
 181         stream, err := c.conn.NewStream(ctx)
 182         if err != nil {
 183                 return nil, err
 184         }
 185         x := &serviceClient_SwInterfaceDumpClient{stream}
 186         if err := x.Stream.SendMsg(in); err != nil {
 187                 return nil, err
 188         }
 189         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 190                 return nil, err
 191         }
 192         return x, nil
 193 }
 194
 195 type RPCService_SwInterfaceDumpClient interface {
 196         Recv() (*SwInterfaceDetails, error)
 197         api.Stream
 198 }
 199
 200 type serviceClient_SwInterfaceDumpClient struct {
 201         api.Stream
 202 }
 203
 204 func (c *serviceClient_SwInterfaceDumpClient) Recv() (*SwInterfaceDetails, error) {
 205         msg, err := c.Stream.RecvMsg()
 206         if err != nil {
 207                 return nil, err
 208         }
 209         switch m := msg.(type) {
 210         case *SwInterfaceDetails:
 211                 return m, nil
 212         case *vpe.ControlPingReply:
 213                 return nil, io.EOF
 214         default:
 215                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 216         }
 217 }
 218
 219 func (c *serviceClient) SwInterfaceGetMacAddress(ctx context.Context, in *SwInterfaceGetMacAddress) (*SwInterfaceGetMacAddressReply, error) {
 220         out := new(SwInterfaceGetMacAddressReply)
 221         err := c.conn.Invoke(ctx, in, out)
 222         if err != nil {
 223                 return nil, err
 224         }
 225         return out, nil
 226 }
 227
 228 func (c *serviceClient) SwInterfaceGetTable(ctx context.Context, in *SwInterfaceGetTable) (*SwInterfaceGetTableReply, error) {
 229         out := new(SwInterfaceGetTableReply)
 230         err := c.conn.Invoke(ctx, in, out)
 231         if err != nil {
 232                 return nil, err
 233         }
 234         return out, nil
 235 }
 236
 237 func (c *serviceClient) SwInterfaceRxPlacementDump(ctx context.Context, in *SwInterfaceRxPlacementDump) (RPCService_SwInterfaceRxPlacementDumpClient, error) {
 238         stream, err := c.conn.NewStream(ctx)
 239         if err != nil {
 240                 return nil, err
 241         }
 242         x := &serviceClient_SwInterfaceRxPlacementDumpClient{stream}
 243         if err := x.Stream.SendMsg(in); err != nil {
 244                 return nil, err
 245         }
 246         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 247                 return nil, err
 248         }
 249         return x, nil
 250 }
 251
 252 type RPCService_SwInterfaceRxPlacementDumpClient interface {
 253         Recv() (*SwInterfaceRxPlacementDetails, error)
 254         api.Stream
 255 }
 256
 257 type serviceClient_SwInterfaceRxPlacementDumpClient struct {
 258         api.Stream
 259 }
 260
 261 func (c *serviceClient_SwInterfaceRxPlacementDumpClient) Recv() (*SwInterfaceRxPlacementDetails, error) {
 262         msg, err := c.Stream.RecvMsg()
 263         if err != nil {
 264                 return nil, err
 265         }
 266         switch m := msg.(type) {
 267         case *SwInterfaceRxPlacementDetails:
 268                 return m, nil
 269         case *vpe.ControlPingReply:
 270                 return nil, io.EOF
 271         default:
 272                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 273         }
 274 }
 275
 276 func (c *serviceClient) SwInterfaceSetFlags(ctx context.Context, in *SwInterfaceSetFlags) (*SwInterfaceSetFlagsReply, error) {
 277         out := new(SwInterfaceSetFlagsReply)
 278         err := c.conn.Invoke(ctx, in, out)
 279         if err != nil {
 280                 return nil, err
 281         }
 282         return out, nil
 283 }
 284
 285 func (c *serviceClient) SwInterfaceSetIPDirectedBroadcast(ctx context.Context, in *SwInterfaceSetIPDirectedBroadcast) (*SwInterfaceSetIPDirectedBroadcastReply, error) {
 286         out := new(SwInterfaceSetIPDirectedBroadcastReply)
 287         err := c.conn.Invoke(ctx, in, out)
 288         if err != nil {
 289                 return nil, err
 290         }
 291         return out, nil
 292 }
 293
 294 func (c *serviceClient) SwInterfaceSetMacAddress(ctx context.Context, in *SwInterfaceSetMacAddress) (*SwInterfaceSetMacAddressReply, error) {
 295         out := new(SwInterfaceSetMacAddressReply)
 296         err := c.conn.Invoke(ctx, in, out)
 297         if err != nil {
 298                 return nil, err
 299         }
 300         return out, nil
 301 }
 302
 303 func (c *serviceClient) SwInterfaceSetMtu(ctx context.Context, in *SwInterfaceSetMtu) (*SwInterfaceSetMtuReply, error) {
 304         out := new(SwInterfaceSetMtuReply)
 305         err := c.conn.Invoke(ctx, in, out)
 306         if err != nil {
 307                 return nil, err
 308         }
 309         return out, nil
 310 }
 311
 312 func (c *serviceClient) SwInterfaceSetRxMode(ctx context.Context, in *SwInterfaceSetRxMode) (*SwInterfaceSetRxModeReply, error) {
 313         out := new(SwInterfaceSetRxModeReply)
 314         err := c.conn.Invoke(ctx, in, out)
 315         if err != nil {
 316                 return nil, err
 317         }
 318         return out, nil
 319 }
 320
 321 func (c *serviceClient) SwInterfaceSetRxPlacement(ctx context.Context, in *SwInterfaceSetRxPlacement) (*SwInterfaceSetRxPlacementReply, error) {
 322         out := new(SwInterfaceSetRxPlacementReply)
 323         err := c.conn.Invoke(ctx, in, out)
 324         if err != nil {
 325                 return nil, err
 326         }
 327         return out, nil
 328 }
 329
 330 func (c *serviceClient) SwInterfaceSetTable(ctx context.Context, in *SwInterfaceSetTable) (*SwInterfaceSetTableReply, error) {
 331         out := new(SwInterfaceSetTableReply)
 332         err := c.conn.Invoke(ctx, in, out)
 333         if err != nil {
 334                 return nil, err
 335         }
 336         return out, nil
 337 }
 338
 339 func (c *serviceClient) SwInterfaceSetUnnumbered(ctx context.Context, in *SwInterfaceSetUnnumbered) (*SwInterfaceSetUnnumberedReply, error) {
 340         out := new(SwInterfaceSetUnnumberedReply)
 341         err := c.conn.Invoke(ctx, in, out)
 342         if err != nil {
 343                 return nil, err
 344         }
 345         return out, nil
 346 }
 347
 348 func (c *serviceClient) SwInterfaceTagAddDel(ctx context.Context, in *SwInterfaceTagAddDel) (*SwInterfaceTagAddDelReply, error) {
 349         out := new(SwInterfaceTagAddDelReply)
 350         err := c.conn.Invoke(ctx, in, out)
 351         if err != nil {
 352                 return nil, err
 353         }
 354         return out, nil
 355 }
 356
 357 func (c *serviceClient) WantInterfaceEvents(ctx context.Context, in *WantInterfaceEvents) (*WantInterfaceEventsReply, error) {
 358         out := new(WantInterfaceEventsReply)
 359         err := c.conn.Invoke(ctx, in, out)
 360         if err != nil {
 361                 return nil, err
 362         }
 363         return out, nil
 364 }