Improve doc & fix import ordering
[govpp.git] / binapi / geneve / geneve_rpc.ba.go
1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
2
3 package geneve
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  geneve.
15 type RPCService interface {
16         GeneveAddDelTunnel(ctx context.Context, in *GeneveAddDelTunnel) (*GeneveAddDelTunnelReply, error)
17         GeneveTunnelDump(ctx context.Context, in *GeneveTunnelDump) (RPCService_GeneveTunnelDumpClient, error)
18         SwInterfaceSetGeneveBypass(ctx context.Context, in *SwInterfaceSetGeneveBypass) (*SwInterfaceSetGeneveBypassReply, error)
19 }
20
21 type serviceClient struct {
22         conn api.Connection
23 }
24
25 func NewServiceClient(conn api.Connection) RPCService {
26         return &serviceClient{conn}
27 }
28
29 func (c *serviceClient) GeneveAddDelTunnel(ctx context.Context, in *GeneveAddDelTunnel) (*GeneveAddDelTunnelReply, error) {
30         out := new(GeneveAddDelTunnelReply)
31         err := c.conn.Invoke(ctx, in, out)
32         if err != nil {
33                 return nil, err
34         }
35         return out, nil
36 }
37
38 func (c *serviceClient) GeneveTunnelDump(ctx context.Context, in *GeneveTunnelDump) (RPCService_GeneveTunnelDumpClient, error) {
39         stream, err := c.conn.NewStream(ctx)
40         if err != nil {
41                 return nil, err
42         }
43         x := &serviceClient_GeneveTunnelDumpClient{stream}
44         if err := x.Stream.SendMsg(in); err != nil {
45                 return nil, err
46         }
47         if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
48                 return nil, err
49         }
50         return x, nil
51 }
52
53 type RPCService_GeneveTunnelDumpClient interface {
54         Recv() (*GeneveTunnelDetails, error)
55         api.Stream
56 }
57
58 type serviceClient_GeneveTunnelDumpClient struct {
59         api.Stream
60 }
61
62 func (c *serviceClient_GeneveTunnelDumpClient) Recv() (*GeneveTunnelDetails, error) {
63         msg, err := c.Stream.RecvMsg()
64         if err != nil {
65                 return nil, err
66         }
67         switch m := msg.(type) {
68         case *GeneveTunnelDetails:
69                 return m, nil
70         case *vpe.ControlPingReply:
71                 return nil, io.EOF
72         default:
73                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
74         }
75 }
76
77 func (c *serviceClient) SwInterfaceSetGeneveBypass(ctx context.Context, in *SwInterfaceSetGeneveBypass) (*SwInterfaceSetGeneveBypassReply, error) {
78         out := new(SwInterfaceSetGeneveBypassReply)
79         err := c.conn.Invoke(ctx, in, out)
80         if err != nil {
81                 return nil, err
82         }
83         return out, nil
84 }