1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
8 api "git.fd.io/govpp.git/api"
9 vpe "git.fd.io/govpp.git/binapi/vpe"
13 // RPCService defines RPC service memif.
14 type RPCService interface {
15 MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error)
16 MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error)
17 MemifDump(ctx context.Context, in *MemifDump) (RPCService_MemifDumpClient, error)
18 MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error)
19 MemifSocketFilenameDump(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_MemifSocketFilenameDumpClient, error)
22 type serviceClient struct {
26 func NewServiceClient(conn api.Connection) RPCService {
27 return &serviceClient{conn}
30 func (c *serviceClient) MemifCreate(ctx context.Context, in *MemifCreate) (*MemifCreateReply, error) {
31 out := new(MemifCreateReply)
32 err := c.conn.Invoke(ctx, in, out)
39 func (c *serviceClient) MemifDelete(ctx context.Context, in *MemifDelete) (*MemifDeleteReply, error) {
40 out := new(MemifDeleteReply)
41 err := c.conn.Invoke(ctx, in, out)
48 func (c *serviceClient) MemifDump(ctx context.Context, in *MemifDump) (RPCService_MemifDumpClient, error) {
49 stream, err := c.conn.NewStream(ctx)
53 x := &serviceClient_MemifDumpClient{stream}
54 if err := x.Stream.SendMsg(in); err != nil {
57 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
63 type RPCService_MemifDumpClient interface {
64 Recv() (*MemifDetails, error)
68 type serviceClient_MemifDumpClient struct {
72 func (c *serviceClient_MemifDumpClient) Recv() (*MemifDetails, error) {
73 msg, err := c.Stream.RecvMsg()
77 switch m := msg.(type) {
80 case *vpe.ControlPingReply:
83 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
87 func (c *serviceClient) MemifSocketFilenameAddDel(ctx context.Context, in *MemifSocketFilenameAddDel) (*MemifSocketFilenameAddDelReply, error) {
88 out := new(MemifSocketFilenameAddDelReply)
89 err := c.conn.Invoke(ctx, in, out)
96 func (c *serviceClient) MemifSocketFilenameDump(ctx context.Context, in *MemifSocketFilenameDump) (RPCService_MemifSocketFilenameDumpClient, error) {
97 stream, err := c.conn.NewStream(ctx)
101 x := &serviceClient_MemifSocketFilenameDumpClient{stream}
102 if err := x.Stream.SendMsg(in); err != nil {
105 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
111 type RPCService_MemifSocketFilenameDumpClient interface {
112 Recv() (*MemifSocketFilenameDetails, error)
116 type serviceClient_MemifSocketFilenameDumpClient struct {
120 func (c *serviceClient_MemifSocketFilenameDumpClient) Recv() (*MemifSocketFilenameDetails, error) {
121 msg, err := c.Stream.RecvMsg()
125 switch m := msg.(type) {
126 case *MemifSocketFilenameDetails:
128 case *vpe.ControlPingReply:
131 return nil, fmt.Errorf("unexpected message: %T %v", m, m)