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