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 lb.
15 type RPCService interface {
16 LbAddDelAs(ctx context.Context, in *LbAddDelAs) (*LbAddDelAsReply, error)
17 LbAddDelIntfNat4(ctx context.Context, in *LbAddDelIntfNat4) (*LbAddDelIntfNat4Reply, error)
18 LbAddDelIntfNat6(ctx context.Context, in *LbAddDelIntfNat6) (*LbAddDelIntfNat6Reply, error)
19 LbAddDelVip(ctx context.Context, in *LbAddDelVip) (*LbAddDelVipReply, error)
20 LbAsDump(ctx context.Context, in *LbAsDump) (RPCService_LbAsDumpClient, error)
21 LbConf(ctx context.Context, in *LbConf) (*LbConfReply, error)
22 LbFlushVip(ctx context.Context, in *LbFlushVip) (*LbFlushVipReply, error)
23 LbVipDump(ctx context.Context, in *LbVipDump) (RPCService_LbVipDumpClient, error)
26 type serviceClient struct {
30 func NewServiceClient(conn api.Connection) RPCService {
31 return &serviceClient{conn}
34 func (c *serviceClient) LbAddDelAs(ctx context.Context, in *LbAddDelAs) (*LbAddDelAsReply, error) {
35 out := new(LbAddDelAsReply)
36 err := c.conn.Invoke(ctx, in, out)
40 return out, api.RetvalToVPPApiError(out.Retval)
43 func (c *serviceClient) LbAddDelIntfNat4(ctx context.Context, in *LbAddDelIntfNat4) (*LbAddDelIntfNat4Reply, error) {
44 out := new(LbAddDelIntfNat4Reply)
45 err := c.conn.Invoke(ctx, in, out)
49 return out, api.RetvalToVPPApiError(out.Retval)
52 func (c *serviceClient) LbAddDelIntfNat6(ctx context.Context, in *LbAddDelIntfNat6) (*LbAddDelIntfNat6Reply, error) {
53 out := new(LbAddDelIntfNat6Reply)
54 err := c.conn.Invoke(ctx, in, out)
58 return out, api.RetvalToVPPApiError(out.Retval)
61 func (c *serviceClient) LbAddDelVip(ctx context.Context, in *LbAddDelVip) (*LbAddDelVipReply, error) {
62 out := new(LbAddDelVipReply)
63 err := c.conn.Invoke(ctx, in, out)
67 return out, api.RetvalToVPPApiError(out.Retval)
70 func (c *serviceClient) LbAsDump(ctx context.Context, in *LbAsDump) (RPCService_LbAsDumpClient, error) {
71 stream, err := c.conn.NewStream(ctx)
75 x := &serviceClient_LbAsDumpClient{stream}
76 if err := x.Stream.SendMsg(in); err != nil {
79 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
85 type RPCService_LbAsDumpClient interface {
86 Recv() (*LbAsDetails, error)
90 type serviceClient_LbAsDumpClient struct {
94 func (c *serviceClient_LbAsDumpClient) Recv() (*LbAsDetails, error) {
95 msg, err := c.Stream.RecvMsg()
99 switch m := msg.(type) {
102 case *vpe.ControlPingReply:
103 err = c.Stream.Close()
109 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
113 func (c *serviceClient) LbConf(ctx context.Context, in *LbConf) (*LbConfReply, error) {
114 out := new(LbConfReply)
115 err := c.conn.Invoke(ctx, in, out)
119 return out, api.RetvalToVPPApiError(out.Retval)
122 func (c *serviceClient) LbFlushVip(ctx context.Context, in *LbFlushVip) (*LbFlushVipReply, error) {
123 out := new(LbFlushVipReply)
124 err := c.conn.Invoke(ctx, in, out)
128 return out, api.RetvalToVPPApiError(out.Retval)
131 func (c *serviceClient) LbVipDump(ctx context.Context, in *LbVipDump) (RPCService_LbVipDumpClient, error) {
132 stream, err := c.conn.NewStream(ctx)
136 x := &serviceClient_LbVipDumpClient{stream}
137 if err := x.Stream.SendMsg(in); err != nil {
140 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
146 type RPCService_LbVipDumpClient interface {
147 Recv() (*LbVipDetails, error)
151 type serviceClient_LbVipDumpClient struct {
155 func (c *serviceClient_LbVipDumpClient) Recv() (*LbVipDetails, error) {
156 msg, err := c.Stream.RecvMsg()
160 switch m := msg.(type) {
163 case *vpe.ControlPingReply:
164 err = c.Stream.Close()
170 return nil, fmt.Errorf("unexpected message: %T %v", m, m)