codec/testdata/binapi2001/memif/memif_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package memif
   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 memif module.
  13 type RPCService interface {
  14         DumpMemif(ctx context.Context, in *MemifDump) (RPCService_DumpMemifClient, error)
  15         DumpMemifSocketFilename(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_DumpMemifSocketFilenameClient, error)
  16         MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error)
  17         MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error)
  18         MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error)
  19 }
  20
  21 type serviceClient struct {
  22         ch api.Channel
  23 }
  24
  25 func NewServiceClient(ch api.Channel) RPCService {
  26         return &serviceClient{ch}
  27 }
  28
  29 func (c *serviceClient) DumpMemif(ctx context.Context, in *MemifDump) (RPCService_DumpMemifClient, error) {
  30         stream := c.ch.SendMultiRequest(in)
  31         x := &serviceClient_DumpMemifClient{stream}
  32         return x, nil
  33 }
  34
  35 type RPCService_DumpMemifClient interface {
  36         Recv() (*MemifDetails, error)
  37 }
  38
  39 type serviceClient_DumpMemifClient struct {
  40         api.MultiRequestCtx
  41 }
  42
  43 func (c *serviceClient_DumpMemifClient) Recv() (*MemifDetails, error) {
  44         m := new(MemifDetails)
  45         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  46         if err != nil {
  47                 return nil, err
  48         }
  49         if stop {
  50                 return nil, io.EOF
  51         }
  52         return m, nil
  53 }
  54
  55 func (c *serviceClient) DumpMemifSocketFilename(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_DumpMemifSocketFilenameClient, error) {
  56         stream := c.ch.SendMultiRequest(in)
  57         x := &serviceClient_DumpMemifSocketFilenameClient{stream}
  58         return x, nil
  59 }
  60
  61 type RPCService_DumpMemifSocketFilenameClient interface {
  62         Recv() (*MemifSocketFilenameDetails, error)
  63 }
  64
  65 type serviceClient_DumpMemifSocketFilenameClient struct {
  66         api.MultiRequestCtx
  67 }
  68
  69 func (c *serviceClient_DumpMemifSocketFilenameClient) Recv() (*MemifSocketFilenameDetails, error) {
  70         m := new(MemifSocketFilenameDetails)
  71         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  72         if err != nil {
  73                 return nil, err
  74         }
  75         if stop {
  76                 return nil, io.EOF
  77         }
  78         return m, nil
  79 }
  80
  81 func (c *serviceClient) MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error) {
  82         out := new(MemifCreateReply)
  83         err := c.ch.SendRequest(in).ReceiveReply(out)
  84         if err != nil {
  85                 return nil, err
  86         }
  87         return out, nil
  88 }
  89
  90 func (c *serviceClient) MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error) {
  91         out := new(MemifDeleteReply)
  92         err := c.ch.SendRequest(in).ReceiveReply(out)
  93         if err != nil {
  94                 return nil, err
  95         }
  96         return out, nil
  97 }
  98
  99 func (c *serviceClient) MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error) {
 100         out := new(MemifSocketFilenameAddDelReply)
 101         err := c.ch.SendRequest(in).ReceiveReply(out)
 102         if err != nil {
 103                 return nil, err
 104         }
 105         return out, nil
 106 }
 107
 108 // Reference imports to suppress errors if they are not otherwise used.
 109 var _ = api.RegisterMessage
 110 var _ = context.Background
 111 var _ = io.Copy