binapi/vrrp/vrrp_rpc.ba.go

   1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
   2
   3 package vrrp
   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  vrrp.
  14 type RPCService interface {
  15         VrrpVrAddDel(ctx context.Context, in *VrrpVrAddDel) (*VrrpVrAddDelReply, error)
  16         VrrpVrDump(ctx context.Context, in *VrrpVrDump) (RPCService_VrrpVrDumpClient, error)
  17         VrrpVrPeerDump(ctx context.Context, in *VrrpVrPeerDump) (RPCService_VrrpVrPeerDumpClient, error)
  18         VrrpVrSetPeers(ctx context.Context, in *VrrpVrSetPeers) (*VrrpVrSetPeersReply, error)
  19         VrrpVrStartStop(ctx context.Context, in *VrrpVrStartStop) (*VrrpVrStartStopReply, error)
  20         VrrpVrTrackIfAddDel(ctx context.Context, in *VrrpVrTrackIfAddDel) (*VrrpVrTrackIfAddDelReply, error)
  21         VrrpVrTrackIfDump(ctx context.Context, in *VrrpVrTrackIfDump) (RPCService_VrrpVrTrackIfDumpClient, error)
  22 }
  23
  24 type serviceClient struct {
  25         conn api.Connection
  26 }
  27
  28 func NewServiceClient(conn api.Connection) RPCService {
  29         return &serviceClient{conn}
  30 }
  31
  32 func (c *serviceClient) VrrpVrAddDel(ctx context.Context, in *VrrpVrAddDel) (*VrrpVrAddDelReply, error) {
  33         out := new(VrrpVrAddDelReply)
  34         err := c.conn.Invoke(ctx, in, out)
  35         if err != nil {
  36                 return nil, err
  37         }
  38         return out, nil
  39 }
  40
  41 func (c *serviceClient) VrrpVrDump(ctx context.Context, in *VrrpVrDump) (RPCService_VrrpVrDumpClient, error) {
  42         stream, err := c.conn.NewStream(ctx)
  43         if err != nil {
  44                 return nil, err
  45         }
  46         x := &serviceClient_VrrpVrDumpClient{stream}
  47         if err := x.Stream.SendMsg(in); err != nil {
  48                 return nil, err
  49         }
  50         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  51                 return nil, err
  52         }
  53         return x, nil
  54 }
  55
  56 type RPCService_VrrpVrDumpClient interface {
  57         Recv() (*VrrpVrDetails, error)
  58         api.Stream
  59 }
  60
  61 type serviceClient_VrrpVrDumpClient struct {
  62         api.Stream
  63 }
  64
  65 func (c *serviceClient_VrrpVrDumpClient) Recv() (*VrrpVrDetails, error) {
  66         msg, err := c.Stream.RecvMsg()
  67         if err != nil {
  68                 return nil, err
  69         }
  70         switch m := msg.(type) {
  71         case *VrrpVrDetails:
  72                 return m, nil
  73         case *vpe.ControlPingReply:
  74                 return nil, io.EOF
  75         default:
  76                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
  77         }
  78 }
  79
  80 func (c *serviceClient) VrrpVrPeerDump(ctx context.Context, in *VrrpVrPeerDump) (RPCService_VrrpVrPeerDumpClient, error) {
  81         stream, err := c.conn.NewStream(ctx)
  82         if err != nil {
  83                 return nil, err
  84         }
  85         x := &serviceClient_VrrpVrPeerDumpClient{stream}
  86         if err := x.Stream.SendMsg(in); err != nil {
  87                 return nil, err
  88         }
  89         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
  90                 return nil, err
  91         }
  92         return x, nil
  93 }
  94
  95 type RPCService_VrrpVrPeerDumpClient interface {
  96         Recv() (*VrrpVrPeerDetails, error)
  97         api.Stream
  98 }
  99
 100 type serviceClient_VrrpVrPeerDumpClient struct {
 101         api.Stream
 102 }
 103
 104 func (c *serviceClient_VrrpVrPeerDumpClient) Recv() (*VrrpVrPeerDetails, error) {
 105         msg, err := c.Stream.RecvMsg()
 106         if err != nil {
 107                 return nil, err
 108         }
 109         switch m := msg.(type) {
 110         case *VrrpVrPeerDetails:
 111                 return m, nil
 112         case *vpe.ControlPingReply:
 113                 return nil, io.EOF
 114         default:
 115                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 116         }
 117 }
 118
 119 func (c *serviceClient) VrrpVrSetPeers(ctx context.Context, in *VrrpVrSetPeers) (*VrrpVrSetPeersReply, error) {
 120         out := new(VrrpVrSetPeersReply)
 121         err := c.conn.Invoke(ctx, in, out)
 122         if err != nil {
 123                 return nil, err
 124         }
 125         return out, nil
 126 }
 127
 128 func (c *serviceClient) VrrpVrStartStop(ctx context.Context, in *VrrpVrStartStop) (*VrrpVrStartStopReply, error) {
 129         out := new(VrrpVrStartStopReply)
 130         err := c.conn.Invoke(ctx, in, out)
 131         if err != nil {
 132                 return nil, err
 133         }
 134         return out, nil
 135 }
 136
 137 func (c *serviceClient) VrrpVrTrackIfAddDel(ctx context.Context, in *VrrpVrTrackIfAddDel) (*VrrpVrTrackIfAddDelReply, error) {
 138         out := new(VrrpVrTrackIfAddDelReply)
 139         err := c.conn.Invoke(ctx, in, out)
 140         if err != nil {
 141                 return nil, err
 142         }
 143         return out, nil
 144 }
 145
 146 func (c *serviceClient) VrrpVrTrackIfDump(ctx context.Context, in *VrrpVrTrackIfDump) (RPCService_VrrpVrTrackIfDumpClient, error) {
 147         stream, err := c.conn.NewStream(ctx)
 148         if err != nil {
 149                 return nil, err
 150         }
 151         x := &serviceClient_VrrpVrTrackIfDumpClient{stream}
 152         if err := x.Stream.SendMsg(in); err != nil {
 153                 return nil, err
 154         }
 155         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
 156                 return nil, err
 157         }
 158         return x, nil
 159 }
 160
 161 type RPCService_VrrpVrTrackIfDumpClient interface {
 162         Recv() (*VrrpVrTrackIfDetails, error)
 163         api.Stream
 164 }
 165
 166 type serviceClient_VrrpVrTrackIfDumpClient struct {
 167         api.Stream
 168 }
 169
 170 func (c *serviceClient_VrrpVrTrackIfDumpClient) Recv() (*VrrpVrTrackIfDetails, error) {
 171         msg, err := c.Stream.RecvMsg()
 172         if err != nil {
 173                 return nil, err
 174         }
 175         switch m := msg.(type) {
 176         case *VrrpVrTrackIfDetails:
 177                 return m, nil
 178         case *vpe.ControlPingReply:
 179                 return nil, io.EOF
 180         default:
 181                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
 182         }
 183 }