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/internal/testbinapi/binapi2001/vpe"
13 // RPCService defines RPC service ipfix_export.
14 type RPCService interface {
15 IpfixClassifyStreamDump(ctx context.Context, in *IpfixClassifyStreamDump) (RPCService_IpfixClassifyStreamDumpClient, error)
16 IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error)
17 IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error)
18 IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error)
19 IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error)
20 SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error)
21 SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error)
24 type serviceClient struct {
28 func NewServiceClient(conn api.Connection) RPCService {
29 return &serviceClient{conn}
32 func (c *serviceClient) IpfixClassifyStreamDump(ctx context.Context, in *IpfixClassifyStreamDump) (RPCService_IpfixClassifyStreamDumpClient, error) {
33 stream, err := c.conn.NewStream(ctx)
37 x := &serviceClient_IpfixClassifyStreamDumpClient{stream}
38 if err := x.Stream.SendMsg(in); err != nil {
41 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
47 type RPCService_IpfixClassifyStreamDumpClient interface {
48 Recv() (*IpfixClassifyStreamDetails, error)
52 type serviceClient_IpfixClassifyStreamDumpClient struct {
56 func (c *serviceClient_IpfixClassifyStreamDumpClient) Recv() (*IpfixClassifyStreamDetails, error) {
57 msg, err := c.Stream.RecvMsg()
61 switch m := msg.(type) {
62 case *IpfixClassifyStreamDetails:
64 case *vpe.ControlPingReply:
67 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
71 func (c *serviceClient) IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error) {
72 out := new(IpfixClassifyTableAddDelReply)
73 err := c.conn.Invoke(ctx, in, out)
80 func (c *serviceClient) IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error) {
81 stream, err := c.conn.NewStream(ctx)
85 x := &serviceClient_IpfixClassifyTableDumpClient{stream}
86 if err := x.Stream.SendMsg(in); err != nil {
89 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
95 type RPCService_IpfixClassifyTableDumpClient interface {
96 Recv() (*IpfixClassifyTableDetails, error)
100 type serviceClient_IpfixClassifyTableDumpClient struct {
104 func (c *serviceClient_IpfixClassifyTableDumpClient) Recv() (*IpfixClassifyTableDetails, error) {
105 msg, err := c.Stream.RecvMsg()
109 switch m := msg.(type) {
110 case *IpfixClassifyTableDetails:
112 case *vpe.ControlPingReply:
115 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
119 func (c *serviceClient) IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error) {
120 stream, err := c.conn.NewStream(ctx)
124 x := &serviceClient_IpfixExporterDumpClient{stream}
125 if err := x.Stream.SendMsg(in); err != nil {
128 if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
134 type RPCService_IpfixExporterDumpClient interface {
135 Recv() (*IpfixExporterDetails, error)
139 type serviceClient_IpfixExporterDumpClient struct {
143 func (c *serviceClient_IpfixExporterDumpClient) Recv() (*IpfixExporterDetails, error) {
144 msg, err := c.Stream.RecvMsg()
148 switch m := msg.(type) {
149 case *IpfixExporterDetails:
151 case *vpe.ControlPingReply:
154 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
158 func (c *serviceClient) IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error) {
159 out := new(IpfixFlushReply)
160 err := c.conn.Invoke(ctx, in, out)
167 func (c *serviceClient) SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error) {
168 out := new(SetIpfixClassifyStreamReply)
169 err := c.conn.Invoke(ctx, in, out)
176 func (c *serviceClient) SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error) {
177 out := new(SetIpfixExporterReply)
178 err := c.conn.Invoke(ctx, in, out)