8ea98205c65ef3a257cb9b2d8c2247ce08ca60ae
[govpp.git] / internal / testbinapi / binapi2001 / gre / gre_rpc.ba.go
1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
2
3 package gre
4
5 import (
6         "context"
7         "fmt"
8         api "git.fd.io/govpp.git/api"
9         vpe "git.fd.io/govpp.git/internal/testbinapi/binapi2001/vpe"
10         "io"
11 )
12
13 // RPCService defines RPC service  gre.
14 type RPCService interface {
15         GreTunnelAddDel(ctx context.Context, in *GreTunnelAddDel) (*GreTunnelAddDelReply, error)
16         GreTunnelDump(ctx context.Context, in *GreTunnelDump) (RPCService_GreTunnelDumpClient, error)
17 }
18
19 type serviceClient struct {
20         conn api.Connection
21 }
22
23 func NewServiceClient(conn api.Connection) RPCService {
24         return &serviceClient{conn}
25 }
26
27 func (c *serviceClient) GreTunnelAddDel(ctx context.Context, in *GreTunnelAddDel) (*GreTunnelAddDelReply, error) {
28         out := new(GreTunnelAddDelReply)
29         err := c.conn.Invoke(ctx, in, out)
30         if err != nil {
31                 return nil, err
32         }
33         return out, nil
34 }
35
36 func (c *serviceClient) GreTunnelDump(ctx context.Context, in *GreTunnelDump) (RPCService_GreTunnelDumpClient, error) {
37         stream, err := c.conn.NewStream(ctx)
38         if err != nil {
39                 return nil, err
40         }
41         x := &serviceClient_GreTunnelDumpClient{stream}
42         if err := x.Stream.SendMsg(in); err != nil {
43                 return nil, err
44         }
45         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
46                 return nil, err
47         }
48         return x, nil
49 }
50
51 type RPCService_GreTunnelDumpClient interface {
52         Recv() (*GreTunnelDetails, error)
53         api.Stream
54 }
55
56 type serviceClient_GreTunnelDumpClient struct {
57         api.Stream
58 }
59
60 func (c *serviceClient_GreTunnelDumpClient) Recv() (*GreTunnelDetails, error) {
61         msg, err := c.Stream.RecvMsg()
62         if err != nil {
63                 return nil, err
64         }
65         switch m := msg.(type) {
66         case *GreTunnelDetails:
67                 return m, nil
68         case *vpe.ControlPingReply:
69                 return nil, io.EOF
70         default:
71                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
72         }
73 }