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