1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "git.fd.io/govpp.git/api"
11 vpe "git.fd.io/govpp.git/binapi/vpe"
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 WantVrrpVrEvents(ctx context.Context, in *WantVrrpVrEvents) (*WantVrrpVrEventsReply, error)
26 type serviceClient struct {
30 func NewServiceClient(conn api.Connection) RPCService {
31 return &serviceClient{conn}
34 func (c *serviceClient) VrrpVrAddDel(ctx context.Context, in *VrrpVrAddDel) (*VrrpVrAddDelReply, error) {
35 out := new(VrrpVrAddDelReply)
36 err := c.conn.Invoke(ctx, in, out)
40 return out, api.RetvalToVPPApiError(out.Retval)
43 func (c *serviceClient) VrrpVrDump(ctx context.Context, in *VrrpVrDump) (RPCService_VrrpVrDumpClient, error) {
44 stream, err := c.conn.NewStream(ctx)
48 x := &serviceClient_VrrpVrDumpClient{stream}
49 if err := x.Stream.SendMsg(in); err != nil {
52 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
58 type RPCService_VrrpVrDumpClient interface {
59 Recv() (*VrrpVrDetails, error)
63 type serviceClient_VrrpVrDumpClient struct {
67 func (c *serviceClient_VrrpVrDumpClient) Recv() (*VrrpVrDetails, error) {
68 msg, err := c.Stream.RecvMsg()
72 switch m := msg.(type) {
75 case *vpe.ControlPingReply:
76 err = c.Stream.Close()
82 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
86 func (c *serviceClient) VrrpVrPeerDump(ctx context.Context, in *VrrpVrPeerDump) (RPCService_VrrpVrPeerDumpClient, error) {
87 stream, err := c.conn.NewStream(ctx)
91 x := &serviceClient_VrrpVrPeerDumpClient{stream}
92 if err := x.Stream.SendMsg(in); err != nil {
95 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
101 type RPCService_VrrpVrPeerDumpClient interface {
102 Recv() (*VrrpVrPeerDetails, error)
106 type serviceClient_VrrpVrPeerDumpClient struct {
110 func (c *serviceClient_VrrpVrPeerDumpClient) Recv() (*VrrpVrPeerDetails, error) {
111 msg, err := c.Stream.RecvMsg()
115 switch m := msg.(type) {
116 case *VrrpVrPeerDetails:
118 case *vpe.ControlPingReply:
119 err = c.Stream.Close()
125 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
129 func (c *serviceClient) VrrpVrSetPeers(ctx context.Context, in *VrrpVrSetPeers) (*VrrpVrSetPeersReply, error) {
130 out := new(VrrpVrSetPeersReply)
131 err := c.conn.Invoke(ctx, in, out)
135 return out, api.RetvalToVPPApiError(out.Retval)
138 func (c *serviceClient) VrrpVrStartStop(ctx context.Context, in *VrrpVrStartStop) (*VrrpVrStartStopReply, error) {
139 out := new(VrrpVrStartStopReply)
140 err := c.conn.Invoke(ctx, in, out)
144 return out, api.RetvalToVPPApiError(out.Retval)
147 func (c *serviceClient) VrrpVrTrackIfAddDel(ctx context.Context, in *VrrpVrTrackIfAddDel) (*VrrpVrTrackIfAddDelReply, error) {
148 out := new(VrrpVrTrackIfAddDelReply)
149 err := c.conn.Invoke(ctx, in, out)
153 return out, api.RetvalToVPPApiError(out.Retval)
156 func (c *serviceClient) VrrpVrTrackIfDump(ctx context.Context, in *VrrpVrTrackIfDump) (RPCService_VrrpVrTrackIfDumpClient, error) {
157 stream, err := c.conn.NewStream(ctx)
161 x := &serviceClient_VrrpVrTrackIfDumpClient{stream}
162 if err := x.Stream.SendMsg(in); err != nil {
165 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
171 type RPCService_VrrpVrTrackIfDumpClient interface {
172 Recv() (*VrrpVrTrackIfDetails, error)
176 type serviceClient_VrrpVrTrackIfDumpClient struct {
180 func (c *serviceClient_VrrpVrTrackIfDumpClient) Recv() (*VrrpVrTrackIfDetails, error) {
181 msg, err := c.Stream.RecvMsg()
185 switch m := msg.(type) {
186 case *VrrpVrTrackIfDetails:
188 case *vpe.ControlPingReply:
189 err = c.Stream.Close()
195 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
199 func (c *serviceClient) WantVrrpVrEvents(ctx context.Context, in *WantVrrpVrEvents) (*WantVrrpVrEventsReply, error) {
200 out := new(WantVrrpVrEventsReply)
201 err := c.conn.Invoke(ctx, in, out)
205 return out, api.RetvalToVPPApiError(out.Retval)