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:
68 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
72 func (c *serviceClient) IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error) {
73 out := new(IpfixClassifyTableAddDelReply)
74 err := c.conn.Invoke(ctx, in, out)
78 return out, api.RetvalToVPPApiError(out.Retval)
81 func (c *serviceClient) IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error) {
82 stream, err := c.conn.NewStream(ctx)
86 x := &serviceClient_IpfixClassifyTableDumpClient{stream}
87 if err := x.Stream.SendMsg(in); err != nil {
90 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
96 type RPCService_IpfixClassifyTableDumpClient interface {
97 Recv() (*IpfixClassifyTableDetails, error)
101 type serviceClient_IpfixClassifyTableDumpClient struct {
105 func (c *serviceClient_IpfixClassifyTableDumpClient) Recv() (*IpfixClassifyTableDetails, error) {
106 msg, err := c.Stream.RecvMsg()
110 switch m := msg.(type) {
111 case *IpfixClassifyTableDetails:
113 case *vpe.ControlPingReply:
116 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
120 func (c *serviceClient) IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error) {
121 stream, err := c.conn.NewStream(ctx)
125 x := &serviceClient_IpfixExporterDumpClient{stream}
126 if err := x.Stream.SendMsg(in); err != nil {
129 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
135 type RPCService_IpfixExporterDumpClient interface {
136 Recv() (*IpfixExporterDetails, error)
140 type serviceClient_IpfixExporterDumpClient struct {
144 func (c *serviceClient_IpfixExporterDumpClient) Recv() (*IpfixExporterDetails, error) {
145 msg, err := c.Stream.RecvMsg()
149 switch m := msg.(type) {
150 case *IpfixExporterDetails:
152 case *vpe.ControlPingReply:
155 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
159 func (c *serviceClient) IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error) {
160 out := new(IpfixFlushReply)
161 err := c.conn.Invoke(ctx, in, out)
165 return out, api.RetvalToVPPApiError(out.Retval)
168 func (c *serviceClient) SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error) {
169 out := new(SetIpfixClassifyStreamReply)
170 err := c.conn.Invoke(ctx, in, out)
174 return out, api.RetvalToVPPApiError(out.Retval)
177 func (c *serviceClient) SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error) {
178 out := new(SetIpfixExporterReply)
179 err := c.conn.Invoke(ctx, in, out)
183 return out, api.RetvalToVPPApiError(out.Retval)