1 // Code generated by GoVPP's binapi-generator. DO NOT EDIT.
10 api "go.fd.io/govpp/api"
11 memclnt "go.fd.io/govpp/binapi/memclnt"
14 // RPCService defines RPC service ipfix_export.
15 type RPCService interface {
16 IpfixAllExporterGet(ctx context.Context, in *IpfixAllExporterGet) (RPCService_IpfixAllExporterGetClient, error)
17 IpfixClassifyStreamDump(ctx context.Context, in *IpfixClassifyStreamDump) (RPCService_IpfixClassifyStreamDumpClient, error)
18 IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error)
19 IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error)
20 IpfixExporterCreateDelete(ctx context.Context, in *IpfixExporterCreateDelete) (*IpfixExporterCreateDeleteReply, error)
21 IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error)
22 IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error)
23 SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error)
24 SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error)
27 type serviceClient struct {
31 func NewServiceClient(conn api.Connection) RPCService {
32 return &serviceClient{conn}
35 func (c *serviceClient) IpfixAllExporterGet(ctx context.Context, in *IpfixAllExporterGet) (RPCService_IpfixAllExporterGetClient, error) {
36 stream, err := c.conn.NewStream(ctx)
40 x := &serviceClient_IpfixAllExporterGetClient{stream}
41 if err := x.Stream.SendMsg(in); err != nil {
47 type RPCService_IpfixAllExporterGetClient interface {
48 Recv() (*IpfixAllExporterDetails, error)
52 type serviceClient_IpfixAllExporterGetClient struct {
56 func (c *serviceClient_IpfixAllExporterGetClient) Recv() (*IpfixAllExporterDetails, error) {
57 msg, err := c.Stream.RecvMsg()
61 switch m := msg.(type) {
62 case *IpfixAllExporterDetails:
64 case *IpfixAllExporterGetReply:
65 err = c.Stream.Close()
71 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
75 func (c *serviceClient) IpfixClassifyStreamDump(ctx context.Context, in *IpfixClassifyStreamDump) (RPCService_IpfixClassifyStreamDumpClient, error) {
76 stream, err := c.conn.NewStream(ctx)
80 x := &serviceClient_IpfixClassifyStreamDumpClient{stream}
81 if err := x.Stream.SendMsg(in); err != nil {
84 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
90 type RPCService_IpfixClassifyStreamDumpClient interface {
91 Recv() (*IpfixClassifyStreamDetails, error)
95 type serviceClient_IpfixClassifyStreamDumpClient struct {
99 func (c *serviceClient_IpfixClassifyStreamDumpClient) Recv() (*IpfixClassifyStreamDetails, error) {
100 msg, err := c.Stream.RecvMsg()
104 switch m := msg.(type) {
105 case *IpfixClassifyStreamDetails:
107 case *memclnt.ControlPingReply:
108 err = c.Stream.Close()
114 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
118 func (c *serviceClient) IpfixClassifyTableAddDel(ctx context.Context, in *IpfixClassifyTableAddDel) (*IpfixClassifyTableAddDelReply, error) {
119 out := new(IpfixClassifyTableAddDelReply)
120 err := c.conn.Invoke(ctx, in, out)
124 return out, api.RetvalToVPPApiError(out.Retval)
127 func (c *serviceClient) IpfixClassifyTableDump(ctx context.Context, in *IpfixClassifyTableDump) (RPCService_IpfixClassifyTableDumpClient, error) {
128 stream, err := c.conn.NewStream(ctx)
132 x := &serviceClient_IpfixClassifyTableDumpClient{stream}
133 if err := x.Stream.SendMsg(in); err != nil {
136 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
142 type RPCService_IpfixClassifyTableDumpClient interface {
143 Recv() (*IpfixClassifyTableDetails, error)
147 type serviceClient_IpfixClassifyTableDumpClient struct {
151 func (c *serviceClient_IpfixClassifyTableDumpClient) Recv() (*IpfixClassifyTableDetails, error) {
152 msg, err := c.Stream.RecvMsg()
156 switch m := msg.(type) {
157 case *IpfixClassifyTableDetails:
159 case *memclnt.ControlPingReply:
160 err = c.Stream.Close()
166 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
170 func (c *serviceClient) IpfixExporterCreateDelete(ctx context.Context, in *IpfixExporterCreateDelete) (*IpfixExporterCreateDeleteReply, error) {
171 out := new(IpfixExporterCreateDeleteReply)
172 err := c.conn.Invoke(ctx, in, out)
176 return out, api.RetvalToVPPApiError(out.Retval)
179 func (c *serviceClient) IpfixExporterDump(ctx context.Context, in *IpfixExporterDump) (RPCService_IpfixExporterDumpClient, error) {
180 stream, err := c.conn.NewStream(ctx)
184 x := &serviceClient_IpfixExporterDumpClient{stream}
185 if err := x.Stream.SendMsg(in); err != nil {
188 if err = x.Stream.SendMsg(&memclnt.ControlPing{}); err != nil {
194 type RPCService_IpfixExporterDumpClient interface {
195 Recv() (*IpfixExporterDetails, error)
199 type serviceClient_IpfixExporterDumpClient struct {
203 func (c *serviceClient_IpfixExporterDumpClient) Recv() (*IpfixExporterDetails, error) {
204 msg, err := c.Stream.RecvMsg()
208 switch m := msg.(type) {
209 case *IpfixExporterDetails:
211 case *memclnt.ControlPingReply:
212 err = c.Stream.Close()
218 return nil, fmt.Errorf("unexpected message: %T %v", m, m)
222 func (c *serviceClient) IpfixFlush(ctx context.Context, in *IpfixFlush) (*IpfixFlushReply, error) {
223 out := new(IpfixFlushReply)
224 err := c.conn.Invoke(ctx, in, out)
228 return out, api.RetvalToVPPApiError(out.Retval)
231 func (c *serviceClient) SetIpfixClassifyStream(ctx context.Context, in *SetIpfixClassifyStream) (*SetIpfixClassifyStreamReply, error) {
232 out := new(SetIpfixClassifyStreamReply)
233 err := c.conn.Invoke(ctx, in, out)
237 return out, api.RetvalToVPPApiError(out.Retval)
240 func (c *serviceClient) SetIpfixExporter(ctx context.Context, in *SetIpfixExporter) (*SetIpfixExporterReply, error) {
241 out := new(SetIpfixExporterReply)
242 err := c.conn.Invoke(ctx, in, out)
246 return out, api.RetvalToVPPApiError(out.Retval)