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 gbp.
15 type RPCService interface {
16 GbpBridgeDomainAdd(ctx context.Context, in *GbpBridgeDomainAdd) (*GbpBridgeDomainAddReply, error)
17 GbpBridgeDomainDel(ctx context.Context, in *GbpBridgeDomainDel) (*GbpBridgeDomainDelReply, error)
18 GbpBridgeDomainDump(ctx context.Context, in *GbpBridgeDomainDump) (RPCService_GbpBridgeDomainDumpClient, error)
19 GbpContractAddDel(ctx context.Context, in *GbpContractAddDel) (*GbpContractAddDelReply, error)
20 GbpContractDump(ctx context.Context, in *GbpContractDump) (RPCService_GbpContractDumpClient, error)
21 GbpEndpointAdd(ctx context.Context, in *GbpEndpointAdd) (*GbpEndpointAddReply, error)
22 GbpEndpointDel(ctx context.Context, in *GbpEndpointDel) (*GbpEndpointDelReply, error)
23 GbpEndpointDump(ctx context.Context, in *GbpEndpointDump) (RPCService_GbpEndpointDumpClient, error)
24 GbpEndpointGroupAdd(ctx context.Context, in *GbpEndpointGroupAdd) (*GbpEndpointGroupAddReply, error)
25 GbpEndpointGroupDel(ctx context.Context, in *GbpEndpointGroupDel) (*GbpEndpointGroupDelReply, error)
26 GbpEndpointGroupDump(ctx context.Context, in *GbpEndpointGroupDump) (RPCService_GbpEndpointGroupDumpClient, error)
27 GbpExtItfAddDel(ctx context.Context, in *GbpExtItfAddDel) (*GbpExtItfAddDelReply, error)
28 GbpExtItfDump(ctx context.Context, in *GbpExtItfDump) (RPCService_GbpExtItfDumpClient, error)
29 GbpRecircAddDel(ctx context.Context, in *GbpRecircAddDel) (*GbpRecircAddDelReply, error)
30 GbpRecircDump(ctx context.Context, in *GbpRecircDump) (RPCService_GbpRecircDumpClient, error)
31 GbpRouteDomainAdd(ctx context.Context, in *GbpRouteDomainAdd) (*GbpRouteDomainAddReply, error)
32 GbpRouteDomainDel(ctx context.Context, in *GbpRouteDomainDel) (*GbpRouteDomainDelReply, error)
33 GbpRouteDomainDump(ctx context.Context, in *GbpRouteDomainDump) (RPCService_GbpRouteDomainDumpClient, error)
34 GbpSubnetAddDel(ctx context.Context, in *GbpSubnetAddDel) (*GbpSubnetAddDelReply, error)
35 GbpSubnetDump(ctx context.Context, in *GbpSubnetDump) (RPCService_GbpSubnetDumpClient, error)
36 GbpVxlanTunnelAdd(ctx context.Context, in *GbpVxlanTunnelAdd) (*GbpVxlanTunnelAddReply, error)
37 GbpVxlanTunnelDel(ctx context.Context, in *GbpVxlanTunnelDel) (*GbpVxlanTunnelDelReply, error)
38 GbpVxlanTunnelDump(ctx context.Context, in *GbpVxlanTunnelDump) (RPCService_GbpVxlanTunnelDumpClient, error)
41 type serviceClient struct {
45 func NewServiceClient(conn api.Connection) RPCService {
46 return &serviceClient{conn}
49 func (c *serviceClient) GbpBridgeDomainAdd(ctx context.Context, in *GbpBridgeDomainAdd) (*GbpBridgeDomainAddReply, error) {
50 out := new(GbpBridgeDomainAddReply)
51 err := c.conn.Invoke(ctx, in, out)
55 return out, api.RetvalToVPPApiError(out.Retval)
58 func (c *serviceClient) GbpBridgeDomainDel(ctx context.Context, in *GbpBridgeDomainDel) (*GbpBridgeDomainDelReply, error) {
59 out := new(GbpBridgeDomainDelReply)
60 err := c.conn.Invoke(ctx, in, out)
64 return out, api.RetvalToVPPApiError(out.Retval)
67 func (c *serviceClient) GbpBridgeDomainDump(ctx context.Context, in *GbpBridgeDomainDump) (RPCService_GbpBridgeDomainDumpClient, error) {
68 stream, err := c.conn.NewStream(ctx)
72 x := &serviceClient_GbpBridgeDomainDumpClient{stream}
73 if err := x.Stream.SendMsg(in); err != nil {
76 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
82 type RPCService_GbpBridgeDomainDumpClient interface {
83 Recv() (*GbpBridgeDomainDetails, error)
87 type serviceClient_GbpBridgeDomainDumpClient struct {
91 func (c *serviceClient_GbpBridgeDomainDumpClient) Recv() (*GbpBridgeDomainDetails, error) {
92 msg, err := c.Stream.RecvMsg()
96 switch m := msg.(type) {
97 case *GbpBridgeDomainDetails:
99 case *vpe.ControlPingReply:
100 err = c.Stream.Close()
106 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
110 func (c *serviceClient) GbpContractAddDel(ctx context.Context, in *GbpContractAddDel) (*GbpContractAddDelReply, error) {
111 out := new(GbpContractAddDelReply)
112 err := c.conn.Invoke(ctx, in, out)
116 return out, api.RetvalToVPPApiError(out.Retval)
119 func (c *serviceClient) GbpContractDump(ctx context.Context, in *GbpContractDump) (RPCService_GbpContractDumpClient, error) {
120 stream, err := c.conn.NewStream(ctx)
124 x := &serviceClient_GbpContractDumpClient{stream}
125 if err := x.Stream.SendMsg(in); err != nil {
128 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
134 type RPCService_GbpContractDumpClient interface {
135 Recv() (*GbpContractDetails, error)
139 type serviceClient_GbpContractDumpClient struct {
143 func (c *serviceClient_GbpContractDumpClient) Recv() (*GbpContractDetails, error) {
144 msg, err := c.Stream.RecvMsg()
148 switch m := msg.(type) {
149 case *GbpContractDetails:
151 case *vpe.ControlPingReply:
152 err = c.Stream.Close()
158 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
162 func (c *serviceClient) GbpEndpointAdd(ctx context.Context, in *GbpEndpointAdd) (*GbpEndpointAddReply, error) {
163 out := new(GbpEndpointAddReply)
164 err := c.conn.Invoke(ctx, in, out)
168 return out, api.RetvalToVPPApiError(out.Retval)
171 func (c *serviceClient) GbpEndpointDel(ctx context.Context, in *GbpEndpointDel) (*GbpEndpointDelReply, error) {
172 out := new(GbpEndpointDelReply)
173 err := c.conn.Invoke(ctx, in, out)
177 return out, api.RetvalToVPPApiError(out.Retval)
180 func (c *serviceClient) GbpEndpointDump(ctx context.Context, in *GbpEndpointDump) (RPCService_GbpEndpointDumpClient, error) {
181 stream, err := c.conn.NewStream(ctx)
185 x := &serviceClient_GbpEndpointDumpClient{stream}
186 if err := x.Stream.SendMsg(in); err != nil {
189 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
195 type RPCService_GbpEndpointDumpClient interface {
196 Recv() (*GbpEndpointDetails, error)
200 type serviceClient_GbpEndpointDumpClient struct {
204 func (c *serviceClient_GbpEndpointDumpClient) Recv() (*GbpEndpointDetails, error) {
205 msg, err := c.Stream.RecvMsg()
209 switch m := msg.(type) {
210 case *GbpEndpointDetails:
212 case *vpe.ControlPingReply:
213 err = c.Stream.Close()
219 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
223 func (c *serviceClient) GbpEndpointGroupAdd(ctx context.Context, in *GbpEndpointGroupAdd) (*GbpEndpointGroupAddReply, error) {
224 out := new(GbpEndpointGroupAddReply)
225 err := c.conn.Invoke(ctx, in, out)
229 return out, api.RetvalToVPPApiError(out.Retval)
232 func (c *serviceClient) GbpEndpointGroupDel(ctx context.Context, in *GbpEndpointGroupDel) (*GbpEndpointGroupDelReply, error) {
233 out := new(GbpEndpointGroupDelReply)
234 err := c.conn.Invoke(ctx, in, out)
238 return out, api.RetvalToVPPApiError(out.Retval)
241 func (c *serviceClient) GbpEndpointGroupDump(ctx context.Context, in *GbpEndpointGroupDump) (RPCService_GbpEndpointGroupDumpClient, error) {
242 stream, err := c.conn.NewStream(ctx)
246 x := &serviceClient_GbpEndpointGroupDumpClient{stream}
247 if err := x.Stream.SendMsg(in); err != nil {
250 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
256 type RPCService_GbpEndpointGroupDumpClient interface {
257 Recv() (*GbpEndpointGroupDetails, error)
261 type serviceClient_GbpEndpointGroupDumpClient struct {
265 func (c *serviceClient_GbpEndpointGroupDumpClient) Recv() (*GbpEndpointGroupDetails, error) {
266 msg, err := c.Stream.RecvMsg()
270 switch m := msg.(type) {
271 case *GbpEndpointGroupDetails:
273 case *vpe.ControlPingReply:
274 err = c.Stream.Close()
280 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
284 func (c *serviceClient) GbpExtItfAddDel(ctx context.Context, in *GbpExtItfAddDel) (*GbpExtItfAddDelReply, error) {
285 out := new(GbpExtItfAddDelReply)
286 err := c.conn.Invoke(ctx, in, out)
290 return out, api.RetvalToVPPApiError(out.Retval)
293 func (c *serviceClient) GbpExtItfDump(ctx context.Context, in *GbpExtItfDump) (RPCService_GbpExtItfDumpClient, error) {
294 stream, err := c.conn.NewStream(ctx)
298 x := &serviceClient_GbpExtItfDumpClient{stream}
299 if err := x.Stream.SendMsg(in); err != nil {
302 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
308 type RPCService_GbpExtItfDumpClient interface {
309 Recv() (*GbpExtItfDetails, error)
313 type serviceClient_GbpExtItfDumpClient struct {
317 func (c *serviceClient_GbpExtItfDumpClient) Recv() (*GbpExtItfDetails, error) {
318 msg, err := c.Stream.RecvMsg()
322 switch m := msg.(type) {
323 case *GbpExtItfDetails:
325 case *vpe.ControlPingReply:
326 err = c.Stream.Close()
332 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
336 func (c *serviceClient) GbpRecircAddDel(ctx context.Context, in *GbpRecircAddDel) (*GbpRecircAddDelReply, error) {
337 out := new(GbpRecircAddDelReply)
338 err := c.conn.Invoke(ctx, in, out)
342 return out, api.RetvalToVPPApiError(out.Retval)
345 func (c *serviceClient) GbpRecircDump(ctx context.Context, in *GbpRecircDump) (RPCService_GbpRecircDumpClient, error) {
346 stream, err := c.conn.NewStream(ctx)
350 x := &serviceClient_GbpRecircDumpClient{stream}
351 if err := x.Stream.SendMsg(in); err != nil {
354 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
360 type RPCService_GbpRecircDumpClient interface {
361 Recv() (*GbpRecircDetails, error)
365 type serviceClient_GbpRecircDumpClient struct {
369 func (c *serviceClient_GbpRecircDumpClient) Recv() (*GbpRecircDetails, error) {
370 msg, err := c.Stream.RecvMsg()
374 switch m := msg.(type) {
375 case *GbpRecircDetails:
377 case *vpe.ControlPingReply:
378 err = c.Stream.Close()
384 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
388 func (c *serviceClient) GbpRouteDomainAdd(ctx context.Context, in *GbpRouteDomainAdd) (*GbpRouteDomainAddReply, error) {
389 out := new(GbpRouteDomainAddReply)
390 err := c.conn.Invoke(ctx, in, out)
394 return out, api.RetvalToVPPApiError(out.Retval)
397 func (c *serviceClient) GbpRouteDomainDel(ctx context.Context, in *GbpRouteDomainDel) (*GbpRouteDomainDelReply, error) {
398 out := new(GbpRouteDomainDelReply)
399 err := c.conn.Invoke(ctx, in, out)
403 return out, api.RetvalToVPPApiError(out.Retval)
406 func (c *serviceClient) GbpRouteDomainDump(ctx context.Context, in *GbpRouteDomainDump) (RPCService_GbpRouteDomainDumpClient, error) {
407 stream, err := c.conn.NewStream(ctx)
411 x := &serviceClient_GbpRouteDomainDumpClient{stream}
412 if err := x.Stream.SendMsg(in); err != nil {
415 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
421 type RPCService_GbpRouteDomainDumpClient interface {
422 Recv() (*GbpRouteDomainDetails, error)
426 type serviceClient_GbpRouteDomainDumpClient struct {
430 func (c *serviceClient_GbpRouteDomainDumpClient) Recv() (*GbpRouteDomainDetails, error) {
431 msg, err := c.Stream.RecvMsg()
435 switch m := msg.(type) {
436 case *GbpRouteDomainDetails:
438 case *vpe.ControlPingReply:
439 err = c.Stream.Close()
445 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
449 func (c *serviceClient) GbpSubnetAddDel(ctx context.Context, in *GbpSubnetAddDel) (*GbpSubnetAddDelReply, error) {
450 out := new(GbpSubnetAddDelReply)
451 err := c.conn.Invoke(ctx, in, out)
455 return out, api.RetvalToVPPApiError(out.Retval)
458 func (c *serviceClient) GbpSubnetDump(ctx context.Context, in *GbpSubnetDump) (RPCService_GbpSubnetDumpClient, error) {
459 stream, err := c.conn.NewStream(ctx)
463 x := &serviceClient_GbpSubnetDumpClient{stream}
464 if err := x.Stream.SendMsg(in); err != nil {
467 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
473 type RPCService_GbpSubnetDumpClient interface {
474 Recv() (*GbpSubnetDetails, error)
478 type serviceClient_GbpSubnetDumpClient struct {
482 func (c *serviceClient_GbpSubnetDumpClient) Recv() (*GbpSubnetDetails, error) {
483 msg, err := c.Stream.RecvMsg()
487 switch m := msg.(type) {
488 case *GbpSubnetDetails:
490 case *vpe.ControlPingReply:
491 err = c.Stream.Close()
497 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
501 func (c *serviceClient) GbpVxlanTunnelAdd(ctx context.Context, in *GbpVxlanTunnelAdd) (*GbpVxlanTunnelAddReply, error) {
502 out := new(GbpVxlanTunnelAddReply)
503 err := c.conn.Invoke(ctx, in, out)
507 return out, api.RetvalToVPPApiError(out.Retval)
510 func (c *serviceClient) GbpVxlanTunnelDel(ctx context.Context, in *GbpVxlanTunnelDel) (*GbpVxlanTunnelDelReply, error) {
511 out := new(GbpVxlanTunnelDelReply)
512 err := c.conn.Invoke(ctx, in, out)
516 return out, api.RetvalToVPPApiError(out.Retval)
519 func (c *serviceClient) GbpVxlanTunnelDump(ctx context.Context, in *GbpVxlanTunnelDump) (RPCService_GbpVxlanTunnelDumpClient, error) {
520 stream, err := c.conn.NewStream(ctx)
524 x := &serviceClient_GbpVxlanTunnelDumpClient{stream}
525 if err := x.Stream.SendMsg(in); err != nil {
528 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
534 type RPCService_GbpVxlanTunnelDumpClient interface {
535 Recv() (*GbpVxlanTunnelDetails, error)
539 type serviceClient_GbpVxlanTunnelDumpClient struct {
543 func (c *serviceClient_GbpVxlanTunnelDumpClient) Recv() (*GbpVxlanTunnelDetails, error) {
544 msg, err := c.Stream.RecvMsg()
548 switch m := msg.(type) {
549 case *GbpVxlanTunnelDetails:
551 case *vpe.ControlPingReply:
552 err = c.Stream.Close()
558 return nil, fmt.Errorf("unexpected message: %T %v", m, m)