1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 memclnt "git.fd.io/govpp.git/binapi/memclnt"
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)
26 type serviceClient struct {
30 func NewServiceClient(conn api.Connection) RPCService {
31 return &serviceClient{conn}
34 func (c *serviceClient) MplsIPBindUnbind(ctx context.Context, in *MplsIPBindUnbind) (*MplsIPBindUnbindReply, error) {
35 out := new(MplsIPBindUnbindReply)
36 err := c.conn.Invoke(ctx, in, out)
40 return out, api.RetvalToVPPApiError(out.Retval)
43 func (c *serviceClient) MplsRouteAddDel(ctx context.Context, in *MplsRouteAddDel) (*MplsRouteAddDelReply, error) {
44 out := new(MplsRouteAddDelReply)
45 err := c.conn.Invoke(ctx, in, out)
49 return out, api.RetvalToVPPApiError(out.Retval)
52 func (c *serviceClient) MplsRouteDump(ctx context.Context, in *MplsRouteDump) (RPCService_MplsRouteDumpClient, error) {
53 stream, err := c.conn.NewStream(ctx)
57 x := &serviceClient_MplsRouteDumpClient{stream}
58 if err := x.Stream.SendMsg(in); err != nil {
61 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
67 type RPCService_MplsRouteDumpClient interface {
68 Recv() (*MplsRouteDetails, error)
72 type serviceClient_MplsRouteDumpClient struct {
76 func (c *serviceClient_MplsRouteDumpClient) Recv() (*MplsRouteDetails, error) {
77 msg, err := c.Stream.RecvMsg()
81 switch m := msg.(type) {
82 case *MplsRouteDetails:
84 case *memclnt.ControlPingReply:
85 err = c.Stream.Close()
91 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
95 func (c *serviceClient) MplsTableAddDel(ctx context.Context, in *MplsTableAddDel) (*MplsTableAddDelReply, error) {
96 out := new(MplsTableAddDelReply)
97 err := c.conn.Invoke(ctx, in, out)
101 return out, api.RetvalToVPPApiError(out.Retval)
104 func (c *serviceClient) MplsTableDump(ctx context.Context, in *MplsTableDump) (RPCService_MplsTableDumpClient, error) {
105 stream, err := c.conn.NewStream(ctx)
109 x := &serviceClient_MplsTableDumpClient{stream}
110 if err := x.Stream.SendMsg(in); err != nil {
113 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
119 type RPCService_MplsTableDumpClient interface {
120 Recv() (*MplsTableDetails, error)
124 type serviceClient_MplsTableDumpClient struct {
128 func (c *serviceClient_MplsTableDumpClient) Recv() (*MplsTableDetails, error) {
129 msg, err := c.Stream.RecvMsg()
133 switch m := msg.(type) {
134 case *MplsTableDetails:
136 case *memclnt.ControlPingReply:
137 err = c.Stream.Close()
143 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
147 func (c *serviceClient) MplsTunnelAddDel(ctx context.Context, in *MplsTunnelAddDel) (*MplsTunnelAddDelReply, error) {
148 out := new(MplsTunnelAddDelReply)
149 err := c.conn.Invoke(ctx, in, out)
153 return out, api.RetvalToVPPApiError(out.Retval)
156 func (c *serviceClient) MplsTunnelDump(ctx context.Context, in *MplsTunnelDump) (RPCService_MplsTunnelDumpClient, error) {
157 stream, err := c.conn.NewStream(ctx)
161 x := &serviceClient_MplsTunnelDumpClient{stream}
162 if err := x.Stream.SendMsg(in); err != nil {
165 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
171 type RPCService_MplsTunnelDumpClient interface {
172 Recv() (*MplsTunnelDetails, error)
176 type serviceClient_MplsTunnelDumpClient struct {
180 func (c *serviceClient_MplsTunnelDumpClient) Recv() (*MplsTunnelDetails, error) {
181 msg, err := c.Stream.RecvMsg()
185 switch m := msg.(type) {
186 case *MplsTunnelDetails:
188 case *memclnt.ControlPingReply:
189 err = c.Stream.Close()
195 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
199 func (c *serviceClient) SwInterfaceSetMplsEnable(ctx context.Context, in *SwInterfaceSetMplsEnable) (*SwInterfaceSetMplsEnableReply, error) {
200 out := new(SwInterfaceSetMplsEnableReply)
201 err := c.conn.Invoke(ctx, in, out)
205 return out, api.RetvalToVPPApiError(out.Retval)