examples/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         "io"
   8
   9         api "git.fd.io/govpp.git/api"
  10 )
  11
  12 // RPCService represents RPC service API for memclnt module.
  13 type RPCService interface {
  14         APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, 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         ch api.Channel
  31 }
  32
  33 func NewServiceClient(ch api.Channel) RPCService {
  34         return &serviceClient{ch}
  35 }
  36
  37 func (c *serviceClient) APIVersions(ctx context.Context, in *APIVersions) (*APIVersionsReply, error) {
  38         out := new(APIVersionsReply)
  39         err := c.ch.SendRequest(in).ReceiveReply(out)
  40         if err != nil {
  41                 return nil, err
  42         }
  43         return out, nil
  44 }
  45
  46 func (c *serviceClient) GetFirstMsgID(ctx context.Context, in *GetFirstMsgID) (*GetFirstMsgIDReply, error) {
  47         out := new(GetFirstMsgIDReply)
  48         err := c.ch.SendRequest(in).ReceiveReply(out)
  49         if err != nil {
  50                 return nil, err
  51         }
  52         return out, nil
  53 }
  54
  55 func (c *serviceClient) MemclntCreate(ctx context.Context, in *MemclntCreate) (*MemclntCreateReply, error) {
  56         out := new(MemclntCreateReply)
  57         err := c.ch.SendRequest(in).ReceiveReply(out)
  58         if err != nil {
  59                 return nil, err
  60         }
  61         return out, nil
  62 }
  63
  64 func (c *serviceClient) MemclntDelete(ctx context.Context, in *MemclntDelete) (*MemclntDeleteReply, error) {
  65         out := new(MemclntDeleteReply)
  66         err := c.ch.SendRequest(in).ReceiveReply(out)
  67         if err != nil {
  68                 return nil, err
  69         }
  70         return out, nil
  71 }
  72
  73 func (c *serviceClient) MemclntKeepalive(ctx context.Context, in *MemclntKeepalive) (*MemclntKeepaliveReply, error) {
  74         out := new(MemclntKeepaliveReply)
  75         err := c.ch.SendRequest(in).ReceiveReply(out)
  76         if err != nil {
  77                 return nil, err
  78         }
  79         return out, nil
  80 }
  81
  82 func (c *serviceClient) MemclntReadTimeout(ctx context.Context, in *MemclntReadTimeout) error {
  83         c.ch.SendRequest(in)
  84         return nil
  85 }
  86
  87 func (c *serviceClient) MemclntRxThreadSuspend(ctx context.Context, in *MemclntRxThreadSuspend) error {
  88         c.ch.SendRequest(in)
  89         return nil
  90 }
  91
  92 func (c *serviceClient) RPCCall(ctx context.Context, in *RPCCall) (*RPCCallReply, error) {
  93         out := new(RPCCallReply)
  94         err := c.ch.SendRequest(in).ReceiveReply(out)
  95         if err != nil {
  96                 return nil, err
  97         }
  98         return out, nil
  99 }
 100
 101 func (c *serviceClient) RxThreadExit(ctx context.Context, in *RxThreadExit) error {
 102         c.ch.SendRequest(in)
 103         return nil
 104 }
 105
 106 func (c *serviceClient) SockInitShm(ctx context.Context, in *SockInitShm) (*SockInitShmReply, error) {
 107         out := new(SockInitShmReply)
 108         err := c.ch.SendRequest(in).ReceiveReply(out)
 109         if err != nil {
 110                 return nil, err
 111         }
 112         return out, nil
 113 }
 114
 115 func (c *serviceClient) SockclntCreate(ctx context.Context, in *SockclntCreate) (*SockclntCreateReply, error) {
 116         out := new(SockclntCreateReply)
 117         err := c.ch.SendRequest(in).ReceiveReply(out)
 118         if err != nil {
 119                 return nil, err
 120         }
 121         return out, nil
 122 }
 123
 124 func (c *serviceClient) SockclntDelete(ctx context.Context, in *SockclntDelete) (*SockclntDeleteReply, error) {
 125         out := new(SockclntDeleteReply)
 126         err := c.ch.SendRequest(in).ReceiveReply(out)
 127         if err != nil {
 128                 return nil, err
 129         }
 130         return out, nil
 131 }
 132
 133 func (c *serviceClient) TracePluginMsgIds(ctx context.Context, in *TracePluginMsgIds) error {
 134         c.ch.SendRequest(in)
 135         return nil
 136 }
 137
 138 // Reference imports to suppress errors if they are not otherwise used.
 139 var _ = api.RegisterMessage
 140 var _ = context.Background
 141 var _ = io.Copy