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