binapi/stn/stn_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package stn
   4
   5 import (
   6         "context"
   7         "fmt"
   8         api "git.fd.io/govpp.git/api"
   9         vpe "git.fd.io/govpp.git/binapi/vpe"
  10         "io"
  11 )
  12
  13 // RPCService defines RPC service  stn.
  14 type RPCService interface {
  15         StnAddDelRule(ctx context.Context, in *StnAddDelRule) (*StnAddDelRuleReply, error)
  16         StnRulesDump(ctx context.Context, in *StnRulesDump) (RPCService_StnRulesDumpClient, error)
  17 }
  18
  19 type serviceClient struct {
  20         conn api.Connection
  21 }
  22
  23 func NewServiceClient(conn api.Connection) RPCService {
  24         return &serviceClient{conn}
  25 }
  26
  27 func (c *serviceClient) StnAddDelRule(ctx context.Context, in *StnAddDelRule) (*StnAddDelRuleReply, error) {
  28         out := new(StnAddDelRuleReply)
  29         err := c.conn.Invoke(ctx, in, out)
  30         if err != nil {
  31                 return nil, err
  32         }
  33         return out, nil
  34 }
  35
  36 func (c *serviceClient) StnRulesDump(ctx context.Context, in *StnRulesDump) (RPCService_StnRulesDumpClient, error) {
  37         stream, err := c.conn.NewStream(ctx)
  38         if err != nil {
  39                 return nil, err
  40         }
  41         x := &serviceClient_StnRulesDumpClient{stream}
  42         if err := x.Stream.SendMsg(in); err != nil {
  43                 return nil, err
  44         }
  45         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  46                 return nil, err
  47         }
  48         return x, nil
  49 }
  50
  51 type RPCService_StnRulesDumpClient interface {
  52         Recv() (*StnRulesDetails, error)
  53         api.Stream
  54 }
  55
  56 type serviceClient_StnRulesDumpClient struct {
  57         api.Stream
  58 }
  59
  60 func (c *serviceClient_StnRulesDumpClient) Recv() (*StnRulesDetails, error) {
  61         msg, err := c.Stream.RecvMsg()
  62         if err != nil {
  63                 return nil, err
  64         }
  65         switch m := msg.(type) {
  66         case *StnRulesDetails:
  67                 return m, nil
  68         case *vpe.ControlPingReply:
  69                 return nil, io.EOF
  70         default:
  71                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  72         }
  73 }