1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "go.fd.io/govpp/api"
11 memclnt "go.fd.io/govpp/binapi/memclnt"
14 // RPCService defines RPC service af_packet.
15 type RPCService interface {
16 AfPacketCreate(ctx context.Context, in *AfPacketCreate) (*AfPacketCreateReply, error)
17 AfPacketCreateV2(ctx context.Context, in *AfPacketCreateV2) (*AfPacketCreateV2Reply, error)
18 AfPacketDelete(ctx context.Context, in *AfPacketDelete) (*AfPacketDeleteReply, error)
19 AfPacketDump(ctx context.Context, in *AfPacketDump) (RPCService_AfPacketDumpClient, error)
20 AfPacketSetL4CksumOffload(ctx context.Context, in *AfPacketSetL4CksumOffload) (*AfPacketSetL4CksumOffloadReply, error)
23 type serviceClient struct {
27 func NewServiceClient(conn api.Connection) RPCService {
28 return &serviceClient{conn}
31 func (c *serviceClient) AfPacketCreate(ctx context.Context, in *AfPacketCreate) (*AfPacketCreateReply, error) {
32 out := new(AfPacketCreateReply)
33 err := c.conn.Invoke(ctx, in, out)
37 return out, api.RetvalToVPPApiError(out.Retval)
40 func (c *serviceClient) AfPacketCreateV2(ctx context.Context, in *AfPacketCreateV2) (*AfPacketCreateV2Reply, error) {
41 out := new(AfPacketCreateV2Reply)
42 err := c.conn.Invoke(ctx, in, out)
46 return out, api.RetvalToVPPApiError(out.Retval)
49 func (c *serviceClient) AfPacketDelete(ctx context.Context, in *AfPacketDelete) (*AfPacketDeleteReply, error) {
50 out := new(AfPacketDeleteReply)
51 err := c.conn.Invoke(ctx, in, out)
55 return out, api.RetvalToVPPApiError(out.Retval)
58 func (c *serviceClient) AfPacketDump(ctx context.Context, in *AfPacketDump) (RPCService_AfPacketDumpClient, error) {
59 stream, err := c.conn.NewStream(ctx)
63 x := &serviceClient_AfPacketDumpClient{stream}
64 if err := x.Stream.SendMsg(in); err != nil {
67 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
73 type RPCService_AfPacketDumpClient interface {
74 Recv() (*AfPacketDetails, error)
78 type serviceClient_AfPacketDumpClient struct {
82 func (c *serviceClient_AfPacketDumpClient) Recv() (*AfPacketDetails, error) {
83 msg, err := c.Stream.RecvMsg()
87 switch m := msg.(type) {
88 case *AfPacketDetails:
90 case *memclnt.ControlPingReply:
91 err = c.Stream.Close()
97 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
101 func (c *serviceClient) AfPacketSetL4CksumOffload(ctx context.Context, in *AfPacketSetL4CksumOffload) (*AfPacketSetL4CksumOffloadReply, error) {
102 out := new(AfPacketSetL4CksumOffloadReply)
103 err := c.conn.Invoke(ctx, in, out)
107 return out, api.RetvalToVPPApiError(out.Retval)