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 igmp.
14 type RPCService interface {
15 IgmpClearInterface(ctx context.Context, in *IgmpClearInterface) (*IgmpClearInterfaceReply, error)
16 IgmpDump(ctx context.Context, in *IgmpDump) (RPCService_IgmpDumpClient, error)
17 IgmpEnableDisable(ctx context.Context, in *IgmpEnableDisable) (*IgmpEnableDisableReply, error)
18 IgmpGroupPrefixDump(ctx context.Context, in *IgmpGroupPrefixDump) (RPCService_IgmpGroupPrefixDumpClient, error)
19 IgmpGroupPrefixSet(ctx context.Context, in *IgmpGroupPrefixSet) (*IgmpGroupPrefixSetReply, error)
20 IgmpListen(ctx context.Context, in *IgmpListen) (*IgmpListenReply, error)
21 IgmpProxyDeviceAddDel(ctx context.Context, in *IgmpProxyDeviceAddDel) (*IgmpProxyDeviceAddDelReply, error)
22 IgmpProxyDeviceAddDelInterface(ctx context.Context, in *IgmpProxyDeviceAddDelInterface) (*IgmpProxyDeviceAddDelInterfaceReply, error)
23 WantIgmpEvents(ctx context.Context, in *WantIgmpEvents) (*WantIgmpEventsReply, error)
26 type serviceClient struct {
30 func NewServiceClient(conn api.Connection) RPCService {
31 return &serviceClient{conn}
34 func (c *serviceClient) IgmpClearInterface(ctx context.Context, in *IgmpClearInterface) (*IgmpClearInterfaceReply, error) {
35 out := new(IgmpClearInterfaceReply)
36 err := c.conn.Invoke(ctx, in, out)
43 func (c *serviceClient) IgmpDump(ctx context.Context, in *IgmpDump) (RPCService_IgmpDumpClient, error) {
44 stream, err := c.conn.NewStream(ctx)
48 x := &serviceClient_IgmpDumpClient{stream}
49 if err := x.Stream.SendMsg(in); err != nil {
52 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
58 type RPCService_IgmpDumpClient interface {
59 Recv() (*IgmpDetails, error)
63 type serviceClient_IgmpDumpClient struct {
67 func (c *serviceClient_IgmpDumpClient) Recv() (*IgmpDetails, error) {
68 msg, err := c.Stream.RecvMsg()
72 switch m := msg.(type) {
75 case *vpe.ControlPingReply:
78 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
82 func (c *serviceClient) IgmpEnableDisable(ctx context.Context, in *IgmpEnableDisable) (*IgmpEnableDisableReply, error) {
83 out := new(IgmpEnableDisableReply)
84 err := c.conn.Invoke(ctx, in, out)
91 func (c *serviceClient) IgmpGroupPrefixDump(ctx context.Context, in *IgmpGroupPrefixDump) (RPCService_IgmpGroupPrefixDumpClient, error) {
92 stream, err := c.conn.NewStream(ctx)
96 x := &serviceClient_IgmpGroupPrefixDumpClient{stream}
97 if err := x.Stream.SendMsg(in); err != nil {
100 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
106 type RPCService_IgmpGroupPrefixDumpClient interface {
107 Recv() (*IgmpGroupPrefixDetails, error)
111 type serviceClient_IgmpGroupPrefixDumpClient struct {
115 func (c *serviceClient_IgmpGroupPrefixDumpClient) Recv() (*IgmpGroupPrefixDetails, error) {
116 msg, err := c.Stream.RecvMsg()
120 switch m := msg.(type) {
121 case *IgmpGroupPrefixDetails:
123 case *vpe.ControlPingReply:
126 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
130 func (c *serviceClient) IgmpGroupPrefixSet(ctx context.Context, in *IgmpGroupPrefixSet) (*IgmpGroupPrefixSetReply, error) {
131 out := new(IgmpGroupPrefixSetReply)
132 err := c.conn.Invoke(ctx, in, out)
139 func (c *serviceClient) IgmpListen(ctx context.Context, in *IgmpListen) (*IgmpListenReply, error) {
140 out := new(IgmpListenReply)
141 err := c.conn.Invoke(ctx, in, out)
148 func (c *serviceClient) IgmpProxyDeviceAddDel(ctx context.Context, in *IgmpProxyDeviceAddDel) (*IgmpProxyDeviceAddDelReply, error) {
149 out := new(IgmpProxyDeviceAddDelReply)
150 err := c.conn.Invoke(ctx, in, out)
157 func (c *serviceClient) IgmpProxyDeviceAddDelInterface(ctx context.Context, in *IgmpProxyDeviceAddDelInterface) (*IgmpProxyDeviceAddDelInterfaceReply, error) {
158 out := new(IgmpProxyDeviceAddDelInterfaceReply)
159 err := c.conn.Invoke(ctx, in, out)
166 func (c *serviceClient) WantIgmpEvents(ctx context.Context, in *WantIgmpEvents) (*WantIgmpEventsReply, error) {
167 out := new(WantIgmpEventsReply)
168 err := c.conn.Invoke(ctx, in, out)