diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2021-02-07 11:49:00 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2021-02-07 12:42:05 +0000 |
commit | 2e85f9325a797977eea9dfea0a925775ddd211d9 (patch) | |
tree | 452c7f30d62fca5755f659b99e4e53c7b03afc21 /backends/prometheus/remote_write/remote_write.cc | |
parent | Releasing debian version 1.19.0-4. (diff) | |
download | netdata-2e85f9325a797977eea9dfea0a925775ddd211d9.tar.xz netdata-2e85f9325a797977eea9dfea0a925775ddd211d9.zip |
Merging upstream version 1.29.0.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'backends/prometheus/remote_write/remote_write.cc')
-rw-r--r-- | backends/prometheus/remote_write/remote_write.cc | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/backends/prometheus/remote_write/remote_write.cc b/backends/prometheus/remote_write/remote_write.cc index 91d4305ba..9448595c1 100644 --- a/backends/prometheus/remote_write/remote_write.cc +++ b/backends/prometheus/remote_write/remote_write.cc @@ -6,20 +6,19 @@ using namespace prometheus; +static google::protobuf::Arena arena; +static WriteRequest *write_request; -google::protobuf::Arena arena; -WriteRequest *write_request; - -void init_write_request() { +void backends_init_write_request() { GOOGLE_PROTOBUF_VERIFY_VERSION; write_request = google::protobuf::Arena::CreateMessage<WriteRequest>(&arena); } -void clear_write_request() { +void backends_clear_write_request() { write_request->clear_timeseries(); } -void add_host_info(const char *name, const char *instance, const char *application, const char *version, const int64_t timestamp) { +void backends_add_host_info(const char *name, const char *instance, const char *application, const char *version, const int64_t timestamp) { TimeSeries *timeseries; Sample *sample; Label *label; @@ -52,7 +51,7 @@ void add_host_info(const char *name, const char *instance, const char *applicati } // adds tag to the last created timeseries -void add_tag(char *tag, char *value) { +void backends_add_tag(char *tag, char *value) { TimeSeries *timeseries; Label *label; @@ -63,7 +62,7 @@ void add_tag(char *tag, char *value) { label->set_value(value); } -void add_metric(const char *name, const char *chart, const char *family, const char *dimension, const char *instance, const double value, const int64_t timestamp) { +void backends_add_metric(const char *name, const char *chart, const char *family, const char *dimension, const char *instance, const double value, const int64_t timestamp) { TimeSeries *timeseries; Sample *sample; Label *label; @@ -97,13 +96,17 @@ void add_metric(const char *name, const char *chart, const char *family, const c sample->set_timestamp(timestamp); } -size_t get_write_request_size(){ +size_t backends_get_write_request_size(){ +#if GOOGLE_PROTOBUF_VERSION < 3001000 size_t size = (size_t)snappy::MaxCompressedLength(write_request->ByteSize()); +#else + size_t size = (size_t)snappy::MaxCompressedLength(write_request->ByteSizeLong()); +#endif return (size < INT_MAX)?size:0; } -int pack_write_request(char *buffer, size_t *size) { +int backends_pack_write_request(char *buffer, size_t *size) { std::string uncompressed_write_request; if(write_request->SerializeToString(&uncompressed_write_request) == false) return 1; @@ -112,6 +115,6 @@ int pack_write_request(char *buffer, size_t *size) { return 0; } -void protocol_buffers_shutdown() { +void backends_protocol_buffers_shutdown() { google::protobuf::ShutdownProtobufLibrary(); } |