feat(opsgenie.go): Add Entity field

pkg/batch/writer.go

@@ -5,7 +5,6 @@ import (
 	"time"
 )
 
-
 // Writer allows to buffer some items and call the Handler function either when the buffer is full or the timeout is
 // reached. There will also be support for concurrency for high volume. The handler function is supposed to return an
 // array of booleans to indicate whether the transfer was successful or not. It can be replaced with status codes in

pkg/exporter/channel_registry.go

@@ -16,9 +16,9 @@ import (
 // and we might need a mechanism to drop the vents
 // On closing, the registry sends a signal on all exit channels, and then waits for all to complete.
 type ChannelBasedReceiverRegistry struct {
-	ch     map[string]chan kube.EnhancedEvent
-	exitCh map[string]chan interface{}
-	wg     *sync.WaitGroup
+	ch           map[string]chan kube.EnhancedEvent
+	exitCh       map[string]chan interface{}
+	wg           *sync.WaitGroup
 	MetricsStore *metrics.Store
 }
 

pkg/exporter/event.go

@@ -1,2 +1 @@
 package exporter
-

pkg/sinks/email.go

@@ -1,3 +1,3 @@
 package sinks
 
-// Just kidding, please don't implement this
+// Just kidding, please don't implement this

pkg/sinks/inmemory.go

@@ -22,5 +22,3 @@ func (i *InMemory) Send(ctx context.Context, ev *kube.EnhancedEvent) error {
 func (i *InMemory) Close() {
 	// No-op
 }
-
-

pkg/sinks/loki.go

@@ -7,11 +7,11 @@ import (
 	"errors"
 	"fmt"
 	"github.com/resmoio/kubernetes-event-exporter/pkg/kube"
+	"github.com/rs/zerolog/log"
 	"io/ioutil"
 	"net/http"
 	"strconv"
 	"time"
-	"github.com/rs/zerolog/log"
 )
 
 type promtailStream struct {

pkg/sinks/opsgenie.go

@@ -2,9 +2,9 @@ package sinks
 
 import (
 	"context"
-	"github.com/resmoio/kubernetes-event-exporter/pkg/kube"
 	"github.com/opsgenie/opsgenie-go-sdk-v2/alert"
 	"github.com/opsgenie/opsgenie-go-sdk-v2/client"
+	"github.com/resmoio/kubernetes-event-exporter/pkg/kube"
 )
 
 type OpsgenieConfig struct {
@@ -16,6 +16,13 @@ type OpsgenieConfig struct {
 	Description string            `yaml:"description"`
 	Tags        []string          `yaml:"tags"`
 	Details     map[string]string `yaml:"details"`
+	Entity      string            `yaml:"entity"`
+	Responders  []Responder       `yaml:"responders"`
+}
+
+type Responder struct {
+	Id   string
+	Type string
 }
 
 type OpsgenieSink struct {

pkg/sinks/pipe.go

@@ -10,9 +10,9 @@ import (
 )
 
 type PipeConfig struct {
-	Path   string                 `yaml:"path"`
+	Path string `yaml:"path"`
 	// DeDot all labels and annotations in the event. For both the event and the involvedObject
-	DeDot       bool              `yaml:"deDot"`
+	DeDot  bool                   `yaml:"deDot"`
 	Layout map[string]interface{} `yaml:"layout"`
 }
 

pkg/sinks/sms.go

@@ -1,3 +1,3 @@
 package sinks
 
-// Just kidding, please don't implement this
+// Just kidding, please don't implement this

pkg/sinks/tmpl.go

@@ -5,8 +5,8 @@ import (
 	"encoding/json"
 	"text/template"
 
-	"github.com/resmoio/kubernetes-event-exporter/pkg/kube"
 	"github.com/Masterminds/sprig/v3"
+	"github.com/resmoio/kubernetes-event-exporter/pkg/kube"
 )
 
 func GetString(event *kube.EnhancedEvent, text string) (string, error) {

pkg/version/version.go

@@ -15,12 +15,12 @@ var (
 
 func Revision() string {
 	bi, ok := debug.ReadBuildInfo()
-	
-	if ok {	
+
+	if ok {
 		for _, kv := range bi.Settings {
 			switch kv.Key {
-				case "vcs.revision":
-					return kv.Value
+			case "vcs.revision":
+				return kv.Value
 			}
 		}
 	}