import (
"context"
- api "git.fd.io/govpp.git/api"
+ api "go.fd.io/govpp/api"
)
// RPCService defines RPC service memclnt.
type RPCService interface {
APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, error)
+ ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error)
GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error)
MemclntCreate(ctx context.Context, in *MemclntCreate) (*MemclntCreateReply, error)
MemclntDelete(ctx context.Context, in *MemclntDelete) (*MemclntDeleteReply, error)
return out, api.RetvalToVPPApiError(out.Retval)
}
+func (c *serviceClient) ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error) {
+ out := new(ControlPingReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, api.RetvalToVPPApiError(out.Retval)
+}
+
func (c *serviceClient) GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error) {
out := new(GetFirstMsgIDReply)
err := c.conn.Invoke(ctx, in, out)
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
return nil
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
return nil
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
return nil
}
if err != nil {
return err
}
+ err = stream.Close()
+ if err != nil {
+ return err
+ }
return nil
}