binapi/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         "fmt"
   8         "io"
   9
  10         api "git.fd.io/govpp.git/api"
  11         vpe "git.fd.io/govpp.git/binapi/vpe"
  12 )
  13
  14 // RPCService defines RPC service  memif.
  15 type RPCService interface {
  16         MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error)
  17         MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error)
  18         MemifDump(ctx context.Context, in *MemifDump) (RPCService_MemifDumpClient, error)
  19         MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error)
  20         MemifSocketFilenameDump(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_MemifSocketFilenameDumpClient, error)
  21 }
  22
  23 type serviceClient struct {
  24         conn api.Connection
  25 }
  26
  27 func NewServiceClient(conn api.Connection) RPCService {
  28         return &serviceClient{conn}
  29 }
  30
  31 func (c *serviceClient) MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error) {
  32         out := new(MemifCreateReply)
  33         err := c.conn.Invoke(ctx, in, out)
  34         if err != nil {
  35                 return nil, err
  36         }
  37         return out, nil
  38 }
  39
  40 func (c *serviceClient) MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error) {
  41         out := new(MemifDeleteReply)
  42         err := c.conn.Invoke(ctx, in, out)
  43         if err != nil {
  44                 return nil, err
  45         }
  46         return out, nil
  47 }
  48
  49 func (c *serviceClient) MemifDump(ctx context.Context, in *MemifDump) (RPCService_MemifDumpClient, error) {
  50         stream, err := c.conn.NewStream(ctx)
  51         if err != nil {
  52                 return nil, err
  53         }
  54         x := &serviceClient_MemifDumpClient{stream}
  55         if err := x.Stream.SendMsg(in); err != nil {
  56                 return nil, err
  57         }
  58         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  59                 return nil, err
  60         }
  61         return x, nil
  62 }
  63
  64 type RPCService_MemifDumpClient interface {
  65         Recv() (*MemifDetails, error)
  66         api.Stream
  67 }
  68
  69 type serviceClient_MemifDumpClient struct {
  70         api.Stream
  71 }
  72
  73 func (c *serviceClient_MemifDumpClient) Recv() (*MemifDetails, error) {
  74         msg, err := c.Stream.RecvMsg()
  75         if err != nil {
  76                 return nil, err
  77         }
  78         switch m := msg.(type) {
  79         case *MemifDetails:
  80                 return m, nil
  81         case *vpe.ControlPingReply:
  82                 return nil, io.EOF
  83         default:
  84                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  85         }
  86 }
  87
  88 func (c *serviceClient) MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error) {
  89         out := new(MemifSocketFilenameAddDelReply)
  90         err := c.conn.Invoke(ctx, in, out)
  91         if err != nil {
  92                 return nil, err
  93         }
  94         return out, nil
  95 }
  96
  97 func (c *serviceClient) MemifSocketFilenameDump(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_MemifSocketFilenameDumpClient, error) {
  98         stream, err := c.conn.NewStream(ctx)
  99         if err != nil {
 100                 return nil, err
 101         }
 102         x := &serviceClient_MemifSocketFilenameDumpClient{stream}
 103         if err := x.Stream.SendMsg(in); err != nil {
 104                 return nil, err
 105         }
 106         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 107                 return nil, err
 108         }
 109         return x, nil
 110 }
 111
 112 type RPCService_MemifSocketFilenameDumpClient interface {
 113         Recv() (*MemifSocketFilenameDetails, error)
 114         api.Stream
 115 }
 116
 117 type serviceClient_MemifSocketFilenameDumpClient struct {
 118         api.Stream
 119 }
 120
 121 func (c *serviceClient_MemifSocketFilenameDumpClient) Recv() (*MemifSocketFilenameDetails, error) {
 122         msg, err := c.Stream.RecvMsg()
 123         if err != nil {
 124                 return nil, err
 125         }
 126         switch m := msg.(type) {
 127         case *MemifSocketFilenameDetails:
 128                 return m, nil
 129         case *vpe.ControlPingReply:
 130                 return nil, io.EOF
 131         default:
 132                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 133         }
 134 }