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:
75 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
79 func (c *serviceClient) AbfPluginGetVersion(ctx context.Context, in *AbfPluginGetVersion) (*AbfPluginGetVersionReply, error) {
80 out := new(AbfPluginGetVersionReply)
81 err := c.conn.Invoke(ctx, in, out)
88 func (c *serviceClient) AbfPolicyAddDel(ctx context.Context, in *AbfPolicyAddDel) (*AbfPolicyAddDelReply, error) {
89 out := new(AbfPolicyAddDelReply)
90 err := c.conn.Invoke(ctx, in, out)
94 return out, api.RetvalToVPPApiError(out.Retval)
97 func (c *serviceClient) AbfPolicyDump(ctx context.Context, in *AbfPolicyDump) (RPCService_AbfPolicyDumpClient, error) {
98 stream, err := c.conn.NewStream(ctx)
102 x := &serviceClient_AbfPolicyDumpClient{stream}
103 if err := x.Stream.SendMsg(in); err != nil {
106 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
112 type RPCService_AbfPolicyDumpClient interface {
113 Recv() (*AbfPolicyDetails, error)
117 type serviceClient_AbfPolicyDumpClient struct {
121 func (c *serviceClient_AbfPolicyDumpClient) Recv() (*AbfPolicyDetails, error) {
122 msg, err := c.Stream.RecvMsg()
126 switch m := msg.(type) {
127 case *AbfPolicyDetails:
129 case *vpe.ControlPingReply:
132 return nil, fmt.Errorf("unexpected message: %T %v", m, m)