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 abf.
15 type RPCService interface {
16 AbfItfAttachAddDel(ctx context.Context, in *AbfItfAttachAddDel) (*AbfItfAttachAddDelReply, error)
17 AbfItfAttachDump(ctx context.Context, in *AbfItfAttachDump) (RPCService_AbfItfAttachDumpClient, error)
18 AbfPluginGetVersion(ctx context.Context, in *AbfPluginGetVersion) (*AbfPluginGetVersionReply, error)
19 AbfPolicyAddDel(ctx context.Context, in *AbfPolicyAddDel) (*AbfPolicyAddDelReply, error)
20 AbfPolicyDump(ctx context.Context, in *AbfPolicyDump) (RPCService_AbfPolicyDumpClient, error)
23 type serviceClient struct {
27 func NewServiceClient(conn api.Connection) RPCService {
28 return &serviceClient{conn}
31 func (c *serviceClient) AbfItfAttachAddDel(ctx context.Context, in *AbfItfAttachAddDel) (*AbfItfAttachAddDelReply, error) {
32 out := new(AbfItfAttachAddDelReply)
33 err := c.conn.Invoke(ctx, in, out)
37 return out, api.RetvalToVPPApiError(out.Retval)
40 func (c *serviceClient) AbfItfAttachDump(ctx context.Context, in *AbfItfAttachDump) (RPCService_AbfItfAttachDumpClient, error) {
41 stream, err := c.conn.NewStream(ctx)
45 x := &serviceClient_AbfItfAttachDumpClient{stream}
46 if err := x.Stream.SendMsg(in); err != nil {
49 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
55 type RPCService_AbfItfAttachDumpClient interface {
56 Recv() (*AbfItfAttachDetails, error)
60 type serviceClient_AbfItfAttachDumpClient struct {
64 func (c *serviceClient_AbfItfAttachDumpClient) Recv() (*AbfItfAttachDetails, error) {
65 msg, err := c.Stream.RecvMsg()
69 switch m := msg.(type) {
70 case *AbfItfAttachDetails:
72 case *vpe.ControlPingReply:
73 err = c.Stream.Close()
79 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
83 func (c *serviceClient) AbfPluginGetVersion(ctx context.Context, in *AbfPluginGetVersion) (*AbfPluginGetVersionReply, error) {
84 out := new(AbfPluginGetVersionReply)
85 err := c.conn.Invoke(ctx, in, out)
92 func (c *serviceClient) AbfPolicyAddDel(ctx context.Context, in *AbfPolicyAddDel) (*AbfPolicyAddDelReply, error) {
93 out := new(AbfPolicyAddDelReply)
94 err := c.conn.Invoke(ctx, in, out)
98 return out, api.RetvalToVPPApiError(out.Retval)
101 func (c *serviceClient) AbfPolicyDump(ctx context.Context, in *AbfPolicyDump) (RPCService_AbfPolicyDumpClient, error) {
102 stream, err := c.conn.NewStream(ctx)
106 x := &serviceClient_AbfPolicyDumpClient{stream}
107 if err := x.Stream.SendMsg(in); err != nil {
110 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
116 type RPCService_AbfPolicyDumpClient interface {
117 Recv() (*AbfPolicyDetails, error)
121 type serviceClient_AbfPolicyDumpClient struct {
125 func (c *serviceClient_AbfPolicyDumpClient) Recv() (*AbfPolicyDetails, error) {
126 msg, err := c.Stream.RecvMsg()
130 switch m := msg.(type) {
131 case *AbfPolicyDetails:
133 case *vpe.ControlPingReply:
134 err = c.Stream.Close()
140 return nil, fmt.Errorf("unexpected message: %T %v", m, m)