binapi/bond/bond_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package bond
   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 bond.
  15 type RPCService interface {
  16         BondAddMember(ctx context.Context, in *BondAddMember) (*BondAddMemberReply, error)
  17         BondCreate(ctx context.Context, in *BondCreate) (*BondCreateReply, error)
  18         BondCreate2(ctx context.Context, in *BondCreate2) (*BondCreate2Reply, error)
  19         BondDelete(ctx context.Context, in *BondDelete) (*BondDeleteReply, error)
  20         BondDetachMember(ctx context.Context, in *BondDetachMember) (*BondDetachMemberReply, error)
  21         BondDetachSlave(ctx context.Context, in *BondDetachSlave) (*BondDetachSlaveReply, error)
  22         BondEnslave(ctx context.Context, in *BondEnslave) (*BondEnslaveReply, error)
  23         SwBondInterfaceDump(ctx context.Context, in *SwBondInterfaceDump) (RPCService_SwBondInterfaceDumpClient, error)
  24         SwInterfaceBondDump(ctx context.Context, in *SwInterfaceBondDump) (RPCService_SwInterfaceBondDumpClient, error)
  25         SwInterfaceSetBondWeight(ctx context.Context, in *SwInterfaceSetBondWeight) (*SwInterfaceSetBondWeightReply, error)
  26         SwInterfaceSlaveDump(ctx context.Context, in *SwInterfaceSlaveDump) (RPCService_SwInterfaceSlaveDumpClient, error)
  27         SwMemberInterfaceDump(ctx context.Context, in *SwMemberInterfaceDump) (RPCService_SwMemberInterfaceDumpClient, error)
  28 }
  29
  30 type serviceClient struct {
  31         conn api.Connection
  32 }
  33
  34 func NewServiceClient(conn api.Connection) RPCService {
  35         return &serviceClient{conn}
  36 }
  37
  38 func (c *serviceClient) BondAddMember(ctx context.Context, in *BondAddMember) (*BondAddMemberReply, error) {
  39         out := new(BondAddMemberReply)
  40         err := c.conn.Invoke(ctx, in, out)
  41         if err != nil {
  42                 return nil, err
  43         }
  44         return out, api.RetvalToVPPApiError(out.Retval)
  45 }
  46
  47 func (c *serviceClient) BondCreate(ctx context.Context, in *BondCreate) (*BondCreateReply, error) {
  48         out := new(BondCreateReply)
  49         err := c.conn.Invoke(ctx, in, out)
  50         if err != nil {
  51                 return nil, err
  52         }
  53         return out, api.RetvalToVPPApiError(out.Retval)
  54 }
  55
  56 func (c *serviceClient) BondCreate2(ctx context.Context, in *BondCreate2) (*BondCreate2Reply, error) {
  57         out := new(BondCreate2Reply)
  58         err := c.conn.Invoke(ctx, in, out)
  59         if err != nil {
  60                 return nil, err
  61         }
  62         return out, api.RetvalToVPPApiError(out.Retval)
  63 }
  64
  65 func (c *serviceClient) BondDelete(ctx context.Context, in *BondDelete) (*BondDeleteReply, error) {
  66         out := new(BondDeleteReply)
  67         err := c.conn.Invoke(ctx, in, out)
  68         if err != nil {
  69                 return nil, err
  70         }
  71         return out, api.RetvalToVPPApiError(out.Retval)
  72 }
  73
  74 func (c *serviceClient) BondDetachMember(ctx context.Context, in *BondDetachMember) (*BondDetachMemberReply, error) {
  75         out := new(BondDetachMemberReply)
  76         err := c.conn.Invoke(ctx, in, out)
  77         if err != nil {
  78                 return nil, err
  79         }
  80         return out, api.RetvalToVPPApiError(out.Retval)
  81 }
  82
  83 func (c *serviceClient) BondDetachSlave(ctx context.Context, in *BondDetachSlave) (*BondDetachSlaveReply, error) {
  84         out := new(BondDetachSlaveReply)
  85         err := c.conn.Invoke(ctx, in, out)
  86         if err != nil {
  87                 return nil, err
  88         }
  89         return out, api.RetvalToVPPApiError(out.Retval)
  90 }
  91
  92 func (c *serviceClient) BondEnslave(ctx context.Context, in *BondEnslave) (*BondEnslaveReply, error) {
  93         out := new(BondEnslaveReply)
  94         err := c.conn.Invoke(ctx, in, out)
  95         if err != nil {
  96                 return nil, err
  97         }
  98         return out, api.RetvalToVPPApiError(out.Retval)
  99 }
 100
 101 func (c *serviceClient) SwBondInterfaceDump(ctx context.Context, in *SwBondInterfaceDump) (RPCService_SwBondInterfaceDumpClient, error) {
 102         stream, err := c.conn.NewStream(ctx)
 103         if err != nil {
 104                 return nil, err
 105         }
 106         x := &serviceClient_SwBondInterfaceDumpClient{stream}
 107         if err := x.Stream.SendMsg(in); err != nil {
 108                 return nil, err
 109         }
 110         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 111                 return nil, err
 112         }
 113         return x, nil
 114 }
 115
 116 type RPCService_SwBondInterfaceDumpClient interface {
 117         Recv() (*SwBondInterfaceDetails, error)
 118         api.Stream
 119 }
 120
 121 type serviceClient_SwBondInterfaceDumpClient struct {
 122         api.Stream
 123 }
 124
 125 func (c *serviceClient_SwBondInterfaceDumpClient) Recv() (*SwBondInterfaceDetails, error) {
 126         msg, err := c.Stream.RecvMsg()
 127         if err != nil {
 128                 return nil, err
 129         }
 130         switch m := msg.(type) {
 131         case *SwBondInterfaceDetails:
 132                 return m, nil
 133         case *vpe.ControlPingReply:
 134                 return nil, io.EOF
 135         default:
 136                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 137         }
 138 }
 139
 140 func (c *serviceClient) SwInterfaceBondDump(ctx context.Context, in *SwInterfaceBondDump) (RPCService_SwInterfaceBondDumpClient, error) {
 141         stream, err := c.conn.NewStream(ctx)
 142         if err != nil {
 143                 return nil, err
 144         }
 145         x := &serviceClient_SwInterfaceBondDumpClient{stream}
 146         if err := x.Stream.SendMsg(in); err != nil {
 147                 return nil, err
 148         }
 149         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 150                 return nil, err
 151         }
 152         return x, nil
 153 }
 154
 155 type RPCService_SwInterfaceBondDumpClient interface {
 156         Recv() (*SwInterfaceBondDetails, error)
 157         api.Stream
 158 }
 159
 160 type serviceClient_SwInterfaceBondDumpClient struct {
 161         api.Stream
 162 }
 163
 164 func (c *serviceClient_SwInterfaceBondDumpClient) Recv() (*SwInterfaceBondDetails, error) {
 165         msg, err := c.Stream.RecvMsg()
 166         if err != nil {
 167                 return nil, err
 168         }
 169         switch m := msg.(type) {
 170         case *SwInterfaceBondDetails:
 171                 return m, nil
 172         case *vpe.ControlPingReply:
 173                 return nil, io.EOF
 174         default:
 175                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 176         }
 177 }
 178
 179 func (c *serviceClient) SwInterfaceSetBondWeight(ctx context.Context, in *SwInterfaceSetBondWeight) (*SwInterfaceSetBondWeightReply, error) {
 180         out := new(SwInterfaceSetBondWeightReply)
 181         err := c.conn.Invoke(ctx, in, out)
 182         if err != nil {
 183                 return nil, err
 184         }
 185         return out, api.RetvalToVPPApiError(out.Retval)
 186 }
 187
 188 func (c *serviceClient) SwInterfaceSlaveDump(ctx context.Context, in *SwInterfaceSlaveDump) (RPCService_SwInterfaceSlaveDumpClient, error) {
 189         stream, err := c.conn.NewStream(ctx)
 190         if err != nil {
 191                 return nil, err
 192         }
 193         x := &serviceClient_SwInterfaceSlaveDumpClient{stream}
 194         if err := x.Stream.SendMsg(in); err != nil {
 195                 return nil, err
 196         }
 197         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 198                 return nil, err
 199         }
 200         return x, nil
 201 }
 202
 203 type RPCService_SwInterfaceSlaveDumpClient interface {
 204         Recv() (*SwInterfaceSlaveDetails, error)
 205         api.Stream
 206 }
 207
 208 type serviceClient_SwInterfaceSlaveDumpClient struct {
 209         api.Stream
 210 }
 211
 212 func (c *serviceClient_SwInterfaceSlaveDumpClient) Recv() (*SwInterfaceSlaveDetails, error) {
 213         msg, err := c.Stream.RecvMsg()
 214         if err != nil {
 215                 return nil, err
 216         }
 217         switch m := msg.(type) {
 218         case *SwInterfaceSlaveDetails:
 219                 return m, nil
 220         case *vpe.ControlPingReply:
 221                 return nil, io.EOF
 222         default:
 223                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 224         }
 225 }
 226
 227 func (c *serviceClient) SwMemberInterfaceDump(ctx context.Context, in *SwMemberInterfaceDump) (RPCService_SwMemberInterfaceDumpClient, error) {
 228         stream, err := c.conn.NewStream(ctx)
 229         if err != nil {
 230                 return nil, err
 231         }
 232         x := &serviceClient_SwMemberInterfaceDumpClient{stream}
 233         if err := x.Stream.SendMsg(in); err != nil {
 234                 return nil, err
 235         }
 236         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 237                 return nil, err
 238         }
 239         return x, nil
 240 }
 241
 242 type RPCService_SwMemberInterfaceDumpClient interface {
 243         Recv() (*SwMemberInterfaceDetails, error)
 244         api.Stream
 245 }
 246
 247 type serviceClient_SwMemberInterfaceDumpClient struct {
 248         api.Stream
 249 }
 250
 251 func (c *serviceClient_SwMemberInterfaceDumpClient) Recv() (*SwMemberInterfaceDetails, error) {
 252         msg, err := c.Stream.RecvMsg()
 253         if err != nil {
 254                 return nil, err
 255         }
 256         switch m := msg.(type) {
 257         case *SwMemberInterfaceDetails:
 258                 return m, nil
 259         case *vpe.ControlPingReply:
 260                 return nil, io.EOF
 261         default:
 262                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 263         }
 264 }