binapi/dslite/dslite_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package dslite
   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  dslite.
  14 type RPCService interface {
  15         DsliteAddDelPoolAddrRange(ctx context.Context, in *DsliteAddDelPoolAddrRange) (*DsliteAddDelPoolAddrRangeReply, error)
  16         DsliteAddressDump(ctx context.Context, in *DsliteAddressDump) (RPCService_DsliteAddressDumpClient, error)
  17         DsliteGetAftrAddr(ctx context.Context, in *DsliteGetAftrAddr) (*DsliteGetAftrAddrReply, error)
  18         DsliteGetB4Addr(ctx context.Context, in *DsliteGetB4Addr) (*DsliteGetB4AddrReply, error)
  19         DsliteSetAftrAddr(ctx context.Context, in *DsliteSetAftrAddr) (*DsliteSetAftrAddrReply, error)
  20         DsliteSetB4Addr(ctx context.Context, in *DsliteSetB4Addr) (*DsliteSetB4AddrReply, error)
  21 }
  22
  23 type serviceClient struct {
  24         conn api.Connection
  25 }
  26
  27 func NewServiceClient(conn api.Connection) RPCService {
  28         return &serviceClient{conn}
  29 }
  30
  31 func (c *serviceClient) DsliteAddDelPoolAddrRange(ctx context.Context, in *DsliteAddDelPoolAddrRange) (*DsliteAddDelPoolAddrRangeReply, error) {
  32         out := new(DsliteAddDelPoolAddrRangeReply)
  33         err := c.conn.Invoke(ctx, in, out)
  34         if err != nil {
  35                 return nil, err
  36         }
  37         return out, nil
  38 }
  39
  40 func (c *serviceClient) DsliteAddressDump(ctx context.Context, in *DsliteAddressDump) (RPCService_DsliteAddressDumpClient, error) {
  41         stream, err := c.conn.NewStream(ctx)
  42         if err != nil {
  43                 return nil, err
  44         }
  45         x := &serviceClient_DsliteAddressDumpClient{stream}
  46         if err := x.Stream.SendMsg(in); err != nil {
  47                 return nil, err
  48         }
  49         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  50                 return nil, err
  51         }
  52         return x, nil
  53 }
  54
  55 type RPCService_DsliteAddressDumpClient interface {
  56         Recv() (*DsliteAddressDetails, error)
  57         api.Stream
  58 }
  59
  60 type serviceClient_DsliteAddressDumpClient struct {
  61         api.Stream
  62 }
  63
  64 func (c *serviceClient_DsliteAddressDumpClient) Recv() (*DsliteAddressDetails, error) {
  65         msg, err := c.Stream.RecvMsg()
  66         if err != nil {
  67                 return nil, err
  68         }
  69         switch m := msg.(type) {
  70         case *DsliteAddressDetails:
  71                 return m, nil
  72         case *vpe.ControlPingReply:
  73                 return nil, io.EOF
  74         default:
  75                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  76         }
  77 }
  78
  79 func (c *serviceClient) DsliteGetAftrAddr(ctx context.Context, in *DsliteGetAftrAddr) (*DsliteGetAftrAddrReply, error) {
  80         out := new(DsliteGetAftrAddrReply)
  81         err := c.conn.Invoke(ctx, in, out)
  82         if err != nil {
  83                 return nil, err
  84         }
  85         return out, nil
  86 }
  87
  88 func (c *serviceClient) DsliteGetB4Addr(ctx context.Context, in *DsliteGetB4Addr) (*DsliteGetB4AddrReply, error) {
  89         out := new(DsliteGetB4AddrReply)
  90         err := c.conn.Invoke(ctx, in, out)
  91         if err != nil {
  92                 return nil, err
  93         }
  94         return out, nil
  95 }
  96
  97 func (c *serviceClient) DsliteSetAftrAddr(ctx context.Context, in *DsliteSetAftrAddr) (*DsliteSetAftrAddrReply, error) {
  98         out := new(DsliteSetAftrAddrReply)
  99         err := c.conn.Invoke(ctx, in, out)
 100         if err != nil {
 101                 return nil, err
 102         }
 103         return out, nil
 104 }
 105
 106 func (c *serviceClient) DsliteSetB4Addr(ctx context.Context, in *DsliteSetB4Addr) (*DsliteSetB4AddrReply, error) {
 107         out := new(DsliteSetB4AddrReply)
 108         err := c.conn.Invoke(ctx, in, out)
 109         if err != nil {
 110                 return nil, err
 111         }
 112         return out, nil
 113 }