allow to set the region for pagerduty

README.md

@@ -446,6 +446,7 @@ kafkarest:
 
 pagerduty:
   routingKey: "" # Pagerduty Routing Key, if not empty, Pagerduty output is enabled
+  region: "us" # Pagerduty Region, can be 'us' or 'eu' (default: us)
   minimumpriority: "" # minimum priority of event for using this output, order is emergency|alert|critical|error|warning|notice|informational|debug or "" (default)
 
 kubeless:
@@ -967,15 +968,9 @@ care of lower/uppercases**) : `yaml: a.b --> envvar: A_B` :
   `emergency|alert|critical|error|warning|notice|informational|debug or "" (default)`
 - **KAFKAREST_MUTUALTLS** : enable mutual tls authentication for this output (default: `false`)
 - **KAFKAREST_CHECKCERT** : check if ssl certificate of the output is valid (default: `true`)
-- **PAGERDUTY_APIKEY**: Pagerduty API Key, if not empty, Pagerduty output is
+- **PAGERDUTY_ROUTINGKEY**: Pagerduty Region, can be 'us' or 'eu' (default: us)
+- **PAGERDUTY_REGION**: Pagerduty Region, if not empty, Pagerduty output is
   _enabled_
-- **PAGERDUTY_SERVICE**: Service to create an incident (mandatory)
-- **PAGERDUTY_ASSIGNEE**: A list of comma separated users to assign. Cannot be
-  provided if `PAGERDUTY_ESCALATION_POLICY` is already specified. If not empty,
-  Pagerduty is _enabled_
-- **PAGERDUTY_ESCALATION_POLICY**: Escalation policy to assign. Cannot be
-  provided if `PAGERDUTY_ASSIGNEE` is already specified.If not empty, Pagerduty
-  is _enabled_
 - **PAGERDUTY_MINIMUMPRIORITY**: minimum priority of event for using this
   output, order is
   `emergency|alert|critical|error|warning|notice|informational|debug or "" (default)`

config.go

@@ -286,6 +286,7 @@ func getConfig() *types.Configuration {
 	v.SetDefault("KafkaRest.CheckCert", true)
 
 	v.SetDefault("Pagerduty.RoutingKey", "")
+	v.SetDefault("Pagerduty.Region", "us")
 	v.SetDefault("Pagerduty.MinimumPriority", "")
 	v.SetDefault("Pagerduty.MutualTls", false)
 	v.SetDefault("Pagerduty.CheckCert", true)

config_example.yaml

@@ -275,6 +275,7 @@ kafkarest:
 
 pagerduty:
   routingKey: "" # Pagerduty Routing Key, if not empty, Pagerduty output is enabled
+  region: "us" # Pagerduty Region, can be 'us' or 'eu' (default: us)
   minimumpriority: "" # minimum priority of event for using this output, order is emergency|alert|critical|error|warning|notice|informational|debug or "" (default)
 
 kubeless:

outputs/pagerduty.go

@@ -1,6 +1,7 @@
 package outputs
 
 import (
+	"context"
 	"log"
 	"strings"
 	"time"
@@ -10,13 +11,24 @@ import (
 	"github.com/falcosecurity/falcosidekick/types"
 )
 
+const (
+	USEndpoint string = "https://events.pagerduty.com"
+	EUEndpoint string = "https://events.eu.pagerduty.com"
+)
+
 // PagerdutyPost posts alert event to Pagerduty
 func (c *Client) PagerdutyPost(falcopayload types.FalcoPayload) {
 	c.Stats.Pagerduty.Add(Total, 1)
 
 	event := createPagerdutyEvent(falcopayload, c.Config.Pagerduty)
 
-	if _, err := pagerduty.ManageEvent(event); err != nil {
+	if strings.ToLower(c.Config.Pagerduty.Region) == "eu" {
+		pagerduty.WithV2EventsAPIEndpoint(EUEndpoint)
+	} else {
+		pagerduty.WithV2EventsAPIEndpoint(USEndpoint)
+	}
+
+	if _, err := pagerduty.ManageEventWithContext(context.Background(), event); err != nil {
 		go c.CountMetric(Outputs, 1, []string{"output:pagerduty", "status:error"})
 		c.Stats.Pagerduty.Add(Error, 1)
 		c.PromStats.Outputs.With(map[string]string{"destination": "pagerduty", "status": Error}).Inc()

types/types.go

@@ -469,6 +469,7 @@ type KafkaRestConfig struct {
 
 type PagerdutyConfig struct {
 	RoutingKey      string
+	Region          string
 	MinimumPriority string
 	CheckCert       bool
 	MutualTLS       bool