binapi/lb/lb_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package lb
   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  lb.
  14 type RPCService interface {
  15         LbAddDelAs(ctx context.Context, in *LbAddDelAs) (*LbAddDelAsReply, error)
  16         LbAddDelIntfNat4(ctx context.Context, in *LbAddDelIntfNat4) (*LbAddDelIntfNat4Reply, error)
  17         LbAddDelIntfNat6(ctx context.Context, in *LbAddDelIntfNat6) (*LbAddDelIntfNat6Reply, error)
  18         LbAddDelVip(ctx context.Context, in *LbAddDelVip) (*LbAddDelVipReply, error)
  19         LbAsDump(ctx context.Context, in *LbAsDump) (RPCService_LbAsDumpClient, error)
  20         LbConf(ctx context.Context, in *LbConf) (*LbConfReply, error)
  21         LbFlushVip(ctx context.Context, in *LbFlushVip) (*LbFlushVipReply, error)
  22         LbVipDump(ctx context.Context, in *LbVipDump) (RPCService_LbVipDumpClient, error)
  23 }
  24
  25 type serviceClient struct {
  26         conn api.Connection
  27 }
  28
  29 func NewServiceClient(conn api.Connection) RPCService {
  30         return &serviceClient{conn}
  31 }
  32
  33 func (c *serviceClient) LbAddDelAs(ctx context.Context, in *LbAddDelAs) (*LbAddDelAsReply, error) {
  34         out := new(LbAddDelAsReply)
  35         err := c.conn.Invoke(ctx, in, out)
  36         if err != nil {
  37                 return nil, err
  38         }
  39         return out, nil
  40 }
  41
  42 func (c *serviceClient) LbAddDelIntfNat4(ctx context.Context, in *LbAddDelIntfNat4) (*LbAddDelIntfNat4Reply, error) {
  43         out := new(LbAddDelIntfNat4Reply)
  44         err := c.conn.Invoke(ctx, in, out)
  45         if err != nil {
  46                 return nil, err
  47         }
  48         return out, nil
  49 }
  50
  51 func (c *serviceClient) LbAddDelIntfNat6(ctx context.Context, in *LbAddDelIntfNat6) (*LbAddDelIntfNat6Reply, error) {
  52         out := new(LbAddDelIntfNat6Reply)
  53         err := c.conn.Invoke(ctx, in, out)
  54         if err != nil {
  55                 return nil, err
  56         }
  57         return out, nil
  58 }
  59
  60 func (c *serviceClient) LbAddDelVip(ctx context.Context, in *LbAddDelVip) (*LbAddDelVipReply, error) {
  61         out := new(LbAddDelVipReply)
  62         err := c.conn.Invoke(ctx, in, out)
  63         if err != nil {
  64                 return nil, err
  65         }
  66         return out, nil
  67 }
  68
  69 func (c *serviceClient) LbAsDump(ctx context.Context, in *LbAsDump) (RPCService_LbAsDumpClient, error) {
  70         stream, err := c.conn.NewStream(ctx)
  71         if err != nil {
  72                 return nil, err
  73         }
  74         x := &serviceClient_LbAsDumpClient{stream}
  75         if err := x.Stream.SendMsg(in); err != nil {
  76                 return nil, err
  77         }
  78         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  79                 return nil, err
  80         }
  81         return x, nil
  82 }
  83
  84 type RPCService_LbAsDumpClient interface {
  85         Recv() (*LbAsDetails, error)
  86         api.Stream
  87 }
  88
  89 type serviceClient_LbAsDumpClient struct {
  90         api.Stream
  91 }
  92
  93 func (c *serviceClient_LbAsDumpClient) Recv() (*LbAsDetails, error) {
  94         msg, err := c.Stream.RecvMsg()
  95         if err != nil {
  96                 return nil, err
  97         }
  98         switch m := msg.(type) {
  99         case *LbAsDetails:
 100                 return m, nil
 101         case *vpe.ControlPingReply:
 102                 return nil, io.EOF
 103         default:
 104                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 105         }
 106 }
 107
 108 func (c *serviceClient) LbConf(ctx context.Context, in *LbConf) (*LbConfReply, error) {
 109         out := new(LbConfReply)
 110         err := c.conn.Invoke(ctx, in, out)
 111         if err != nil {
 112                 return nil, err
 113         }
 114         return out, nil
 115 }
 116
 117 func (c *serviceClient) LbFlushVip(ctx context.Context, in *LbFlushVip) (*LbFlushVipReply, error) {
 118         out := new(LbFlushVipReply)
 119         err := c.conn.Invoke(ctx, in, out)
 120         if err != nil {
 121                 return nil, err
 122         }
 123         return out, nil
 124 }
 125
 126 func (c *serviceClient) LbVipDump(ctx context.Context, in *LbVipDump) (RPCService_LbVipDumpClient, error) {
 127         stream, err := c.conn.NewStream(ctx)
 128         if err != nil {
 129                 return nil, err
 130         }
 131         x := &serviceClient_LbVipDumpClient{stream}
 132         if err := x.Stream.SendMsg(in); err != nil {
 133                 return nil, err
 134         }
 135         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 136                 return nil, err
 137         }
 138         return x, nil
 139 }
 140
 141 type RPCService_LbVipDumpClient interface {
 142         Recv() (*LbVipDetails, error)
 143         api.Stream
 144 }
 145
 146 type serviceClient_LbVipDumpClient struct {
 147         api.Stream
 148 }
 149
 150 func (c *serviceClient_LbVipDumpClient) Recv() (*LbVipDetails, error) {
 151         msg, err := c.Stream.RecvMsg()
 152         if err != nil {
 153                 return nil, err
 154         }
 155         switch m := msg.(type) {
 156         case *LbVipDetails:
 157                 return m, nil
 158         case *vpe.ControlPingReply:
 159                 return nil, io.EOF
 160         default:
 161                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 162         }
 163 }