109 Commits

Author SHA1 Message Date
Kebree
907ce911f7 enable sha mechanism for kafka authentication (#173)
Co-authored-by: Jean-Baptiste GINTRAND <jean-baptiste.gintrand@forterro.com>
2024-05-14 00:27:38 +03:00
bysph
c1455c01fb fix: support to set kafka version (#146)
Co-authored-by: sph <shepenghui@corp.netease.com>
2023-11-21 16:30:45 +03:00
Branko Toic
ff7498c5cc feat(loki): add support for custom headers (#142)
add custom headers support in Loki sink, and documentation in README

fix: #141
2023-11-18 01:00:56 +03:00
tedyage
4df1af5f2b Add Headers into the ElasticsearchConfig. (#131)
Co-authored-by: tian.zhiqiang3 <tian.zhiqiang3@neolink.com>
2023-10-25 14:50:43 +03:00
Kazuki Suda
8b324e8ae0 sink/slack: Use GetString for color (#112)
Signed-off-by: Kazuki Suda <kazuki.suda@gmail.com>
2023-07-23 17:03:08 +03:00
Mustafa Akın
7ec9b6b842 Revert "fixed kafka sinker initialization failure when the TLS certificate is invalid" (#103) 2023-07-06 21:22:33 +03:00
Mustafa Akın
4ee63104eb Merge branch 'br_kafka_error' of https://github.com/yanmxa/kubernetes-event-exporter into yanmxa-br_kafka_error 2023-07-06 21:17:32 +03:00
Mustafa Akın
ff36eee2d0 Merge branch 'ineffectual_err' of https://github.com/Yleisradio/kubernetes-event-exporter into Yleisradio-ineffectual_err 2023-07-06 20:34:47 +03:00
Mustafa Akın
3ae9db7c7a Merge branch 'master' of https://github.com/xonvanetta/kubernetes-event-exporter into xonvanetta-master 2023-07-06 20:33:15 +03:00
Navid Shariati
680b4e29e3 add loki receiver (#50)
* add loki output

* update README for loki

---------

Co-authored-by: navid.shariaty <navid.shariaty@snapp.cab>
2023-07-06 20:31:54 +03:00
Mustafa Akın
34ca68c7fd Merge branch 'teams-rate-limited' of https://github.com/minchao/kubernetes-event-exporter into minchao-teams-rate-limited 2023-07-06 19:41:47 +03:00
Manuel Rüger
811ab9b6c9 go.mod: Update masterminds/sprig to v3 (#72) 2023-07-06 18:38:57 +03:00
Juha Ylitalo
e1070dc954 "io/ioutil" has been deprecated (#85)
As of Go 1.16, the same functionality is now provided by package io or package os
2023-07-06 18:36:15 +03:00
Juha Ylitalo
da4a97c1e2 Remove redundant returns (#87)
* If ev.Count >= r.MinCount, it will fallthrough to return true

* No need for return at the end of Stdout.Close
2023-07-06 18:35:17 +03:00
minchao
f5bf1eb7dc feat: return an error when teams endpoint responds with http error 429
Improve error handling in the teams sink to return an error when the Teams endpoint responds with HTTP error 429.

see: https://learn.microsoft.com/en-us/microsoftteams/platform/webhooks-and-connectors/how-to/connectors-using?tabs=cURL#rate-limiting-for-connectors
2023-05-30 20:36:57 +08:00
Juha Ylitalo
937b37e038 ineffectual assignment to err, if we don't check it 2023-05-19 15:53:34 +03:00
myan
6db2f8a304 Fixed kafka producer initialization failure when the TLS certificate is invalid
Signed-off-by: myan <myan@redhat.com>
2023-05-11 14:46:19 +00:00
Fabian Heib
7db54ff9bc feat: Add GetString to slack sink config
like title,auther and footer
return error from template Parse in GetString
2023-05-02 14:28:59 +02:00
Romain Poirot
335530564c feat: add dedot option to stdout and pipe sinks (#59) 2023-03-17 10:44:00 +03:00
raffis
1b684b5cb9 fix: allow specify root ca without client/key (#41)
Signed-off-by: Raffael Sahli <raffael.sahli@doodle.com>

Signed-off-by: Raffael Sahli <raffael.sahli@doodle.com>
2022-12-19 10:56:36 +03:00
Kevin Li
a3dc8681df Reuse transport to avoid the unnecessary connections (#31)
* Reuse trasport to avoid uncessary connections

* Fix typo

Co-authored-by: Kanwen Li 🐼 <kanwli@microsoft.com>
Co-authored-by: Mustafa Akın <mustafa@resmo.com>
2022-12-19 10:52:32 +03:00
Mustafa Akın
f9335bda24 Updated packages, tidied and changed package name from opsgenie to resmoio (#45)
* Updated packages, tidied and changed package name from opsgenie to resmoio

* Handle removal of clusterName from API and leader election api change

* Update Dockerfile Go to 1.19

* Test case for parsing minCount properly for #43

* more extensive test case to also match apiVersion config
2022-12-19 10:45:46 +03:00
Kirill Borodin
60cc0f689b enable DeDot function with firehose sink (#18)
* enable DeDot function with firehose sink

* function fix
2022-09-15 11:08:56 +03:00
Mustafa Akın
5c720d3a4d Remove vendor now, go is better at handling dependencies 2022-07-03 22:40:29 +03:00
Mustafa Akın
62c4f35f3d Merge branch 'xxops/master' 2022-07-03 22:01:43 +03:00
Mustafa Akın
90375e68c2 Merge branch 'webhook-transport-proxy' 2022-07-03 21:58:38 +03:00
Mustafa Akın
970e9a0adb Merge branch 'add-opensearch-sink' 2022-07-03 21:57:59 +03:00
chenlichao
8f1f14fb3d Enhance webhook sink, add template feature to http headers 2022-03-28 19:31:29 +08:00
minchao
0c6926329e fix proxy support for webhook transport
Because the webhook used http.DefaultTransport which supports http.ProxyFromEnvironment in v0.10.
2022-03-08 11:39:58 +08:00
Andrey Shikanov
97247cb9fd Add deDot for receiver: file 2022-02-17 16:14:46 +03:00
Willem Borgesius
90ce4b5f94 Add opensearch sink 2021-12-16 08:17:44 +01:00
Mustafa Akın
3b6a261d4a Kafka avro commit merge 2021-11-06 12:31:27 +03:00
Mustafa Akın
7eef4f6586 Merge branch 'kafka-avro' of https://github.com/xmcqueen/kubernetes-event-exporter into xmcqueen-kafka-avro 2021-11-06 12:31:04 +03:00
mustafaakin-atl
4b40b6b1b6 Merge pull request #134 from TinySong/webhook-tls
webhook support tls setting
2021-11-06 12:21:17 +03:00
mustafaakin-atl
1dfcee6ef7 Merge pull request #142 from blamarvt/es-err-info
Log error message when ES sink fails to index
2021-11-06 12:19:40 +03:00
mustafaakin-atl
13119e5d33 Merge pull request #141 from omauger/master
Support SASL connection for Kafka and add function to get time format ISO8601
2021-11-06 12:19:14 +03:00
Brian McQueen
a4756bc0cb cleaned up the code a bit and add more comments 2021-10-06 16:09:08 -07:00
Brian McQueen
4cb4939cb1 added support for kafka with avro 2021-10-06 15:23:18 -07:00
Brian Lamar
add874fb4c Log error message when ES sink fails to index 2021-08-27 15:57:06 -04:00
omauger
1646dc34c7 kafka sink works with sasl auth 2021-08-26 14:21:05 +02:00
omauger
5db3ccd0d0 Update Kafka output to support sasl auth 2021-08-24 16:09:47 +02:00
song
c59e7c974e webhook support tls setting 2021-08-06 10:14:52 +08:00
Alex Andrews
b7d83c8999 Add firehose sink 2021-07-21 12:36:32 +01:00
Mustafa Akın
b1c3a9efff Merge branch 'update-slack-library' of https://github.com/jun06t/kubernetes-event-exporter into jun06t-update-slack-library 2021-06-16 22:45:02 +03:00
Mustafa Akın
5867a4eea6 Minor fixes for event bridge 2021-06-16 22:26:02 +03:00
Mustafa Akın
bf1f9bdd8c resolve conflicts 2021-06-16 22:09:23 +03:00
Mustafa Akın
dbcf9044fc Resolve conflicts 2021-06-16 22:06:56 +03:00
makocchi
db3b1847a6 Improve slack attachment (#92)
* improve slack attachment

* update slack configuration
2021-06-16 21:36:06 +03:00
Christoph Petrausch
46c2cb70f4 elasticsearch: Add TLS client cert auth (#116)
* elasticsearch: Add TLS client cert auth

* Elasticsearch: Init RootCA certpool to prevent nil pointer dereference

* Elasticsearch: Refactor TLS setup to catch errors

Don't setup client cert auth of not both keyFile and certFile are configured
2021-06-16 21:35:06 +03:00
Jason Yanowitz
ce3f5f0c78 expose InsecureSkipVerify for Kafka TLS config (#86)
Defaults to false if it's not specified.

    Co-authored-by: Joyce Yee <jzyeezy>
2021-06-16 21:34:20 +03:00