1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 vpe "git.fd.io/govpp.git/binapi/vpe"
14 // RPCService defines RPC service qos.
15 type RPCService interface {
16 QosEgressMapDelete(ctx context.Context, in *QosEgressMapDelete) (*QosEgressMapDeleteReply, error)
17 QosEgressMapDump(ctx context.Context, in *QosEgressMapDump) (RPCService_QosEgressMapDumpClient, error)
18 QosEgressMapUpdate(ctx context.Context, in *QosEgressMapUpdate) (*QosEgressMapUpdateReply, error)
19 QosMarkDump(ctx context.Context, in *QosMarkDump) (RPCService_QosMarkDumpClient, error)
20 QosMarkEnableDisable(ctx context.Context, in *QosMarkEnableDisable) (*QosMarkEnableDisableReply, error)
21 QosRecordDump(ctx context.Context, in *QosRecordDump) (RPCService_QosRecordDumpClient, error)
22 QosRecordEnableDisable(ctx context.Context, in *QosRecordEnableDisable) (*QosRecordEnableDisableReply, error)
23 QosStoreDump(ctx context.Context, in *QosStoreDump) (RPCService_QosStoreDumpClient, error)
24 QosStoreEnableDisable(ctx context.Context, in *QosStoreEnableDisable) (*QosStoreEnableDisableReply, error)
27 type serviceClient struct {
31 func NewServiceClient(conn api.Connection) RPCService {
32 return &serviceClient{conn}
35 func (c *serviceClient) QosEgressMapDelete(ctx context.Context, in *QosEgressMapDelete) (*QosEgressMapDeleteReply, error) {
36 out := new(QosEgressMapDeleteReply)
37 err := c.conn.Invoke(ctx, in, out)
41 return out, api.RetvalToVPPApiError(out.Retval)
44 func (c *serviceClient) QosEgressMapDump(ctx context.Context, in *QosEgressMapDump) (RPCService_QosEgressMapDumpClient, error) {
45 stream, err := c.conn.NewStream(ctx)
49 x := &serviceClient_QosEgressMapDumpClient{stream}
50 if err := x.Stream.SendMsg(in); err != nil {
53 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
59 type RPCService_QosEgressMapDumpClient interface {
60 Recv() (*QosEgressMapDetails, error)
64 type serviceClient_QosEgressMapDumpClient struct {
68 func (c *serviceClient_QosEgressMapDumpClient) Recv() (*QosEgressMapDetails, error) {
69 msg, err := c.Stream.RecvMsg()
73 switch m := msg.(type) {
74 case *QosEgressMapDetails:
76 case *vpe.ControlPingReply:
77 err = c.Stream.Close()
83 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
87 func (c *serviceClient) QosEgressMapUpdate(ctx context.Context, in *QosEgressMapUpdate) (*QosEgressMapUpdateReply, error) {
88 out := new(QosEgressMapUpdateReply)
89 err := c.conn.Invoke(ctx, in, out)
93 return out, api.RetvalToVPPApiError(out.Retval)
96 func (c *serviceClient) QosMarkDump(ctx context.Context, in *QosMarkDump) (RPCService_QosMarkDumpClient, error) {
97 stream, err := c.conn.NewStream(ctx)
101 x := &serviceClient_QosMarkDumpClient{stream}
102 if err := x.Stream.SendMsg(in); err != nil {
105 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
111 type RPCService_QosMarkDumpClient interface {
112 Recv() (*QosMarkDetails, error)
116 type serviceClient_QosMarkDumpClient struct {
120 func (c *serviceClient_QosMarkDumpClient) Recv() (*QosMarkDetails, error) {
121 msg, err := c.Stream.RecvMsg()
125 switch m := msg.(type) {
126 case *QosMarkDetails:
128 case *vpe.ControlPingReply:
129 err = c.Stream.Close()
135 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
139 func (c *serviceClient) QosMarkEnableDisable(ctx context.Context, in *QosMarkEnableDisable) (*QosMarkEnableDisableReply, error) {
140 out := new(QosMarkEnableDisableReply)
141 err := c.conn.Invoke(ctx, in, out)
145 return out, api.RetvalToVPPApiError(out.Retval)
148 func (c *serviceClient) QosRecordDump(ctx context.Context, in *QosRecordDump) (RPCService_QosRecordDumpClient, error) {
149 stream, err := c.conn.NewStream(ctx)
153 x := &serviceClient_QosRecordDumpClient{stream}
154 if err := x.Stream.SendMsg(in); err != nil {
157 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
163 type RPCService_QosRecordDumpClient interface {
164 Recv() (*QosRecordDetails, error)
168 type serviceClient_QosRecordDumpClient struct {
172 func (c *serviceClient_QosRecordDumpClient) Recv() (*QosRecordDetails, error) {
173 msg, err := c.Stream.RecvMsg()
177 switch m := msg.(type) {
178 case *QosRecordDetails:
180 case *vpe.ControlPingReply:
181 err = c.Stream.Close()
187 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
191 func (c *serviceClient) QosRecordEnableDisable(ctx context.Context, in *QosRecordEnableDisable) (*QosRecordEnableDisableReply, error) {
192 out := new(QosRecordEnableDisableReply)
193 err := c.conn.Invoke(ctx, in, out)
197 return out, api.RetvalToVPPApiError(out.Retval)
200 func (c *serviceClient) QosStoreDump(ctx context.Context, in *QosStoreDump) (RPCService_QosStoreDumpClient, error) {
201 stream, err := c.conn.NewStream(ctx)
205 x := &serviceClient_QosStoreDumpClient{stream}
206 if err := x.Stream.SendMsg(in); err != nil {
209 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
215 type RPCService_QosStoreDumpClient interface {
216 Recv() (*QosStoreDetails, error)
220 type serviceClient_QosStoreDumpClient struct {
224 func (c *serviceClient_QosStoreDumpClient) Recv() (*QosStoreDetails, error) {
225 msg, err := c.Stream.RecvMsg()
229 switch m := msg.(type) {
230 case *QosStoreDetails:
232 case *vpe.ControlPingReply:
233 err = c.Stream.Close()
239 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
243 func (c *serviceClient) QosStoreEnableDisable(ctx context.Context, in *QosStoreEnableDisable) (*QosStoreEnableDisableReply, error) {
244 out := new(QosStoreEnableDisableReply)
245 err := c.conn.Invoke(ctx, in, out)
249 return out, api.RetvalToVPPApiError(out.Retval)