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         api "git.fd.io/govpp.git/api"
   8 )
   9
  10 // RPCService defines RPC service  memclnt.
  11 type RPCService interface {
  12         APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, error)
  13         GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error)
  14         MemclntCreate(ctx context.Context, in *MemclntCreate) (*MemclntCreateReply, error)
  15         MemclntDelete(ctx context.Context, in *MemclntDelete) (*MemclntDeleteReply, error)
  16         MemclntKeepalive(ctx context.Context, in *MemclntKeepalive) (*MemclntKeepaliveReply, error)
  17         MemclntReadTimeout(ctx context.Context, in *MemclntReadTimeout) error
  18         MemclntRxThreadSuspend(ctx context.Context, in *MemclntRxThreadSuspend) error
  19         RPCCall(ctx context.Context, in *RPCCall) (*RPCCallReply, error)
  20         RxThreadExit(ctx context.Context, in *RxThreadExit) error
  21         SockInitShm(ctx context.Context, in *SockInitShm) (*SockInitShmReply, error)
  22         SockclntCreate(ctx context.Context, in *SockclntCreate) (*SockclntCreateReply, error)
  23         SockclntDelete(ctx context.Context, in *SockclntDelete) (*SockclntDeleteReply, error)
  24         TracePluginMsgIds(ctx context.Context, in *TracePluginMsgIds) error
  25 }
  26
  27 type serviceClient struct {
  28         conn api.Connection
  29 }
  30
  31 func NewServiceClient(conn api.Connection) RPCService {
  32         return &serviceClient{conn}
  33 }
  34
  35 func (c *serviceClient) APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, error) {
  36         out := new(APIVersionsReply)
  37         err := c.conn.Invoke(ctx, in, out)
  38         if err != nil {
  39                 return nil, err
  40         }
  41         return out, nil
  42 }
  43
  44 func (c *serviceClient) GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error) {
  45         out := new(GetFirstMsgIDReply)
  46         err := c.conn.Invoke(ctx, in, out)
  47         if err != nil {
  48                 return nil, err
  49         }
  50         return out, nil
  51 }
  52
  53 func (c *serviceClient) MemclntCreate(ctx context.Context, in *MemclntCreate) (*MemclntCreateReply, error) {
  54         out := new(MemclntCreateReply)
  55         err := c.conn.Invoke(ctx, in, out)
  56         if err != nil {
  57                 return nil, err
  58         }
  59         return out, nil
  60 }
  61
  62 func (c *serviceClient) MemclntDelete(ctx context.Context, in *MemclntDelete) (*MemclntDeleteReply, error) {
  63         out := new(MemclntDeleteReply)
  64         err := c.conn.Invoke(ctx, in, out)
  65         if err != nil {
  66                 return nil, err
  67         }
  68         return out, nil
  69 }
  70
  71 func (c *serviceClient) MemclntKeepalive(ctx context.Context, in *MemclntKeepalive) (*MemclntKeepaliveReply, error) {
  72         out := new(MemclntKeepaliveReply)
  73         err := c.conn.Invoke(ctx, in, out)
  74         if err != nil {
  75                 return nil, err
  76         }
  77         return out, nil
  78 }
  79
  80 func (c *serviceClient) MemclntReadTimeout(ctx context.Context, in *MemclntReadTimeout) error {
  81         stream, err := c.conn.NewStream(ctx)
  82         if err != nil {
  83                 return err
  84         }
  85         err = stream.SendMsg(in)
  86         if err != nil {
  87                 return err
  88         }
  89         return nil
  90 }
  91
  92 func (c *serviceClient) MemclntRxThreadSuspend(ctx context.Context, in *MemclntRxThreadSuspend) error {
  93         stream, err := c.conn.NewStream(ctx)
  94         if err != nil {
  95                 return err
  96         }
  97         err = stream.SendMsg(in)
  98         if err != nil {
  99                 return err
 100         }
 101         return nil
 102 }
 103
 104 func (c *serviceClient) RPCCall(ctx context.Context, in *RPCCall) (*RPCCallReply, error) {
 105         out := new(RPCCallReply)
 106         err := c.conn.Invoke(ctx, in, out)
 107         if err != nil {
 108                 return nil, err
 109         }
 110         return out, nil
 111 }
 112
 113 func (c *serviceClient) RxThreadExit(ctx context.Context, in *RxThreadExit) error {
 114         stream, err := c.conn.NewStream(ctx)
 115         if err != nil {
 116                 return err
 117         }
 118         err = stream.SendMsg(in)
 119         if err != nil {
 120                 return err
 121         }
 122         return nil
 123 }
 124
 125 func (c *serviceClient) SockInitShm(ctx context.Context, in *SockInitShm) (*SockInitShmReply, error) {
 126         out := new(SockInitShmReply)
 127         err := c.conn.Invoke(ctx, in, out)
 128         if err != nil {
 129                 return nil, err
 130         }
 131         return out, nil
 132 }
 133
 134 func (c *serviceClient) SockclntCreate(ctx context.Context, in *SockclntCreate) (*SockclntCreateReply, error) {
 135         out := new(SockclntCreateReply)
 136         err := c.conn.Invoke(ctx, in, out)
 137         if err != nil {
 138                 return nil, err
 139         }
 140         return out, nil
 141 }
 142
 143 func (c *serviceClient) SockclntDelete(ctx context.Context, in *SockclntDelete) (*SockclntDeleteReply, error) {
 144         out := new(SockclntDeleteReply)
 145         err := c.conn.Invoke(ctx, in, out)
 146         if err != nil {
 147                 return nil, err
 148         }
 149         return out, nil
 150 }
 151
 152 func (c *serviceClient) TracePluginMsgIds(ctx context.Context, in *TracePluginMsgIds) error {
 153         stream, err := c.conn.NewStream(ctx)
 154         if err != nil {
 155                 return err
 156         }
 157         err = stream.SendMsg(in)
 158         if err != nil {
 159                 return err
 160         }
 161         return nil
 162 }