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 ipfix_export.
15 type RPCService interface {
16 IpfixClassifyStreamDump(ctx context.Context, in *IpfixClassifyStreamDump) (RPCService_IpfixClassifyStreamDumpClient, error)
17 IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error)
18 IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error)
19 IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error)
20 IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error)
21 SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error)
22 SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error)
25 type serviceClient struct {
29 func NewServiceClient(conn api.Connection) RPCService {
30 return &serviceClient{conn}
33 func (c *serviceClient) IpfixClassifyStreamDump(ctx context.Context, in *IpfixClassifyStreamDump) (RPCService_IpfixClassifyStreamDumpClient, error) {
34 stream, err := c.conn.NewStream(ctx)
38 x := &serviceClient_IpfixClassifyStreamDumpClient{stream}
39 if err := x.Stream.SendMsg(in); err != nil {
42 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
48 type RPCService_IpfixClassifyStreamDumpClient interface {
49 Recv() (*IpfixClassifyStreamDetails, error)
53 type serviceClient_IpfixClassifyStreamDumpClient struct {
57 func (c *serviceClient_IpfixClassifyStreamDumpClient) Recv() (*IpfixClassifyStreamDetails, error) {
58 msg, err := c.Stream.RecvMsg()
62 switch m := msg.(type) {
63 case *IpfixClassifyStreamDetails:
65 case *vpe.ControlPingReply:
66 err = c.Stream.Close()
72 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
76 func (c *serviceClient) IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error) {
77 out := new(IpfixClassifyTableAddDelReply)
78 err := c.conn.Invoke(ctx, in, out)
82 return out, api.RetvalToVPPApiError(out.Retval)
85 func (c *serviceClient) IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error) {
86 stream, err := c.conn.NewStream(ctx)
90 x := &serviceClient_IpfixClassifyTableDumpClient{stream}
91 if err := x.Stream.SendMsg(in); err != nil {
94 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
100 type RPCService_IpfixClassifyTableDumpClient interface {
101 Recv() (*IpfixClassifyTableDetails, error)
105 type serviceClient_IpfixClassifyTableDumpClient struct {
109 func (c *serviceClient_IpfixClassifyTableDumpClient) Recv() (*IpfixClassifyTableDetails, error) {
110 msg, err := c.Stream.RecvMsg()
114 switch m := msg.(type) {
115 case *IpfixClassifyTableDetails:
117 case *vpe.ControlPingReply:
118 err = c.Stream.Close()
124 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
128 func (c *serviceClient) IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error) {
129 stream, err := c.conn.NewStream(ctx)
133 x := &serviceClient_IpfixExporterDumpClient{stream}
134 if err := x.Stream.SendMsg(in); err != nil {
137 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
143 type RPCService_IpfixExporterDumpClient interface {
144 Recv() (*IpfixExporterDetails, error)
148 type serviceClient_IpfixExporterDumpClient struct {
152 func (c *serviceClient_IpfixExporterDumpClient) Recv() (*IpfixExporterDetails, error) {
153 msg, err := c.Stream.RecvMsg()
157 switch m := msg.(type) {
158 case *IpfixExporterDetails:
160 case *vpe.ControlPingReply:
161 err = c.Stream.Close()
167 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
171 func (c *serviceClient) IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error) {
172 out := new(IpfixFlushReply)
173 err := c.conn.Invoke(ctx, in, out)
177 return out, api.RetvalToVPPApiError(out.Retval)
180 func (c *serviceClient) SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error) {
181 out := new(SetIpfixClassifyStreamReply)
182 err := c.conn.Invoke(ctx, in, out)
186 return out, api.RetvalToVPPApiError(out.Retval)
189 func (c *serviceClient) SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error) {
190 out := new(SetIpfixExporterReply)
191 err := c.conn.Invoke(ctx, in, out)
195 return out, api.RetvalToVPPApiError(out.Retval)