1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
8 api "git.fd.io/govpp.git/api"
9 vpe "git.fd.io/govpp.git/binapi/vpe"
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)
25 type serviceClient struct {
29 func NewServiceClient(conn api.Connection) RPCService {
30 return &serviceClient{conn}
33 func (c *serviceClient) MplsIPBindUnbind(ctx context.Context, in *MplsIPBindUnbind) (*MplsIPBindUnbindReply, error) {
34 out := new(MplsIPBindUnbindReply)
35 err := c.conn.Invoke(ctx, in, out)
42 func (c *serviceClient) MplsRouteAddDel(ctx context.Context, in *MplsRouteAddDel) (*MplsRouteAddDelReply, error) {
43 out := new(MplsRouteAddDelReply)
44 err := c.conn.Invoke(ctx, in, out)
51 func (c *serviceClient) MplsRouteDump(ctx context.Context, in *MplsRouteDump) (RPCService_MplsRouteDumpClient, error) {
52 stream, err := c.conn.NewStream(ctx)
56 x := &serviceClient_MplsRouteDumpClient{stream}
57 if err := x.Stream.SendMsg(in); err != nil {
60 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
66 type RPCService_MplsRouteDumpClient interface {
67 Recv() (*MplsRouteDetails, error)
71 type serviceClient_MplsRouteDumpClient struct {
75 func (c *serviceClient_MplsRouteDumpClient) Recv() (*MplsRouteDetails, error) {
76 msg, err := c.Stream.RecvMsg()
80 switch m := msg.(type) {
81 case *MplsRouteDetails:
83 case *vpe.ControlPingReply:
86 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
90 func (c *serviceClient) MplsTableAddDel(ctx context.Context, in *MplsTableAddDel) (*MplsTableAddDelReply, error) {
91 out := new(MplsTableAddDelReply)
92 err := c.conn.Invoke(ctx, in, out)
99 func (c *serviceClient) MplsTableDump(ctx context.Context, in *MplsTableDump) (RPCService_MplsTableDumpClient, error) {
100 stream, err := c.conn.NewStream(ctx)
104 x := &serviceClient_MplsTableDumpClient{stream}
105 if err := x.Stream.SendMsg(in); err != nil {
108 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
114 type RPCService_MplsTableDumpClient interface {
115 Recv() (*MplsTableDetails, error)
119 type serviceClient_MplsTableDumpClient struct {
123 func (c *serviceClient_MplsTableDumpClient) Recv() (*MplsTableDetails, error) {
124 msg, err := c.Stream.RecvMsg()
128 switch m := msg.(type) {
129 case *MplsTableDetails:
131 case *vpe.ControlPingReply:
134 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
138 func (c *serviceClient) MplsTunnelAddDel(ctx context.Context, in *MplsTunnelAddDel) (*MplsTunnelAddDelReply, error) {
139 out := new(MplsTunnelAddDelReply)
140 err := c.conn.Invoke(ctx, in, out)
147 func (c *serviceClient) MplsTunnelDump(ctx context.Context, in *MplsTunnelDump) (RPCService_MplsTunnelDumpClient, error) {
148 stream, err := c.conn.NewStream(ctx)
152 x := &serviceClient_MplsTunnelDumpClient{stream}
153 if err := x.Stream.SendMsg(in); err != nil {
156 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
162 type RPCService_MplsTunnelDumpClient interface {
163 Recv() (*MplsTunnelDetails, error)
167 type serviceClient_MplsTunnelDumpClient struct {
171 func (c *serviceClient_MplsTunnelDumpClient) Recv() (*MplsTunnelDetails, error) {
172 msg, err := c.Stream.RecvMsg()
176 switch m := msg.(type) {
177 case *MplsTunnelDetails:
179 case *vpe.ControlPingReply:
182 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
186 func (c *serviceClient) SwInterfaceSetMplsEnable(ctx context.Context, in *SwInterfaceSetMplsEnable) (*SwInterfaceSetMplsEnableReply, error) {
187 out := new(SwInterfaceSetMplsEnableReply)
188 err := c.conn.Invoke(ctx, in, out)