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 bier.
15 type RPCService interface {
16 BierDispEntryAddDel(ctx context.Context, in *BierDispEntryAddDel) (*BierDispEntryAddDelReply, error)
17 BierDispEntryDump(ctx context.Context, in *BierDispEntryDump) (RPCService_BierDispEntryDumpClient, error)
18 BierDispTableAddDel(ctx context.Context, in *BierDispTableAddDel) (*BierDispTableAddDelReply, error)
19 BierDispTableDump(ctx context.Context, in *BierDispTableDump) (RPCService_BierDispTableDumpClient, error)
20 BierImpAdd(ctx context.Context, in *BierImpAdd) (*BierImpAddReply, error)
21 BierImpDel(ctx context.Context, in *BierImpDel) (*BierImpDelReply, error)
22 BierImpDump(ctx context.Context, in *BierImpDump) (RPCService_BierImpDumpClient, error)
23 BierRouteAddDel(ctx context.Context, in *BierRouteAddDel) (*BierRouteAddDelReply, error)
24 BierRouteDump(ctx context.Context, in *BierRouteDump) (RPCService_BierRouteDumpClient, error)
25 BierTableAddDel(ctx context.Context, in *BierTableAddDel) (*BierTableAddDelReply, error)
26 BierTableDump(ctx context.Context, in *BierTableDump) (RPCService_BierTableDumpClient, error)
29 type serviceClient struct {
33 func NewServiceClient(conn api.Connection) RPCService {
34 return &serviceClient{conn}
37 func (c *serviceClient) BierDispEntryAddDel(ctx context.Context, in *BierDispEntryAddDel) (*BierDispEntryAddDelReply, error) {
38 out := new(BierDispEntryAddDelReply)
39 err := c.conn.Invoke(ctx, in, out)
43 return out, api.RetvalToVPPApiError(out.Retval)
46 func (c *serviceClient) BierDispEntryDump(ctx context.Context, in *BierDispEntryDump) (RPCService_BierDispEntryDumpClient, error) {
47 stream, err := c.conn.NewStream(ctx)
51 x := &serviceClient_BierDispEntryDumpClient{stream}
52 if err := x.Stream.SendMsg(in); err != nil {
55 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
61 type RPCService_BierDispEntryDumpClient interface {
62 Recv() (*BierDispEntryDetails, error)
66 type serviceClient_BierDispEntryDumpClient struct {
70 func (c *serviceClient_BierDispEntryDumpClient) Recv() (*BierDispEntryDetails, error) {
71 msg, err := c.Stream.RecvMsg()
75 switch m := msg.(type) {
76 case *BierDispEntryDetails:
78 case *vpe.ControlPingReply:
79 err = c.Stream.Close()
85 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
89 func (c *serviceClient) BierDispTableAddDel(ctx context.Context, in *BierDispTableAddDel) (*BierDispTableAddDelReply, error) {
90 out := new(BierDispTableAddDelReply)
91 err := c.conn.Invoke(ctx, in, out)
95 return out, api.RetvalToVPPApiError(out.Retval)
98 func (c *serviceClient) BierDispTableDump(ctx context.Context, in *BierDispTableDump) (RPCService_BierDispTableDumpClient, error) {
99 stream, err := c.conn.NewStream(ctx)
103 x := &serviceClient_BierDispTableDumpClient{stream}
104 if err := x.Stream.SendMsg(in); err != nil {
107 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
113 type RPCService_BierDispTableDumpClient interface {
114 Recv() (*BierDispTableDetails, error)
118 type serviceClient_BierDispTableDumpClient struct {
122 func (c *serviceClient_BierDispTableDumpClient) Recv() (*BierDispTableDetails, error) {
123 msg, err := c.Stream.RecvMsg()
127 switch m := msg.(type) {
128 case *BierDispTableDetails:
130 case *vpe.ControlPingReply:
131 err = c.Stream.Close()
137 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
141 func (c *serviceClient) BierImpAdd(ctx context.Context, in *BierImpAdd) (*BierImpAddReply, error) {
142 out := new(BierImpAddReply)
143 err := c.conn.Invoke(ctx, in, out)
147 return out, api.RetvalToVPPApiError(out.Retval)
150 func (c *serviceClient) BierImpDel(ctx context.Context, in *BierImpDel) (*BierImpDelReply, error) {
151 out := new(BierImpDelReply)
152 err := c.conn.Invoke(ctx, in, out)
156 return out, api.RetvalToVPPApiError(out.Retval)
159 func (c *serviceClient) BierImpDump(ctx context.Context, in *BierImpDump) (RPCService_BierImpDumpClient, error) {
160 stream, err := c.conn.NewStream(ctx)
164 x := &serviceClient_BierImpDumpClient{stream}
165 if err := x.Stream.SendMsg(in); err != nil {
168 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
174 type RPCService_BierImpDumpClient interface {
175 Recv() (*BierImpDetails, error)
179 type serviceClient_BierImpDumpClient struct {
183 func (c *serviceClient_BierImpDumpClient) Recv() (*BierImpDetails, error) {
184 msg, err := c.Stream.RecvMsg()
188 switch m := msg.(type) {
189 case *BierImpDetails:
191 case *vpe.ControlPingReply:
192 err = c.Stream.Close()
198 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
202 func (c *serviceClient) BierRouteAddDel(ctx context.Context, in *BierRouteAddDel) (*BierRouteAddDelReply, error) {
203 out := new(BierRouteAddDelReply)
204 err := c.conn.Invoke(ctx, in, out)
208 return out, api.RetvalToVPPApiError(out.Retval)
211 func (c *serviceClient) BierRouteDump(ctx context.Context, in *BierRouteDump) (RPCService_BierRouteDumpClient, error) {
212 stream, err := c.conn.NewStream(ctx)
216 x := &serviceClient_BierRouteDumpClient{stream}
217 if err := x.Stream.SendMsg(in); err != nil {
220 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
226 type RPCService_BierRouteDumpClient interface {
227 Recv() (*BierRouteDetails, error)
231 type serviceClient_BierRouteDumpClient struct {
235 func (c *serviceClient_BierRouteDumpClient) Recv() (*BierRouteDetails, error) {
236 msg, err := c.Stream.RecvMsg()
240 switch m := msg.(type) {
241 case *BierRouteDetails:
243 case *vpe.ControlPingReply:
244 err = c.Stream.Close()
250 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
254 func (c *serviceClient) BierTableAddDel(ctx context.Context, in *BierTableAddDel) (*BierTableAddDelReply, error) {
255 out := new(BierTableAddDelReply)
256 err := c.conn.Invoke(ctx, in, out)
260 return out, api.RetvalToVPPApiError(out.Retval)
263 func (c *serviceClient) BierTableDump(ctx context.Context, in *BierTableDump) (RPCService_BierTableDumpClient, error) {
264 stream, err := c.conn.NewStream(ctx)
268 x := &serviceClient_BierTableDumpClient{stream}
269 if err := x.Stream.SendMsg(in); err != nil {
272 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
278 type RPCService_BierTableDumpClient interface {
279 Recv() (*BierTableDetails, error)
283 type serviceClient_BierTableDumpClient struct {
287 func (c *serviceClient_BierTableDumpClient) Recv() (*BierTableDetails, error) {
288 msg, err := c.Stream.RecvMsg()
292 switch m := msg.(type) {
293 case *BierTableDetails:
295 case *vpe.ControlPingReply:
296 err = c.Stream.Close()
302 return nil, fmt.Errorf("unexpected message: %T %v", m, m)