binapi/l2/l2_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package l2
   4
   5 import (
   6         "context"
   7         "fmt"
   8         api "git.fd.io/govpp.git/api"
   9         vpe "git.fd.io/govpp.git/binapi/vpe"
  10         "io"
  11 )
  12
  13 // RPCService defines RPC service  l2.
  14 type RPCService interface {
  15         BdIPMacAddDel(ctx context.Context, in *BdIPMacAddDel) (*BdIPMacAddDelReply, error)
  16         BdIPMacDump(ctx context.Context, in *BdIPMacDump) (RPCService_BdIPMacDumpClient, error)
  17         BdIPMacFlush(ctx context.Context, in *BdIPMacFlush) (*BdIPMacFlushReply, error)
  18         BridgeDomainAddDel(ctx context.Context, in *BridgeDomainAddDel) (*BridgeDomainAddDelReply, error)
  19         BridgeDomainDump(ctx context.Context, in *BridgeDomainDump) (RPCService_BridgeDomainDumpClient, error)
  20         BridgeDomainSetMacAge(ctx context.Context, in *BridgeDomainSetMacAge) (*BridgeDomainSetMacAgeReply, error)
  21         BridgeFlags(ctx context.Context, in *BridgeFlags) (*BridgeFlagsReply, error)
  22         BviCreate(ctx context.Context, in *BviCreate) (*BviCreateReply, error)
  23         BviDelete(ctx context.Context, in *BviDelete) (*BviDeleteReply, error)
  24         L2FibClearTable(ctx context.Context, in *L2FibClearTable) (*L2FibClearTableReply, error)
  25         L2FibTableDump(ctx context.Context, in *L2FibTableDump) (RPCService_L2FibTableDumpClient, error)
  26         L2Flags(ctx context.Context, in *L2Flags) (*L2FlagsReply, error)
  27         L2InterfaceEfpFilter(ctx context.Context, in *L2InterfaceEfpFilter) (*L2InterfaceEfpFilterReply, error)
  28         L2InterfacePbbTagRewrite(ctx context.Context, in *L2InterfacePbbTagRewrite) (*L2InterfacePbbTagRewriteReply, error)
  29         L2InterfaceVlanTagRewrite(ctx context.Context, in *L2InterfaceVlanTagRewrite) (*L2InterfaceVlanTagRewriteReply, error)
  30         L2PatchAddDel(ctx context.Context, in *L2PatchAddDel) (*L2PatchAddDelReply, error)
  31         L2XconnectDump(ctx context.Context, in *L2XconnectDump) (RPCService_L2XconnectDumpClient, error)
  32         L2fibAddDel(ctx context.Context, in *L2fibAddDel) (*L2fibAddDelReply, error)
  33         L2fibFlushAll(ctx context.Context, in *L2fibFlushAll) (*L2fibFlushAllReply, error)
  34         L2fibFlushBd(ctx context.Context, in *L2fibFlushBd) (*L2fibFlushBdReply, error)
  35         L2fibFlushInt(ctx context.Context, in *L2fibFlushInt) (*L2fibFlushIntReply, error)
  36         SwInterfaceSetL2Bridge(ctx context.Context, in *SwInterfaceSetL2Bridge) (*SwInterfaceSetL2BridgeReply, error)
  37         SwInterfaceSetL2Xconnect(ctx context.Context, in *SwInterfaceSetL2Xconnect) (*SwInterfaceSetL2XconnectReply, error)
  38         SwInterfaceSetVpath(ctx context.Context, in *SwInterfaceSetVpath) (*SwInterfaceSetVpathReply, error)
  39         WantL2ArpTermEvents(ctx context.Context, in *WantL2ArpTermEvents) (*WantL2ArpTermEventsReply, error)
  40         WantL2MacsEvents(ctx context.Context, in *WantL2MacsEvents) (*WantL2MacsEventsReply, 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) BdIPMacAddDel(ctx context.Context, in *BdIPMacAddDel) (*BdIPMacAddDelReply, error) {
  52         out := new(BdIPMacAddDelReply)
  53         err := c.conn.Invoke(ctx, in, out)
  54         if err != nil {
  55                 return nil, err
  56         }
  57         return out, nil
  58 }
  59
  60 func (c *serviceClient) BdIPMacDump(ctx context.Context, in *BdIPMacDump) (RPCService_BdIPMacDumpClient, error) {
  61         stream, err := c.conn.NewStream(ctx)
  62         if err != nil {
  63                 return nil, err
  64         }
  65         x := &serviceClient_BdIPMacDumpClient{stream}
  66         if err := x.Stream.SendMsg(in); err != nil {
  67                 return nil, err
  68         }
  69         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  70                 return nil, err
  71         }
  72         return x, nil
  73 }
  74
  75 type RPCService_BdIPMacDumpClient interface {
  76         Recv() (*BdIPMacDetails, error)
  77         api.Stream
  78 }
  79
  80 type serviceClient_BdIPMacDumpClient struct {
  81         api.Stream
  82 }
  83
  84 func (c *serviceClient_BdIPMacDumpClient) Recv() (*BdIPMacDetails, error) {
  85         msg, err := c.Stream.RecvMsg()
  86         if err != nil {
  87                 return nil, err
  88         }
  89         switch m := msg.(type) {
  90         case *BdIPMacDetails:
  91                 return m, nil
  92         case *vpe.ControlPingReply:
  93                 return nil, io.EOF
  94         default:
  95                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  96         }
  97 }
  98
  99 func (c *serviceClient) BdIPMacFlush(ctx context.Context, in *BdIPMacFlush) (*BdIPMacFlushReply, error) {
 100         out := new(BdIPMacFlushReply)
 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) BridgeDomainAddDel(ctx context.Context, in *BridgeDomainAddDel) (*BridgeDomainAddDelReply, error) {
 109         out := new(BridgeDomainAddDelReply)
 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) BridgeDomainDump(ctx context.Context, in *BridgeDomainDump) (RPCService_BridgeDomainDumpClient, error) {
 118         stream, err := c.conn.NewStream(ctx)
 119         if err != nil {
 120                 return nil, err
 121         }
 122         x := &serviceClient_BridgeDomainDumpClient{stream}
 123         if err := x.Stream.SendMsg(in); err != nil {
 124                 return nil, err
 125         }
 126         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 127                 return nil, err
 128         }
 129         return x, nil
 130 }
 131
 132 type RPCService_BridgeDomainDumpClient interface {
 133         Recv() (*BridgeDomainDetails, error)
 134         api.Stream
 135 }
 136
 137 type serviceClient_BridgeDomainDumpClient struct {
 138         api.Stream
 139 }
 140
 141 func (c *serviceClient_BridgeDomainDumpClient) Recv() (*BridgeDomainDetails, error) {
 142         msg, err := c.Stream.RecvMsg()
 143         if err != nil {
 144                 return nil, err
 145         }
 146         switch m := msg.(type) {
 147         case *BridgeDomainDetails:
 148                 return m, nil
 149         case *vpe.ControlPingReply:
 150                 return nil, io.EOF
 151         default:
 152                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 153         }
 154 }
 155
 156 func (c *serviceClient) BridgeDomainSetMacAge(ctx context.Context, in *BridgeDomainSetMacAge) (*BridgeDomainSetMacAgeReply, error) {
 157         out := new(BridgeDomainSetMacAgeReply)
 158         err := c.conn.Invoke(ctx, in, out)
 159         if err != nil {
 160                 return nil, err
 161         }
 162         return out, nil
 163 }
 164
 165 func (c *serviceClient) BridgeFlags(ctx context.Context, in *BridgeFlags) (*BridgeFlagsReply, error) {
 166         out := new(BridgeFlagsReply)
 167         err := c.conn.Invoke(ctx, in, out)
 168         if err != nil {
 169                 return nil, err
 170         }
 171         return out, nil
 172 }
 173
 174 func (c *serviceClient) BviCreate(ctx context.Context, in *BviCreate) (*BviCreateReply, error) {
 175         out := new(BviCreateReply)
 176         err := c.conn.Invoke(ctx, in, out)
 177         if err != nil {
 178                 return nil, err
 179         }
 180         return out, nil
 181 }
 182
 183 func (c *serviceClient) BviDelete(ctx context.Context, in *BviDelete) (*BviDeleteReply, error) {
 184         out := new(BviDeleteReply)
 185         err := c.conn.Invoke(ctx, in, out)
 186         if err != nil {
 187                 return nil, err
 188         }
 189         return out, nil
 190 }
 191
 192 func (c *serviceClient) L2FibClearTable(ctx context.Context, in *L2FibClearTable) (*L2FibClearTableReply, error) {
 193         out := new(L2FibClearTableReply)
 194         err := c.conn.Invoke(ctx, in, out)
 195         if err != nil {
 196                 return nil, err
 197         }
 198         return out, nil
 199 }
 200
 201 func (c *serviceClient) L2FibTableDump(ctx context.Context, in *L2FibTableDump) (RPCService_L2FibTableDumpClient, error) {
 202         stream, err := c.conn.NewStream(ctx)
 203         if err != nil {
 204                 return nil, err
 205         }
 206         x := &serviceClient_L2FibTableDumpClient{stream}
 207         if err := x.Stream.SendMsg(in); err != nil {
 208                 return nil, err
 209         }
 210         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 211                 return nil, err
 212         }
 213         return x, nil
 214 }
 215
 216 type RPCService_L2FibTableDumpClient interface {
 217         Recv() (*L2FibTableDetails, error)
 218         api.Stream
 219 }
 220
 221 type serviceClient_L2FibTableDumpClient struct {
 222         api.Stream
 223 }
 224
 225 func (c *serviceClient_L2FibTableDumpClient) Recv() (*L2FibTableDetails, error) {
 226         msg, err := c.Stream.RecvMsg()
 227         if err != nil {
 228                 return nil, err
 229         }
 230         switch m := msg.(type) {
 231         case *L2FibTableDetails:
 232                 return m, nil
 233         case *vpe.ControlPingReply:
 234                 return nil, io.EOF
 235         default:
 236                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 237         }
 238 }
 239
 240 func (c *serviceClient) L2Flags(ctx context.Context, in *L2Flags) (*L2FlagsReply, error) {
 241         out := new(L2FlagsReply)
 242         err := c.conn.Invoke(ctx, in, out)
 243         if err != nil {
 244                 return nil, err
 245         }
 246         return out, nil
 247 }
 248
 249 func (c *serviceClient) L2InterfaceEfpFilter(ctx context.Context, in *L2InterfaceEfpFilter) (*L2InterfaceEfpFilterReply, error) {
 250         out := new(L2InterfaceEfpFilterReply)
 251         err := c.conn.Invoke(ctx, in, out)
 252         if err != nil {
 253                 return nil, err
 254         }
 255         return out, nil
 256 }
 257
 258 func (c *serviceClient) L2InterfacePbbTagRewrite(ctx context.Context, in *L2InterfacePbbTagRewrite) (*L2InterfacePbbTagRewriteReply, error) {
 259         out := new(L2InterfacePbbTagRewriteReply)
 260         err := c.conn.Invoke(ctx, in, out)
 261         if err != nil {
 262                 return nil, err
 263         }
 264         return out, nil
 265 }
 266
 267 func (c *serviceClient) L2InterfaceVlanTagRewrite(ctx context.Context, in *L2InterfaceVlanTagRewrite) (*L2InterfaceVlanTagRewriteReply, error) {
 268         out := new(L2InterfaceVlanTagRewriteReply)
 269         err := c.conn.Invoke(ctx, in, out)
 270         if err != nil {
 271                 return nil, err
 272         }
 273         return out, nil
 274 }
 275
 276 func (c *serviceClient) L2PatchAddDel(ctx context.Context, in *L2PatchAddDel) (*L2PatchAddDelReply, error) {
 277         out := new(L2PatchAddDelReply)
 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) L2XconnectDump(ctx context.Context, in *L2XconnectDump) (RPCService_L2XconnectDumpClient, error) {
 286         stream, err := c.conn.NewStream(ctx)
 287         if err != nil {
 288                 return nil, err
 289         }
 290         x := &serviceClient_L2XconnectDumpClient{stream}
 291         if err := x.Stream.SendMsg(in); err != nil {
 292                 return nil, err
 293         }
 294         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 295                 return nil, err
 296         }
 297         return x, nil
 298 }
 299
 300 type RPCService_L2XconnectDumpClient interface {
 301         Recv() (*L2XconnectDetails, error)
 302         api.Stream
 303 }
 304
 305 type serviceClient_L2XconnectDumpClient struct {
 306         api.Stream
 307 }
 308
 309 func (c *serviceClient_L2XconnectDumpClient) Recv() (*L2XconnectDetails, error) {
 310         msg, err := c.Stream.RecvMsg()
 311         if err != nil {
 312                 return nil, err
 313         }
 314         switch m := msg.(type) {
 315         case *L2XconnectDetails:
 316                 return m, nil
 317         case *vpe.ControlPingReply:
 318                 return nil, io.EOF
 319         default:
 320                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 321         }
 322 }
 323
 324 func (c *serviceClient) L2fibAddDel(ctx context.Context, in *L2fibAddDel) (*L2fibAddDelReply, error) {
 325         out := new(L2fibAddDelReply)
 326         err := c.conn.Invoke(ctx, in, out)
 327         if err != nil {
 328                 return nil, err
 329         }
 330         return out, nil
 331 }
 332
 333 func (c *serviceClient) L2fibFlushAll(ctx context.Context, in *L2fibFlushAll) (*L2fibFlushAllReply, error) {
 334         out := new(L2fibFlushAllReply)
 335         err := c.conn.Invoke(ctx, in, out)
 336         if err != nil {
 337                 return nil, err
 338         }
 339         return out, nil
 340 }
 341
 342 func (c *serviceClient) L2fibFlushBd(ctx context.Context, in *L2fibFlushBd) (*L2fibFlushBdReply, error) {
 343         out := new(L2fibFlushBdReply)
 344         err := c.conn.Invoke(ctx, in, out)
 345         if err != nil {
 346                 return nil, err
 347         }
 348         return out, nil
 349 }
 350
 351 func (c *serviceClient) L2fibFlushInt(ctx context.Context, in *L2fibFlushInt) (*L2fibFlushIntReply, error) {
 352         out := new(L2fibFlushIntReply)
 353         err := c.conn.Invoke(ctx, in, out)
 354         if err != nil {
 355                 return nil, err
 356         }
 357         return out, nil
 358 }
 359
 360 func (c *serviceClient) SwInterfaceSetL2Bridge(ctx context.Context, in *SwInterfaceSetL2Bridge) (*SwInterfaceSetL2BridgeReply, error) {
 361         out := new(SwInterfaceSetL2BridgeReply)
 362         err := c.conn.Invoke(ctx, in, out)
 363         if err != nil {
 364                 return nil, err
 365         }
 366         return out, nil
 367 }
 368
 369 func (c *serviceClient) SwInterfaceSetL2Xconnect(ctx context.Context, in *SwInterfaceSetL2Xconnect) (*SwInterfaceSetL2XconnectReply, error) {
 370         out := new(SwInterfaceSetL2XconnectReply)
 371         err := c.conn.Invoke(ctx, in, out)
 372         if err != nil {
 373                 return nil, err
 374         }
 375         return out, nil
 376 }
 377
 378 func (c *serviceClient) SwInterfaceSetVpath(ctx context.Context, in *SwInterfaceSetVpath) (*SwInterfaceSetVpathReply, error) {
 379         out := new(SwInterfaceSetVpathReply)
 380         err := c.conn.Invoke(ctx, in, out)
 381         if err != nil {
 382                 return nil, err
 383         }
 384         return out, nil
 385 }
 386
 387 func (c *serviceClient) WantL2ArpTermEvents(ctx context.Context, in *WantL2ArpTermEvents) (*WantL2ArpTermEventsReply, error) {
 388         out := new(WantL2ArpTermEventsReply)
 389         err := c.conn.Invoke(ctx, in, out)
 390         if err != nil {
 391                 return nil, err
 392         }
 393         return out, nil
 394 }
 395
 396 func (c *serviceClient) WantL2MacsEvents(ctx context.Context, in *WantL2MacsEvents) (*WantL2MacsEventsReply, error) {
 397         out := new(WantL2MacsEventsReply)
 398         err := c.conn.Invoke(ctx, in, out)
 399         if err != nil {
 400                 return nil, err
 401         }
 402         return out, nil
 403 }