binapi/qos/qos_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package qos
   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  qos.
  14 type RPCService interface {
  15         QosEgressMapDelete(ctx context.Context, in *QosEgressMapDelete) (*QosEgressMapDeleteReply, error)
  16         QosEgressMapDump(ctx context.Context, in *QosEgressMapDump) (RPCService_QosEgressMapDumpClient, error)
  17         QosEgressMapUpdate(ctx context.Context, in *QosEgressMapUpdate) (*QosEgressMapUpdateReply, error)
  18         QosMarkDump(ctx context.Context, in *QosMarkDump) (RPCService_QosMarkDumpClient, error)
  19         QosMarkEnableDisable(ctx context.Context, in *QosMarkEnableDisable) (*QosMarkEnableDisableReply, error)
  20         QosRecordDump(ctx context.Context, in *QosRecordDump) (RPCService_QosRecordDumpClient, error)
  21         QosRecordEnableDisable(ctx context.Context, in *QosRecordEnableDisable) (*QosRecordEnableDisableReply, error)
  22         QosStoreDump(ctx context.Context, in *QosStoreDump) (RPCService_QosStoreDumpClient, error)
  23         QosStoreEnableDisable(ctx context.Context, in *QosStoreEnableDisable) (*QosStoreEnableDisableReply, error)
  24 }
  25
  26 type serviceClient struct {
  27         conn api.Connection
  28 }
  29
  30 func NewServiceClient(conn api.Connection) RPCService {
  31         return &serviceClient{conn}
  32 }
  33
  34 func (c *serviceClient) QosEgressMapDelete(ctx context.Context, in *QosEgressMapDelete) (*QosEgressMapDeleteReply, error) {
  35         out := new(QosEgressMapDeleteReply)
  36         err := c.conn.Invoke(ctx, in, out)
  37         if err != nil {
  38                 return nil, err
  39         }
  40         return out, nil
  41 }
  42
  43 func (c *serviceClient) QosEgressMapDump(ctx context.Context, in *QosEgressMapDump) (RPCService_QosEgressMapDumpClient, error) {
  44         stream, err := c.conn.NewStream(ctx)
  45         if err != nil {
  46                 return nil, err
  47         }
  48         x := &serviceClient_QosEgressMapDumpClient{stream}
  49         if err := x.Stream.SendMsg(in); err != nil {
  50                 return nil, err
  51         }
  52         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  53                 return nil, err
  54         }
  55         return x, nil
  56 }
  57
  58 type RPCService_QosEgressMapDumpClient interface {
  59         Recv() (*QosEgressMapDetails, error)
  60         api.Stream
  61 }
  62
  63 type serviceClient_QosEgressMapDumpClient struct {
  64         api.Stream
  65 }
  66
  67 func (c *serviceClient_QosEgressMapDumpClient) Recv() (*QosEgressMapDetails, error) {
  68         msg, err := c.Stream.RecvMsg()
  69         if err != nil {
  70                 return nil, err
  71         }
  72         switch m := msg.(type) {
  73         case *QosEgressMapDetails:
  74                 return m, nil
  75         case *vpe.ControlPingReply:
  76                 return nil, io.EOF
  77         default:
  78                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  79         }
  80 }
  81
  82 func (c *serviceClient) QosEgressMapUpdate(ctx context.Context, in *QosEgressMapUpdate) (*QosEgressMapUpdateReply, error) {
  83         out := new(QosEgressMapUpdateReply)
  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) QosMarkDump(ctx context.Context, in *QosMarkDump) (RPCService_QosMarkDumpClient, error) {
  92         stream, err := c.conn.NewStream(ctx)
  93         if err != nil {
  94                 return nil, err
  95         }
  96         x := &serviceClient_QosMarkDumpClient{stream}
  97         if err := x.Stream.SendMsg(in); err != nil {
  98                 return nil, err
  99         }
 100         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 101                 return nil, err
 102         }
 103         return x, nil
 104 }
 105
 106 type RPCService_QosMarkDumpClient interface {
 107         Recv() (*QosMarkDetails, error)
 108         api.Stream
 109 }
 110
 111 type serviceClient_QosMarkDumpClient struct {
 112         api.Stream
 113 }
 114
 115 func (c *serviceClient_QosMarkDumpClient) Recv() (*QosMarkDetails, error) {
 116         msg, err := c.Stream.RecvMsg()
 117         if err != nil {
 118                 return nil, err
 119         }
 120         switch m := msg.(type) {
 121         case *QosMarkDetails:
 122                 return m, nil
 123         case *vpe.ControlPingReply:
 124                 return nil, io.EOF
 125         default:
 126                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 127         }
 128 }
 129
 130 func (c *serviceClient) QosMarkEnableDisable(ctx context.Context, in *QosMarkEnableDisable) (*QosMarkEnableDisableReply, error) {
 131         out := new(QosMarkEnableDisableReply)
 132         err := c.conn.Invoke(ctx, in, out)
 133         if err != nil {
 134                 return nil, err
 135         }
 136         return out, nil
 137 }
 138
 139 func (c *serviceClient) QosRecordDump(ctx context.Context, in *QosRecordDump) (RPCService_QosRecordDumpClient, error) {
 140         stream, err := c.conn.NewStream(ctx)
 141         if err != nil {
 142                 return nil, err
 143         }
 144         x := &serviceClient_QosRecordDumpClient{stream}
 145         if err := x.Stream.SendMsg(in); err != nil {
 146                 return nil, err
 147         }
 148         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 149                 return nil, err
 150         }
 151         return x, nil
 152 }
 153
 154 type RPCService_QosRecordDumpClient interface {
 155         Recv() (*QosRecordDetails, error)
 156         api.Stream
 157 }
 158
 159 type serviceClient_QosRecordDumpClient struct {
 160         api.Stream
 161 }
 162
 163 func (c *serviceClient_QosRecordDumpClient) Recv() (*QosRecordDetails, error) {
 164         msg, err := c.Stream.RecvMsg()
 165         if err != nil {
 166                 return nil, err
 167         }
 168         switch m := msg.(type) {
 169         case *QosRecordDetails:
 170                 return m, nil
 171         case *vpe.ControlPingReply:
 172                 return nil, io.EOF
 173         default:
 174                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 175         }
 176 }
 177
 178 func (c *serviceClient) QosRecordEnableDisable(ctx context.Context, in *QosRecordEnableDisable) (*QosRecordEnableDisableReply, error) {
 179         out := new(QosRecordEnableDisableReply)
 180         err := c.conn.Invoke(ctx, in, out)
 181         if err != nil {
 182                 return nil, err
 183         }
 184         return out, nil
 185 }
 186
 187 func (c *serviceClient) QosStoreDump(ctx context.Context, in *QosStoreDump) (RPCService_QosStoreDumpClient, error) {
 188         stream, err := c.conn.NewStream(ctx)
 189         if err != nil {
 190                 return nil, err
 191         }
 192         x := &serviceClient_QosStoreDumpClient{stream}
 193         if err := x.Stream.SendMsg(in); err != nil {
 194                 return nil, err
 195         }
 196         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 197                 return nil, err
 198         }
 199         return x, nil
 200 }
 201
 202 type RPCService_QosStoreDumpClient interface {
 203         Recv() (*QosStoreDetails, error)
 204         api.Stream
 205 }
 206
 207 type serviceClient_QosStoreDumpClient struct {
 208         api.Stream
 209 }
 210
 211 func (c *serviceClient_QosStoreDumpClient) Recv() (*QosStoreDetails, error) {
 212         msg, err := c.Stream.RecvMsg()
 213         if err != nil {
 214                 return nil, err
 215         }
 216         switch m := msg.(type) {
 217         case *QosStoreDetails:
 218                 return m, nil
 219         case *vpe.ControlPingReply:
 220                 return nil, io.EOF
 221         default:
 222                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 223         }
 224 }
 225
 226 func (c *serviceClient) QosStoreEnableDisable(ctx context.Context, in *QosStoreEnableDisable) (*QosStoreEnableDisableReply, error) {
 227         out := new(QosStoreEnableDisableReply)
 228         err := c.conn.Invoke(ctx, in, out)
 229         if err != nil {
 230                 return nil, err
 231         }
 232         return out, nil
 233 }