examples/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         "io"
   8
   9         api "git.fd.io/govpp.git/api"
  10 )
  11
  12 // RPCService represents RPC service API for vpe module.
  13 type RPCService interface {
  14         DumpLog(ctx context.Context, in *LogDump) (RPCService_DumpLogClient, error)
  15         AddNodeNext(ctx context.Context, in *AddNodeNext) (*AddNodeNextReply, error)
  16         Cli(ctx context.Context, in *Cli) (*CliReply, error)
  17         CliInband(ctx context.Context, in *CliInband) (*CliInbandReply, error)
  18         ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error)
  19         GetF64EndianValue(ctx context.Context, in *GetF64EndianValue) (*GetF64EndianValueReply, error)
  20         GetF64IncrementByOne(ctx context.Context, in *GetF64IncrementByOne) (*GetF64IncrementByOneReply, error)
  21         GetNextIndex(ctx context.Context, in *GetNextIndex) (*GetNextIndexReply, error)
  22         GetNodeGraph(ctx context.Context, in *GetNodeGraph) (*GetNodeGraphReply, error)
  23         GetNodeIndex(ctx context.Context, in *GetNodeIndex) (*GetNodeIndexReply, 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         ch api.Channel
  31 }
  32
  33 func NewServiceClient(ch api.Channel) RPCService {
  34         return &serviceClient{ch}
  35 }
  36
  37 func (c *serviceClient) DumpLog(ctx context.Context, in *LogDump) (RPCService_DumpLogClient, error) {
  38         stream := c.ch.SendMultiRequest(in)
  39         x := &serviceClient_DumpLogClient{stream}
  40         return x, nil
  41 }
  42
  43 type RPCService_DumpLogClient interface {
  44         Recv() (*LogDetails, error)
  45 }
  46
  47 type serviceClient_DumpLogClient struct {
  48         api.MultiRequestCtx
  49 }
  50
  51 func (c *serviceClient_DumpLogClient) Recv() (*LogDetails, error) {
  52         m := new(LogDetails)
  53         stop, err := c.MultiRequestCtx.ReceiveReply(m)
  54         if err != nil {
  55                 return nil, err
  56         }
  57         if stop {
  58                 return nil, io.EOF
  59         }
  60         return m, nil
  61 }
  62
  63 func (c *serviceClient) AddNodeNext(ctx context.Context, in *AddNodeNext) (*AddNodeNextReply, error) {
  64         out := new(AddNodeNextReply)
  65         err := c.ch.SendRequest(in).ReceiveReply(out)
  66         if err != nil {
  67                 return nil, err
  68         }
  69         return out, nil
  70 }
  71
  72 func (c *serviceClient) Cli(ctx context.Context, in *Cli) (*CliReply, error) {
  73         out := new(CliReply)
  74         err := c.ch.SendRequest(in).ReceiveReply(out)
  75         if err != nil {
  76                 return nil, err
  77         }
  78         return out, nil
  79 }
  80
  81 func (c *serviceClient) CliInband(ctx context.Context, in *CliInband) (*CliInbandReply, error) {
  82         out := new(CliInbandReply)
  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) ControlPing(ctx context.Context, in *ControlPing) (*ControlPingReply, error) {
  91         out := new(ControlPingReply)
  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) GetF64EndianValue(ctx context.Context, in *GetF64EndianValue) (*GetF64EndianValueReply, error) {
 100         out := new(GetF64EndianValueReply)
 101         err := c.ch.SendRequest(in).ReceiveReply(out)
 102         if err != nil {
 103                 return nil, err
 104         }
 105         return out, nil
 106 }
 107
 108 func (c *serviceClient) GetF64IncrementByOne(ctx context.Context, in *GetF64IncrementByOne) (*GetF64IncrementByOneReply, error) {
 109         out := new(GetF64IncrementByOneReply)
 110         err := c.ch.SendRequest(in).ReceiveReply(out)
 111         if err != nil {
 112                 return nil, err
 113         }
 114         return out, nil
 115 }
 116
 117 func (c *serviceClient) GetNextIndex(ctx context.Context, in *GetNextIndex) (*GetNextIndexReply, error) {
 118         out := new(GetNextIndexReply)
 119         err := c.ch.SendRequest(in).ReceiveReply(out)
 120         if err != nil {
 121                 return nil, err
 122         }
 123         return out, nil
 124 }
 125
 126 func (c *serviceClient) GetNodeGraph(ctx context.Context, in *GetNodeGraph) (*GetNodeGraphReply, error) {
 127         out := new(GetNodeGraphReply)
 128         err := c.ch.SendRequest(in).ReceiveReply(out)
 129         if err != nil {
 130                 return nil, err
 131         }
 132         return out, nil
 133 }
 134
 135 func (c *serviceClient) GetNodeIndex(ctx context.Context, in *GetNodeIndex) (*GetNodeIndexReply, error) {
 136         out := new(GetNodeIndexReply)
 137         err := c.ch.SendRequest(in).ReceiveReply(out)
 138         if err != nil {
 139                 return nil, err
 140         }
 141         return out, nil
 142 }
 143
 144 func (c *serviceClient) ShowThreads(ctx context.Context, in *ShowThreads) (*ShowThreadsReply, error) {
 145         out := new(ShowThreadsReply)
 146         err := c.ch.SendRequest(in).ReceiveReply(out)
 147         if err != nil {
 148                 return nil, err
 149         }
 150         return out, nil
 151 }
 152
 153 func (c *serviceClient) ShowVersion(ctx context.Context, in *ShowVersion) (*ShowVersionReply, error) {
 154         out := new(ShowVersionReply)
 155         err := c.ch.SendRequest(in).ReceiveReply(out)
 156         if err != nil {
 157                 return nil, err
 158         }
 159         return out, nil
 160 }
 161
 162 func (c *serviceClient) ShowVpeSystemTime(ctx context.Context, in *ShowVpeSystemTime) (*ShowVpeSystemTimeReply, error) {
 163         out := new(ShowVpeSystemTimeReply)
 164         err := c.ch.SendRequest(in).ReceiveReply(out)
 165         if err != nil {
 166                 return nil, err
 167         }
 168         return out, nil
 169 }
 170
 171 // Reference imports to suppress errors if they are not otherwise used.
 172 var _ = api.RegisterMessage
 173 var _ = context.Background
 174 var _ = io.Copy