fix duplicated log messages and some format of log prefix

Signed-off-by: Issif <issif_github@gadz.org>
falcosecurity · Apr 13, 2021 · 31e9017 · 31e9017
1 parent d0fd27b
commit 31e9017
Show file tree

Hide file tree

Showing 18 changed files with 4 additions and 18 deletions.
diff --git a/outputs/alertmanager.go b/outputs/alertmanager.go
@@ -102,5 +102,4 @@ func (c *Client) AlertmanagerPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:alertmanager", "status:ok"})
 	c.Stats.Alertmanager.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "alertmanager", "status": OK}).Inc()
-	log.Printf("[INFO]  : AlertManager - Publish OK\n")
 }
diff --git a/outputs/azure.go b/outputs/azure.go
@@ -59,7 +59,7 @@ func (c *Client) EventHubPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:azureeventhub", "status:ok"})
 	c.Stats.AzureEventHub.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "azureeventhub", "status": OK}).Inc()
-	log.Printf("[INFO] : %v EventHub - Publish OK", c.OutputType)
+	log.Printf("[INFO]  : %v EventHub - Publish OK", c.OutputType)
 }
 
 // setEventHubErrorMetrics set the error stats

diff --git a/outputs/cloudevents.go b/outputs/cloudevents.go
@@ -53,5 +53,5 @@ func (c *Client) CloudEventsSend(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:cloudevents", "status:ok"})
 	c.Stats.CloudEvents.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "cloudevents", "status": OK}).Inc()
-	log.Printf("[INFO] : CloudEvents - Send OK\n")
+	log.Printf("[INFO]  : CloudEvents - Send OK\n")
 }
diff --git a/outputs/datadog.go b/outputs/datadog.go
@@ -67,5 +67,4 @@ func (c *Client) DatadogPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:datadog", "status:ok"})
 	c.Stats.Datadog.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "datadog", "status": OK}).Inc()
-	log.Printf("[INFO] : Datadog - Publish OK\n")
 }
diff --git a/outputs/discord.go b/outputs/discord.go
@@ -107,5 +107,4 @@ func (c *Client) DiscordPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:discord", "status:ok"})
 	c.Stats.Discord.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "discord", "status": OK}).Inc()
-	log.Printf("[INFO] : Discord - Publish OK\n")
 }
diff --git a/outputs/elasticsearch.go b/outputs/elasticsearch.go
@@ -44,7 +44,6 @@ func (c *Client) ElasticsearchPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:elasticsearch", "status:ok"})
 	c.Stats.Elasticsearch.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "elasticsearch", "status": OK}).Inc()
-	log.Printf("[INFO]  : ElasticSearch - Publish OK\n")
 }
 
 // setElasticSearchErrorMetrics set the error stats

diff --git a/outputs/googlechat.go b/outputs/googlechat.go
@@ -96,5 +96,4 @@ func (c *Client) GooglechatPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:googlechat", "status:ok"})
 	c.Stats.GoogleChat.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "googlechat", "status": OK}).Inc()
-	log.Printf("[INFO]  : GoogleChat - Publish OK\n")
 }
diff --git a/outputs/influxdb.go b/outputs/influxdb.go
@@ -43,5 +43,4 @@ func (c *Client) InfluxdbPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:influxdb", "status:ok"})
 	c.Stats.Influxdb.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "influxdb", "status": OK}).Inc()
-	log.Printf("[INFO] : InfluxDB - Publish OK\n")
 }
diff --git a/outputs/loki.go b/outputs/loki.go
@@ -60,5 +60,4 @@ func (c *Client) LokiPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:loki", "status:ok"})
 	c.Stats.Loki.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "loki", "status": OK}).Inc()
-	log.Printf("[INFO] : Loki - Publish OK\n")
 }
diff --git a/outputs/mattermost.go b/outputs/mattermost.go
@@ -118,5 +118,4 @@ func (c *Client) MattermostPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:mattermost", "status:ok"})
 	c.Stats.Mattermost.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "mattermost", "status": OK}).Inc()
-	log.Printf("[INFO] : Mattermost - Publish OK\n")
 }
diff --git a/outputs/opsgenie.go b/outputs/opsgenie.go
@@ -65,5 +65,4 @@ func (c *Client) OpsgeniePost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:opsgenie", "status:ok"})
 	c.Stats.Opsgenie.Add("ok", 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "opsgenie", "status": OK}).Inc()
-	log.Printf("[INFO] : OpsGenie - Publish OK\n")
 }
diff --git a/outputs/pagerduty.go b/outputs/pagerduty.go
@@ -26,7 +26,7 @@ func (c *Client) PagerdutyPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:pagerduty", "status:ok"})
 	c.Stats.Pagerduty.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "pagerduty", "status": OK}).Inc()
-	log.Printf("[INFO] : Pagerduty - Create Incident OK\n")
+	log.Printf("[INFO]  : Pagerduty - Create Incident OK\n")
 }
 
 func createPagerdutyEvent(falcopayload types.FalcoPayload, config types.PagerdutyConfig) pagerduty.V2Event {

diff --git a/outputs/rocketchat.go b/outputs/rocketchat.go
@@ -114,5 +114,4 @@ func (c *Client) RocketchatPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:rocketchat", "status:ok"})
 	c.Stats.Rocketchat.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "rocketchat", "status": OK}).Inc()
-	log.Printf("[INFO] : RocketChat - Publish OK\n")
 }
diff --git a/outputs/slack.go b/outputs/slack.go
@@ -136,5 +136,4 @@ func (c *Client) SlackPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:slack", "status:ok"})
 	c.Stats.Slack.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "slack", "status": OK}).Inc()
-	log.Printf("[INFO] : Slack - Publish OK\n")
 }
diff --git a/outputs/stan.go b/outputs/stan.go
@@ -41,7 +41,7 @@ func (c *Client) StanPublish(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:stan", "status:ok"})
 	c.Stats.Stan.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "stan", "status": OK}).Inc()
-	log.Printf("[INFO] : STAN - Publish OK\n")
+	log.Printf("[INFO]  : STAN - Publish OK\n")
 }
 
 // setStanErrorMetrics set the error stats

diff --git a/outputs/teams.go b/outputs/teams.go
@@ -118,5 +118,4 @@ func (c *Client) TeamsPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:teams", "status:ok"})
 	c.Stats.Teams.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "teams", "status": OK}).Inc()
-	log.Printf("[INFO] : Teams - Publish OK\n")
 }
diff --git a/outputs/webhook.go b/outputs/webhook.go
@@ -23,5 +23,4 @@ func (c *Client) WebhookPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:webhook", "status:ok"})
 	c.Stats.Webhook.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "webhook", "status": OK}).Inc()
-	log.Printf("[INFO] : WebHook - Publish OK\n")
 }
diff --git a/outputs/webui.go b/outputs/webui.go
@@ -38,5 +38,4 @@ func (c *Client) WebUIPost(falcopayload types.FalcoPayload) {
 	go c.CountMetric(Outputs, 1, []string{"output:webui", "status:ok"})
 	c.Stats.WebUI.Add(OK, 1)
 	c.PromStats.Outputs.With(map[string]string{"destination": "webui", "status": OK}).Inc()
-	log.Printf("[INFO]  : WebUI - Publish OK\n")
 }