diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2022-11-28 12:22:38 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-28 12:22:38 +0200 |
| commit | 53a13ab8e110923d097968353a6bc1e22399480f (patch) | |
| tree | a22fe110436844fcc0331073d37182adefbf0edc /streaming/replication.h | |
| parent | 1e9f2c7a2a866be27203c528067adecd283e0ceb (diff) | |
replication fixes No 7 (#14053)
* move global statistics workers to a separate thread; query statistics per query source; query statistics for ML, exporters, backfilling; reset replication point in time every 10 seconds, instead of every 1; fix compilation warnings; optimize the replication queries code; prevent long tail of replication requests (big sleeps); provide query statistics about replication ; optimize replication sender when most senders are full; optimize replication_request_get_first_available(); reset replication completion calculation;
* remove workers utilization from global statistics thread
Diffstat (limited to 'streaming/replication.h')
| -rw-r--r-- | streaming/replication.h | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/streaming/replication.h b/streaming/replication.h index 9bd2c87da1..e17073bba0 100644 --- a/streaming/replication.h +++ b/streaming/replication.h @@ -5,6 +5,15 @@ #include "daemon/common.h" +struct replication_query_statistics { + size_t queries_started; + size_t queries_finished; + size_t points_read; + size_t points_generated; +}; + +struct replication_query_statistics replication_get_query_statistics(void); + bool replicate_chart_response(RRDHOST *rh, RRDSET *rs, bool start_streaming, time_t after, time_t before); typedef int (*send_command)(const char *txt, void *data); |