diff options
| author | Timotej S <6674623+underhood@users.noreply.github.com> | 2023-10-20 14:07:55 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-10-20 15:07:55 +0300 |
| commit | 6c05c827d96495edc4925c86650283f87d21c448 (patch) | |
| tree | ffcdf05a8e82c1f37e2176478a7163dda042ccfe /streaming | |
| parent | 897009e223e56e6515e935dec1df80475668f067 (diff) | |
add DYNCFG_RESET (#16241)
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/rrdpush.c | 13 | ||||
| -rw-r--r-- | streaming/rrdpush.h | 3 |
2 files changed, 15 insertions, 1 deletions
diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index e8c46a0218..038f29e40b 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -674,6 +674,19 @@ void rrdpush_send_dyncfg_reg_job(RRDHOST *host, const char *plugin_name, const c sender_thread_buffer_free(); } +void rrdpush_send_dyncfg_reset(RRDHOST *host, const char *plugin_name) +{ + dyncfg_check_can_push(host); + + BUFFER *wb = sender_start(host->sender); + + buffer_sprintf(wb, PLUGINSD_KEYWORD_DYNCFG_RESET " %s\n", plugin_name); + + sender_commit(host->sender, wb, STREAM_TRAFFIC_TYPE_METADATA); + + sender_thread_buffer_free(); +} + void rrdpush_send_claimed_id(RRDHOST *host) { if(!stream_has_capability(host->sender, STREAM_CAP_CLAIM)) return; diff --git a/streaming/rrdpush.h b/streaming/rrdpush.h index c3c14233fa..787e63de12 100644 --- a/streaming/rrdpush.h +++ b/streaming/rrdpush.h @@ -781,6 +781,7 @@ void rrdpush_send_job_deleted(RRDHOST *host, const char *plugin_name, const char void rrdpush_send_dyncfg_enable(RRDHOST *host, const char *plugin_name); void rrdpush_send_dyncfg_reg_module(RRDHOST *host, const char *plugin_name, const char *module_name, enum module_type type); -void rrdpush_send_dyncfg_reg_job(RRDHOST *host, const char *plugin_name, const char *module_name, const char *job_name, enum job_type type, uint32_t flags);//x +void rrdpush_send_dyncfg_reg_job(RRDHOST *host, const char *plugin_name, const char *module_name, const char *job_name, enum job_type type, uint32_t flags); +void rrdpush_send_dyncfg_reset(RRDHOST *host, const char *plugin_name); #endif //NETDATA_RRDPUSH_H |