1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
13 // RPCService defines RPC service mss_clamp.
14 type RPCService interface {
15 MssClampEnableDisable(ctx context.Context, in *MssClampEnableDisable) (*MssClampEnableDisableReply, error)
16 MssClampGet(ctx context.Context, in *MssClampGet) (RPCService_MssClampGetClient, error)
19 type serviceClient struct {
23 func NewServiceClient(conn api.Connection) RPCService {
24 return &serviceClient{conn}
27 func (c *serviceClient) MssClampEnableDisable(ctx context.Context, in *MssClampEnableDisable) (*MssClampEnableDisableReply, error) {
28 out := new(MssClampEnableDisableReply)
29 err := c.conn.Invoke(ctx, in, out)
33 return out, api.RetvalToVPPApiError(out.Retval)
36 func (c *serviceClient) MssClampGet(ctx context.Context, in *MssClampGet) (RPCService_MssClampGetClient, error) {
37 stream, err := c.conn.NewStream(ctx)
41 x := &serviceClient_MssClampGetClient{stream}
42 if err := x.Stream.SendMsg(in); err != nil {
48 type RPCService_MssClampGetClient interface {
49 Recv() (*MssClampDetails, error)
53 type serviceClient_MssClampGetClient struct {
57 func (c *serviceClient_MssClampGetClient) Recv() (*MssClampDetails, error) {
58 msg, err := c.Stream.RecvMsg()
62 switch m := msg.(type) {
63 case *MssClampDetails:
65 case *MssClampGetReply:
66 err = c.Stream.Close()
72 return nil, fmt.Errorf("unexpected message: %T %v", m, m)