diff options
| author | Timotej S <6674623+underhood@users.noreply.github.com> | 2022-03-09 14:08:20 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-03-09 14:08:20 +0100 |
| commit | d8aba23d0f471ccb3f0107c4aac119cf35753f94 (patch) | |
| tree | 0d2d3632e4a04058912378fb90286634cedfb612 /database/sqlite/sqlite_aclk_chart.h | |
| parent | 5b8737361aac20a9887ae97b95a861d7c4f3deab (diff) | |
Adds more info to aclk-state API call (#12231)
Diffstat (limited to 'database/sqlite/sqlite_aclk_chart.h')
| -rw-r--r-- | database/sqlite/sqlite_aclk_chart.h | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/database/sqlite/sqlite_aclk_chart.h b/database/sqlite/sqlite_aclk_chart.h index 370af4729a..fee5ecca2f 100644 --- a/database/sqlite/sqlite_aclk_chart.h +++ b/database/sqlite/sqlite_aclk_chart.h @@ -16,6 +16,22 @@ extern sqlite3 *db_meta; #define RRDSET_MINIMUM_LIVE_MULTIPLIER (1.5) #endif +struct aclk_chart_sync_stats { + int updates; + uint64_t batch_id; + uint64_t min_seqid; + uint64_t max_seqid; + uint64_t min_seqid_pend; + uint64_t max_seqid_pend; + uint64_t min_seqid_sent; + uint64_t max_seqid_sent; + uint64_t min_seqid_ack; + uint64_t max_seqid_ack; + time_t max_date_created; + time_t max_date_submitted; + time_t max_date_ack; +}; + extern int queue_chart_to_aclk(RRDSET *st); extern int queue_dimension_to_aclk(RRDDIM *rd); extern void sql_create_aclk_table(RRDHOST *host, uuid_t *host_uuid, uuid_t *node_id); @@ -35,4 +51,5 @@ void aclk_receive_chart_ack(struct aclk_database_worker_config *wc, struct aclk_ void aclk_process_dimension_deletion(struct aclk_database_worker_config *wc, struct aclk_database_cmd cmd); uint32_t sql_get_pending_count(struct aclk_database_worker_config *wc); void aclk_send_dimension_update(RRDDIM *rd); +struct aclk_chart_sync_stats *aclk_get_chart_sync_stats(RRDHOST *host); #endif //NETDATA_SQLITE_ACLK_CHART_H |