aggregate.h File Reference
NAF Core Library Flow Aggregation API. More...
#include <naf/autoinc.h>
#include <naf/nafcore.h>
#include <naf/match.h>
Go to the source code of this file.
Functions | |
| gboolean | naf_aggregate (gboolean flush, NAFMultiBin *mtab, NAFAggConfig *conf, fBuf_t **fbuf_ary, GError **err) |
| Aggregate dequeueable bin tables from a given multibin according to an aggregation configuration, writing the resulting aggregates. | |
Detailed Description
NAF Core Library Flow Aggregation API.Used by nafalize. Defines a single entry point for aggregating flows from a multibin managed by the match API (see match.h). This function should be called periodically, and to completely aggregate and flush the multibin at process or aggregation termination.
The proper use of the match and aggregate APIs is as follows:
- naf_exparse() to initialize a NAFAggConfig from an expression
- naf_mtab_init() to initialize a NAFMultiBin
- to process each flow:
- naf_mtab_add_raw() to add each raw flow to the NAFMultiBin, matching it
- naf_aggregate() to aggregate and flush flows as they are dequeueable. aggregate does not neet to be called for each flow, but it should be called periodically to flush the multibin.
Function Documentation
|
||||||||||||||||||||||||
|
Aggregate dequeueable bin tables from a given multibin according to an aggregation configuration, writing the resulting aggregates. This is a single entry point to the NAF aggregation apparatus, and should be called periodically with flush set to FALSE, then once at process or aggregation termination with flush set TRUE.
|