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