f2e3e528295a5223c2a8545d2c83270d7fb3b84b
[govpp.git] / binapi / memif / memif_rpc.ba.go
1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
2
3 package memif
4
5 import (
6         "context"
7         "fmt"
8         "io"
9
10         api "go.fd.io/govpp/api"
11         memclnt "go.fd.io/govpp/binapi/memclnt"
12 )
13
14 // RPCService defines RPC service memif.
15 type RPCService interface {
16         MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error)
17         MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error)
18         MemifDump(ctx context.Context, in *MemifDump) (RPCService_MemifDumpClient, error)
19         MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error)
20         MemifSocketFilenameDump(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_MemifSocketFilenameDumpClient, error)
21 }
22
23 type serviceClient struct {
24         conn api.Connection
25 }
26
27 func NewServiceClient(conn api.Connection) RPCService {
28         return &serviceClient{conn}
29 }
30
31 func (c *serviceClient) MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error) {
32         out := new(MemifCreateReply)
33         err := c.conn.Invoke(ctx, in, out)
34         if err != nil {
35                 return nil, err
36         }
37         return out, api.RetvalToVPPApiError(out.Retval)
38 }
39
40 func (c *serviceClient) MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error) {
41         out := new(MemifDeleteReply)
42         err := c.conn.Invoke(ctx, in, out)
43         if err != nil {
44                 return nil, err
45         }
46         return out, api.RetvalToVPPApiError(out.Retval)
47 }
48
49 func (c *serviceClient) MemifDump(ctx context.Context, in *MemifDump) (RPCService_MemifDumpClient, error) {
50         stream, err := c.conn.NewStream(ctx)
51         if err != nil {
52                 return nil, err
53         }
54         x := &serviceClient_MemifDumpClient{stream}
55         if err := x.Stream.SendMsg(in); err != nil {
56                 return nil, err
57         }
58         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
59                 return nil, err
60         }
61         return x, nil
62 }
63
64 type RPCService_MemifDumpClient interface {
65         Recv() (*MemifDetails, error)
66         api.Stream
67 }
68
69 type serviceClient_MemifDumpClient struct {
70         api.Stream
71 }
72
73 func (c *serviceClient_MemifDumpClient) Recv() (*MemifDetails, error) {
74         msg, err := c.Stream.RecvMsg()
75         if err != nil {
76                 return nil, err
77         }
78         switch m := msg.(type) {
79         case *MemifDetails:
80                 return m, nil
81         case *memclnt.ControlPingReply:
82                 err = c.Stream.Close()
83                 if err != nil {
84                         return nil, err
85                 }
86                 return nil, io.EOF
87         default:
88                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
89         }
90 }
91
92 func (c *serviceClient) MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error) {
93         out := new(MemifSocketFilenameAddDelReply)
94         err := c.conn.Invoke(ctx, in, out)
95         if err != nil {
96                 return nil, err
97         }
98         return out, api.RetvalToVPPApiError(out.Retval)
99 }
100
101 func (c *serviceClient) MemifSocketFilenameDump(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_MemifSocketFilenameDumpClient, error) {
102         stream, err := c.conn.NewStream(ctx)
103         if err != nil {
104                 return nil, err
105         }
106         x := &serviceClient_MemifSocketFilenameDumpClient{stream}
107         if err := x.Stream.SendMsg(in); err != nil {
108                 return nil, err
109         }
110         if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
111                 return nil, err
112         }
113         return x, nil
114 }
115
116 type RPCService_MemifSocketFilenameDumpClient interface {
117         Recv() (*MemifSocketFilenameDetails, error)
118         api.Stream
119 }
120
121 type serviceClient_MemifSocketFilenameDumpClient struct {
122         api.Stream
123 }
124
125 func (c *serviceClient_MemifSocketFilenameDumpClient) Recv() (*MemifSocketFilenameDetails, error) {
126         msg, err := c.Stream.RecvMsg()
127         if err != nil {
128                 return nil, err
129         }
130         switch m := msg.(type) {
131         case *MemifSocketFilenameDetails:
132                 return m, nil
133         case *memclnt.ControlPingReply:
134                 err = c.Stream.Close()
135                 if err != nil {
136                         return nil, err
137                 }
138                 return nil, io.EOF
139         default:
140                 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
141         }
142 }