binapi/memclnt/memclnt_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package memclnt
   4
   5 import (
   6         "context"
   7
   8         api "git.fd.io/govpp.git/api"
   9 )
  10
  11 // RPCService defines RPC service memclnt.
  12 type RPCService interface {
  13         APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, error)
  14         ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error)
  15         GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error)
  16         MemclntCreate(ctx context.Context, in *MemclntCreate) (*MemclntCreateReply, error)
  17         MemclntDelete(ctx context.Context, in *MemclntDelete) (*MemclntDeleteReply, error)
  18         MemclntKeepalive(ctx context.Context, in *MemclntKeepalive) (*MemclntKeepaliveReply, error)
  19         MemclntReadTimeout(ctx context.Context, in *MemclntReadTimeout) error
  20         MemclntRxThreadSuspend(ctx context.Context, in *MemclntRxThreadSuspend) error
  21         RPCCall(ctx context.Context, in *RPCCall) (*RPCCallReply, error)
  22         RxThreadExit(ctx context.Context, in *RxThreadExit) error
  23         SockInitShm(ctx context.Context, in *SockInitShm) (*SockInitShmReply, error)
  24         SockclntCreate(ctx context.Context, in *SockclntCreate) (*SockclntCreateReply, error)
  25         SockclntDelete(ctx context.Context, in *SockclntDelete) (*SockclntDeleteReply, error)
  26         TracePluginMsgIds(ctx context.Context, in *TracePluginMsgIds) error
  27 }
  28
  29 type serviceClient struct {
  30         conn api.Connection
  31 }
  32
  33 func NewServiceClient(conn api.Connection) RPCService {
  34         return &serviceClient{conn}
  35 }
  36
  37 func (c *serviceClient) APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, error) {
  38         out := new(APIVersionsReply)
  39         err := c.conn.Invoke(ctx, in, out)
  40         if err != nil {
  41                 return nil, err
  42         }
  43         return out, api.RetvalToVPPApiError(out.Retval)
  44 }
  45
  46 func (c *serviceClient) ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error) {
  47         out := new(ControlPingReply)
  48         err := c.conn.Invoke(ctx, in, out)
  49         if err != nil {
  50                 return nil, err
  51         }
  52         return out, api.RetvalToVPPApiError(out.Retval)
  53 }
  54
  55 func (c *serviceClient) GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error) {
  56         out := new(GetFirstMsgIDReply)
  57         err := c.conn.Invoke(ctx, in, out)
  58         if err != nil {
  59                 return nil, err
  60         }
  61         return out, api.RetvalToVPPApiError(out.Retval)
  62 }
  63
  64 func (c *serviceClient) MemclntCreate(ctx context.Context, in *MemclntCreate) (*MemclntCreateReply, error) {
  65         out := new(MemclntCreateReply)
  66         err := c.conn.Invoke(ctx, in, out)
  67         if err != nil {
  68                 return nil, err
  69         }
  70         return out, nil
  71 }
  72
  73 func (c *serviceClient) MemclntDelete(ctx context.Context, in *MemclntDelete) (*MemclntDeleteReply, error) {
  74         out := new(MemclntDeleteReply)
  75         err := c.conn.Invoke(ctx, in, out)
  76         if err != nil {
  77                 return nil, err
  78         }
  79         return out, nil
  80 }
  81
  82 func (c *serviceClient) MemclntKeepalive(ctx context.Context, in *MemclntKeepalive) (*MemclntKeepaliveReply, error) {
  83         out := new(MemclntKeepaliveReply)
  84         err := c.conn.Invoke(ctx, in, out)
  85         if err != nil {
  86                 return nil, err
  87         }
  88         return out, api.RetvalToVPPApiError(out.Retval)
  89 }
  90
  91 func (c *serviceClient) MemclntReadTimeout(ctx context.Context, in *MemclntReadTimeout) error {
  92         stream, err := c.conn.NewStream(ctx)
  93         if err != nil {
  94                 return err
  95         }
  96         err = stream.SendMsg(in)
  97         if err != nil {
  98                 return err
  99         }
 100         err = stream.Close()
 101         if err != nil {
 102                 return err
 103         }
 104         return nil
 105 }
 106
 107 func (c *serviceClient) MemclntRxThreadSuspend(ctx context.Context, in *MemclntRxThreadSuspend) error {
 108         stream, err := c.conn.NewStream(ctx)
 109         if err != nil {
 110                 return err
 111         }
 112         err = stream.SendMsg(in)
 113         if err != nil {
 114                 return err
 115         }
 116         err = stream.Close()
 117         if err != nil {
 118                 return err
 119         }
 120         return nil
 121 }
 122
 123 func (c *serviceClient) RPCCall(ctx context.Context, in *RPCCall) (*RPCCallReply, error) {
 124         out := new(RPCCallReply)
 125         err := c.conn.Invoke(ctx, in, out)
 126         if err != nil {
 127                 return nil, err
 128         }
 129         return out, api.RetvalToVPPApiError(out.Retval)
 130 }
 131
 132 func (c *serviceClient) RxThreadExit(ctx context.Context, in *RxThreadExit) error {
 133         stream, err := c.conn.NewStream(ctx)
 134         if err != nil {
 135                 return err
 136         }
 137         err = stream.SendMsg(in)
 138         if err != nil {
 139                 return err
 140         }
 141         err = stream.Close()
 142         if err != nil {
 143                 return err
 144         }
 145         return nil
 146 }
 147
 148 func (c *serviceClient) SockInitShm(ctx context.Context, in *SockInitShm) (*SockInitShmReply, error) {
 149         out := new(SockInitShmReply)
 150         err := c.conn.Invoke(ctx, in, out)
 151         if err != nil {
 152                 return nil, err
 153         }
 154         return out, api.RetvalToVPPApiError(out.Retval)
 155 }
 156
 157 func (c *serviceClient) SockclntCreate(ctx context.Context, in *SockclntCreate) (*SockclntCreateReply, error) {
 158         out := new(SockclntCreateReply)
 159         err := c.conn.Invoke(ctx, in, out)
 160         if err != nil {
 161                 return nil, err
 162         }
 163         return out, nil
 164 }
 165
 166 func (c *serviceClient) SockclntDelete(ctx context.Context, in *SockclntDelete) (*SockclntDeleteReply, error) {
 167         out := new(SockclntDeleteReply)
 168         err := c.conn.Invoke(ctx, in, out)
 169         if err != nil {
 170                 return nil, err
 171         }
 172         return out, nil
 173 }
 174
 175 func (c *serviceClient) TracePluginMsgIds(ctx context.Context, in *TracePluginMsgIds) error {
 176         stream, err := c.conn.NewStream(ctx)
 177         if err != nil {
 178                 return err
 179         }
 180         err = stream.SendMsg(in)
 181         if err != nil {
 182                 return err
 183         }
 184         err = stream.Close()
 185         if err != nil {
 186                 return err
 187         }
 188         return nil
 189 }