replication.h 1.0 KB

1234567891011121314151617181920212223
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #ifndef REPLICATION_H
  3. #define REPLICATION_H
  4. #include "daemon/common.h"
  5. bool replicate_chart_response(RRDHOST *rh, RRDSET *rs, bool start_streaming, time_t after, time_t before);
  6. typedef int (*send_command)(const char *txt, void *data);
  7. bool replicate_chart_request(send_command callback, void *callback_data,
  8. RRDHOST *rh, RRDSET *rs,
  9. time_t first_entry_child, time_t last_entry_child, time_t child_world_time,
  10. time_t response_first_start_time, time_t response_last_end_time);
  11. void replication_init_sender(struct sender_state *sender);
  12. void replication_cleanup_sender(struct sender_state *sender);
  13. void replication_sender_delete_pending_requests(struct sender_state *sender);
  14. void replication_add_request(struct sender_state *sender, const char *chart_id, time_t after, time_t before, bool start_streaming);
  15. void replication_recalculate_buffer_used_ratio_unsafe(struct sender_state *s);
  16. #endif /* REPLICATION_H */