12 Commits

Author SHA1 Message Date
ionutboangiu
8443af3a89 Relicense from GPLv3 to AGPLv3 2025-10-29 19:42:40 +01:00
ionutboangiu
7bb065fda6 rename *dc DataProvider to *em (from EventMetrics) 2025-03-17 17:36:58 +01:00
ionutboangiu
1c00a3aad1 Add cron-based/manual reset to ExporterMetrics 2025-03-17 17:36:58 +01:00
ionutboangiu
11b96de00a Add kafkaBatchSize configuration field
Avoids the default 1 second delay when the batch doesn't
reach 100 messages within that time.

Useful when the Kafka exporter is not cached, as it would
otherwise encounter that delay. Setting BatchSize to 1
prevents this.
2024-06-30 16:28:52 +02:00
ionutboangiu
02ae2cce79 Revise Kafka exporter implementation
- added extra error return parameter to constructor
- failing to parse PEM certificates returns an error (previously nil
return)
- moved Connect logic inside the constructor*
- removed unnecessary fields from poster structure. Use the
configuration fields directly instead.
- removed mutex from poster structure (kafka writer is thread-safe)
- removed nil writer check. Message is exported directly.
- shortened receiver name
(https://google.github.io/styleguide/go/decisions#receiver-names)

*The Kafka Transport is not a connection but a configuration for the
connection created during the first export. The connection and its
related goroutines stay running until manually closed.
2024-06-30 16:28:52 +02:00
ionutboangiu
88b02a3249 Set kafka MaxAttempts to 1
This leaves it to the ExportWithAttempts function to handle the
connect attempts.
2024-04-15 10:39:33 +02:00
ionutboangiu
36bdc41e97 Add support for kafka ssl encryption
For both poster and reader.
Added integration test.
2024-01-23 14:12:33 +01:00
gezimbll
1b1dd13677 Separating opts for each eventexporter type and fixing tests 2023-06-22 10:36:46 +02:00
ionutboangiu
6c16ff320f Replace interface{} with any 2023-05-31 10:23:12 +02:00
ionutboangiu
40eb832060 Fix all compilation errors related to ers after making ees opts of type struct 2021-11-29 20:57:39 +01:00
Trial97
d80a5668ac Updated integration tests 2021-08-18 16:33:28 +02:00
Trial97
cd0964dfea Finished implementing all the exporters 2021-08-18 16:33:28 +02:00