binapi/mpls/mpls_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package mpls
   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  mpls.
  14 type RPCService interface {
  15         MplsIPBindUnbind(ctx context.Context, in *MplsIPBindUnbind) (*MplsIPBindUnbindReply, error)
  16         MplsRouteAddDel(ctx context.Context, in *MplsRouteAddDel) (*MplsRouteAddDelReply, error)
  17         MplsRouteDump(ctx context.Context, in *MplsRouteDump) (RPCService_MplsRouteDumpClient, error)
  18         MplsTableAddDel(ctx context.Context, in *MplsTableAddDel) (*MplsTableAddDelReply, error)
  19         MplsTableDump(ctx context.Context, in *MplsTableDump) (RPCService_MplsTableDumpClient, error)
  20         MplsTunnelAddDel(ctx context.Context, in *MplsTunnelAddDel) (*MplsTunnelAddDelReply, error)
  21         MplsTunnelDump(ctx context.Context, in *MplsTunnelDump) (RPCService_MplsTunnelDumpClient, error)
  22         SwInterfaceSetMplsEnable(ctx context.Context, in *SwInterfaceSetMplsEnable) (*SwInterfaceSetMplsEnableReply, error)
  23 }
  24
  25 type serviceClient struct {
  26         conn api.Connection
  27 }
  28
  29 func NewServiceClient(conn api.Connection) RPCService {
  30         return &serviceClient{conn}
  31 }
  32
  33 func (c *serviceClient) MplsIPBindUnbind(ctx context.Context, in *MplsIPBindUnbind) (*MplsIPBindUnbindReply, error) {
  34         out := new(MplsIPBindUnbindReply)
  35         err := c.conn.Invoke(ctx, in, out)
  36         if err != nil {
  37                 return nil, err
  38         }
  39         return out, nil
  40 }
  41
  42 func (c *serviceClient) MplsRouteAddDel(ctx context.Context, in *MplsRouteAddDel) (*MplsRouteAddDelReply, error) {
  43         out := new(MplsRouteAddDelReply)
  44         err := c.conn.Invoke(ctx, in, out)
  45         if err != nil {
  46                 return nil, err
  47         }
  48         return out, nil
  49 }
  50
  51 func (c *serviceClient) MplsRouteDump(ctx context.Context, in *MplsRouteDump) (RPCService_MplsRouteDumpClient, error) {
  52         stream, err := c.conn.NewStream(ctx)
  53         if err != nil {
  54                 return nil, err
  55         }
  56         x := &serviceClient_MplsRouteDumpClient{stream}
  57         if err := x.Stream.SendMsg(in); err != nil {
  58                 return nil, err
  59         }
  60         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  61                 return nil, err
  62         }
  63         return x, nil
  64 }
  65
  66 type RPCService_MplsRouteDumpClient interface {
  67         Recv() (*MplsRouteDetails, error)
  68         api.Stream
  69 }
  70
  71 type serviceClient_MplsRouteDumpClient struct {
  72         api.Stream
  73 }
  74
  75 func (c *serviceClient_MplsRouteDumpClient) Recv() (*MplsRouteDetails, error) {
  76         msg, err := c.Stream.RecvMsg()
  77         if err != nil {
  78                 return nil, err
  79         }
  80         switch m := msg.(type) {
  81         case *MplsRouteDetails:
  82                 return m, nil
  83         case *vpe.ControlPingReply:
  84                 return nil, io.EOF
  85         default:
  86                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  87         }
  88 }
  89
  90 func (c *serviceClient) MplsTableAddDel(ctx context.Context, in *MplsTableAddDel) (*MplsTableAddDelReply, error) {
  91         out := new(MplsTableAddDelReply)
  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) MplsTableDump(ctx context.Context, in *MplsTableDump) (RPCService_MplsTableDumpClient, error) {
 100         stream, err := c.conn.NewStream(ctx)
 101         if err != nil {
 102                 return nil, err
 103         }
 104         x := &serviceClient_MplsTableDumpClient{stream}
 105         if err := x.Stream.SendMsg(in); err != nil {
 106                 return nil, err
 107         }
 108         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 109                 return nil, err
 110         }
 111         return x, nil
 112 }
 113
 114 type RPCService_MplsTableDumpClient interface {
 115         Recv() (*MplsTableDetails, error)
 116         api.Stream
 117 }
 118
 119 type serviceClient_MplsTableDumpClient struct {
 120         api.Stream
 121 }
 122
 123 func (c *serviceClient_MplsTableDumpClient) Recv() (*MplsTableDetails, error) {
 124         msg, err := c.Stream.RecvMsg()
 125         if err != nil {
 126                 return nil, err
 127         }
 128         switch m := msg.(type) {
 129         case *MplsTableDetails:
 130                 return m, nil
 131         case *vpe.ControlPingReply:
 132                 return nil, io.EOF
 133         default:
 134                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 135         }
 136 }
 137
 138 func (c *serviceClient) MplsTunnelAddDel(ctx context.Context, in *MplsTunnelAddDel) (*MplsTunnelAddDelReply, error) {
 139         out := new(MplsTunnelAddDelReply)
 140         err := c.conn.Invoke(ctx, in, out)
 141         if err != nil {
 142                 return nil, err
 143         }
 144         return out, nil
 145 }
 146
 147 func (c *serviceClient) MplsTunnelDump(ctx context.Context, in *MplsTunnelDump) (RPCService_MplsTunnelDumpClient, error) {
 148         stream, err := c.conn.NewStream(ctx)
 149         if err != nil {
 150                 return nil, err
 151         }
 152         x := &serviceClient_MplsTunnelDumpClient{stream}
 153         if err := x.Stream.SendMsg(in); err != nil {
 154                 return nil, err
 155         }
 156         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 157                 return nil, err
 158         }
 159         return x, nil
 160 }
 161
 162 type RPCService_MplsTunnelDumpClient interface {
 163         Recv() (*MplsTunnelDetails, error)
 164         api.Stream
 165 }
 166
 167 type serviceClient_MplsTunnelDumpClient struct {
 168         api.Stream
 169 }
 170
 171 func (c *serviceClient_MplsTunnelDumpClient) Recv() (*MplsTunnelDetails, error) {
 172         msg, err := c.Stream.RecvMsg()
 173         if err != nil {
 174                 return nil, err
 175         }
 176         switch m := msg.(type) {
 177         case *MplsTunnelDetails:
 178                 return m, nil
 179         case *vpe.ControlPingReply:
 180                 return nil, io.EOF
 181         default:
 182                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 183         }
 184 }
 185
 186 func (c *serviceClient) SwInterfaceSetMplsEnable(ctx context.Context, in *SwInterfaceSetMplsEnable) (*SwInterfaceSetMplsEnableReply, error) {
 187         out := new(SwInterfaceSetMplsEnableReply)
 188         err := c.conn.Invoke(ctx, in, out)
 189         if err != nil {
 190                 return nil, err
 191         }
 192         return out, nil
 193 }