binapi/vpe/vpe_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package vpe
   4
   5 import (
   6         "context"
   7         "fmt"
   8         api "git.fd.io/govpp.git/api"
   9         "io"
  10 )
  11
  12 // RPCService defines RPC service  vpe.
  13 type RPCService interface {
  14         AddNodeNext(ctx context.Context, in *AddNodeNext) (*AddNodeNextReply, error)
  15         Cli(ctx context.Context, in *Cli) (*CliReply, error)
  16         CliInband(ctx context.Context, in *CliInband) (*CliInbandReply, error)
  17         ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error)
  18         GetF64EndianValue(ctx context.Context, in *GetF64EndianValue) (*GetF64EndianValueReply, error)
  19         GetF64IncrementByOne(ctx context.Context, in *GetF64IncrementByOne) (*GetF64IncrementByOneReply, error)
  20         GetNextIndex(ctx context.Context, in *GetNextIndex) (*GetNextIndexReply, error)
  21         GetNodeGraph(ctx context.Context, in *GetNodeGraph) (*GetNodeGraphReply, error)
  22         GetNodeIndex(ctx context.Context, in *GetNodeIndex) (*GetNodeIndexReply, error)
  23         LogDump(ctx context.Context, in *LogDump) (RPCService_LogDumpClient, error)
  24         ShowThreads(ctx context.Context, in *ShowThreads) (*ShowThreadsReply, error)
  25         ShowVersion(ctx context.Context, in *ShowVersion) (*ShowVersionReply, error)
  26         ShowVpeSystemTime(ctx context.Context, in *ShowVpeSystemTime) (*ShowVpeSystemTimeReply, 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) AddNodeNext(ctx context.Context, in *AddNodeNext) (*AddNodeNextReply, error) {
  38         out := new(AddNodeNextReply)
  39         err := c.conn.Invoke(ctx, in, out)
  40         if err != nil {
  41                 return nil, err
  42         }
  43         return out, nil
  44 }
  45
  46 func (c *serviceClient) Cli(ctx context.Context, in *Cli) (*CliReply, error) {
  47         out := new(CliReply)
  48         err := c.conn.Invoke(ctx, in, out)
  49         if err != nil {
  50                 return nil, err
  51         }
  52         return out, nil
  53 }
  54
  55 func (c *serviceClient) CliInband(ctx context.Context, in *CliInband) (*CliInbandReply, error) {
  56         out := new(CliInbandReply)
  57         err := c.conn.Invoke(ctx, in, out)
  58         if err != nil {
  59                 return nil, err
  60         }
  61         return out, nil
  62 }
  63
  64 func (c *serviceClient) ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error) {
  65         out := new(ControlPingReply)
  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) GetF64EndianValue(ctx context.Context, in *GetF64EndianValue) (*GetF64EndianValueReply, error) {
  74         out := new(GetF64EndianValueReply)
  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) GetF64IncrementByOne(ctx context.Context, in *GetF64IncrementByOne) (*GetF64IncrementByOneReply, error) {
  83         out := new(GetF64IncrementByOneReply)
  84         err := c.conn.Invoke(ctx, in, out)
  85         if err != nil {
  86                 return nil, err
  87         }
  88         return out, nil
  89 }
  90
  91 func (c *serviceClient) GetNextIndex(ctx context.Context, in *GetNextIndex) (*GetNextIndexReply, error) {
  92         out := new(GetNextIndexReply)
  93         err := c.conn.Invoke(ctx, in, out)
  94         if err != nil {
  95                 return nil, err
  96         }
  97         return out, nil
  98 }
  99
 100 func (c *serviceClient) GetNodeGraph(ctx context.Context, in *GetNodeGraph) (*GetNodeGraphReply, error) {
 101         out := new(GetNodeGraphReply)
 102         err := c.conn.Invoke(ctx, in, out)
 103         if err != nil {
 104                 return nil, err
 105         }
 106         return out, nil
 107 }
 108
 109 func (c *serviceClient) GetNodeIndex(ctx context.Context, in *GetNodeIndex) (*GetNodeIndexReply, error) {
 110         out := new(GetNodeIndexReply)
 111         err := c.conn.Invoke(ctx, in, out)
 112         if err != nil {
 113                 return nil, err
 114         }
 115         return out, nil
 116 }
 117
 118 func (c *serviceClient) LogDump(ctx context.Context, in *LogDump) (RPCService_LogDumpClient, error) {
 119         stream, err := c.conn.NewStream(ctx)
 120         if err != nil {
 121                 return nil, err
 122         }
 123         x := &serviceClient_LogDumpClient{stream}
 124         if err := x.Stream.SendMsg(in); err != nil {
 125                 return nil, err
 126         }
 127         if err = x.Stream.SendMsg(&ControlPing{}); err != nil {
 128                 return nil, err
 129         }
 130         return x, nil
 131 }
 132
 133 type RPCService_LogDumpClient interface {
 134         Recv() (*LogDetails, error)
 135         api.Stream
 136 }
 137
 138 type serviceClient_LogDumpClient struct {
 139         api.Stream
 140 }
 141
 142 func (c *serviceClient_LogDumpClient) Recv() (*LogDetails, error) {
 143         msg, err := c.Stream.RecvMsg()
 144         if err != nil {
 145                 return nil, err
 146         }
 147         switch m := msg.(type) {
 148         case *LogDetails:
 149                 return m, nil
 150         case *ControlPingReply:
 151                 return nil, io.EOF
 152         default:
 153                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 154         }
 155 }
 156
 157 func (c *serviceClient) ShowThreads(ctx context.Context, in *ShowThreads) (*ShowThreadsReply, error) {
 158         out := new(ShowThreadsReply)
 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) ShowVersion(ctx context.Context, in *ShowVersion) (*ShowVersionReply, error) {
 167         out := new(ShowVersionReply)
 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) ShowVpeSystemTime(ctx context.Context, in *ShowVpeSystemTime) (*ShowVpeSystemTimeReply, error) {
 176         out := new(ShowVpeSystemTimeReply)
 177         err := c.conn.Invoke(ctx, in, out)
 178         if err != nil {
 179                 return nil, err
 180         }
 181         return out, nil
 182 }