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 arp.
14 type RPCService interface {
15 ProxyArpAddDel(ctx context.Context, in *ProxyArpAddDel) (*ProxyArpAddDelReply, error)
16 ProxyArpDump(ctx context.Context, in *ProxyArpDump) (RPCService_ProxyArpDumpClient, error)
17 ProxyArpIntfcDump(ctx context.Context, in *ProxyArpIntfcDump) (RPCService_ProxyArpIntfcDumpClient, error)
18 ProxyArpIntfcEnableDisable(ctx context.Context, in *ProxyArpIntfcEnableDisable) (*ProxyArpIntfcEnableDisableReply, error)
21 type serviceClient struct {
25 func NewServiceClient(conn api.Connection) RPCService {
26 return &serviceClient{conn}
29 func (c *serviceClient) ProxyArpAddDel(ctx context.Context, in *ProxyArpAddDel) (*ProxyArpAddDelReply, error) {
30 out := new(ProxyArpAddDelReply)
31 err := c.conn.Invoke(ctx, in, out)
38 func (c *serviceClient) ProxyArpDump(ctx context.Context, in *ProxyArpDump) (RPCService_ProxyArpDumpClient, error) {
39 stream, err := c.conn.NewStream(ctx)
43 x := &serviceClient_ProxyArpDumpClient{stream}
44 if err := x.Stream.SendMsg(in); err != nil {
47 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
53 type RPCService_ProxyArpDumpClient interface {
54 Recv() (*ProxyArpDetails, error)
58 type serviceClient_ProxyArpDumpClient struct {
62 func (c *serviceClient_ProxyArpDumpClient) Recv() (*ProxyArpDetails, error) {
63 msg, err := c.Stream.RecvMsg()
67 switch m := msg.(type) {
68 case *ProxyArpDetails:
70 case *vpe.ControlPingReply:
73 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
77 func (c *serviceClient) ProxyArpIntfcDump(ctx context.Context, in *ProxyArpIntfcDump) (RPCService_ProxyArpIntfcDumpClient, error) {
78 stream, err := c.conn.NewStream(ctx)
82 x := &serviceClient_ProxyArpIntfcDumpClient{stream}
83 if err := x.Stream.SendMsg(in); err != nil {
86 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
92 type RPCService_ProxyArpIntfcDumpClient interface {
93 Recv() (*ProxyArpIntfcDetails, error)
97 type serviceClient_ProxyArpIntfcDumpClient struct {
101 func (c *serviceClient_ProxyArpIntfcDumpClient) Recv() (*ProxyArpIntfcDetails, error) {
102 msg, err := c.Stream.RecvMsg()
106 switch m := msg.(type) {
107 case *ProxyArpIntfcDetails:
109 case *vpe.ControlPingReply:
112 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
116 func (c *serviceClient) ProxyArpIntfcEnableDisable(ctx context.Context, in *ProxyArpIntfcEnableDisable) (*ProxyArpIntfcEnableDisableReply, error) {
117 out := new(ProxyArpIntfcEnableDisableReply)
118 err := c.conn.Invoke(ctx, in, out)