🐛 send alerts to channels (#306)

* 🐛 send alerts to channels

alertmanager/dingtalk/dingtalk_test.go

@@ -128,11 +128,11 @@ func TestSendEvent(t *testing.T) {
 	c.url = s.URL + "/send?accessToken=%s"
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/discord/discord.go

@@ -77,12 +77,12 @@ func (s *Discord) SendEvent(ev *event.Event) error {
 		},
 		{
 			Name:   "Name",
-			Value:  ev.Name,
+			Value:  ev.PodName,
 			Inline: true,
 		},
 		{
 			Name:   "Container",
-			Value:  ev.Container,
+			Value:  ev.ContainerName,
 			Inline: true,
 		},
 		{

alertmanager/discord/discord_test.go

@@ -72,10 +72,10 @@ func TestSendEvent(t *testing.T) {
 	c.send = mockedSend
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
 		Logs: "Nam quis nulla. Integer malesuada. In in enim a arcu " +
 			"imperdiet malesuada. Sed vel lectus. Donec odio urna, tempus " +
 			"molestie, porttitor ut, iaculis quis, sem. Phasellus rhoncus.\n" +

alertmanager/email/email.go

@@ -114,16 +114,16 @@ func (e *Email) buildMessageSubjectAndBody(
 		logsText = util.JsonEscape(ev.Logs)
 	}
 
-	subject := fmt.Sprintf("⛑ Kwatch detected a crash in pod %s ", ev.Container)
+	subject := fmt.Sprintf("⛑ Kwatch detected a crash in pod %s ", ev.ContainerName)
 	body := fmt.Sprintf(
 		"An alert for cluster: *%s* Name: *%s*  Container: *%s* "+
 			"Namespace: *%s*  "+
 			"has been triggered:\\n—\\n "+
 			"Logs: *%s* \\n "+
 			"Events: *%s* ",
 		e.appCfg.ClusterName,
-		ev.Name,
-		ev.Container,
+		ev.PodName,
+		ev.ContainerName,
 		ev.Namespace,
 		logsText,
 		eventsText,

alertmanager/email/email_test.go

@@ -122,11 +122,11 @@ func TestSendEvent(t *testing.T) {
 
 	c.send = mockedSend
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/feishu/feishu_test.go

@@ -44,12 +44,12 @@ func TestBuildRequestBodyFeiShu(t *testing.T) {
 	c := NewFeiShu(configMap, &config.App{ClusterName: "dev"})
 	assertions.NotNil(c)
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
-		Events:    "test",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
+		Events:        "test",
 	}
 	formattedMsg := ev.FormatMarkdown(c.appCfg.ClusterName, "", "")
 
@@ -113,11 +113,11 @@ func TestSendEvent(t *testing.T) {
 	assertions.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/googlechat/googlechat_test.go

@@ -84,11 +84,11 @@ func TestSendEvent(t *testing.T) {
 	assert.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/matrix/matrix_test.go

@@ -118,11 +118,11 @@ func TestSendEvent(t *testing.T) {
 	assert.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/mattermost/mattermost.go

@@ -149,12 +149,12 @@ func (m *Mattermost) buildMessage(e *event.Event, msg *string) []byte {
 					},
 					{
 						Title: "Name",
-						Value: e.Name,
+						Value: e.PodName,
 						Short: true,
 					},
 					{
 						Title: "Container",
-						Value: e.Container,
+						Value: e.ContainerName,
 						Short: true,
 					},
 					{

alertmanager/mattermost/mattermost_test.go

@@ -84,11 +84,11 @@ func TestSendEvent(t *testing.T) {
 	assert.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/opsgenie/opsgenie.go

@@ -121,21 +121,21 @@ func (m *Opsgenie) buildMessage(e *event.Event) []byte {
 	// use custom title if it's provided, otherwise use default
 	title := m.title
 	if len(title) == 0 {
-		title = fmt.Sprintf(defaultOpsgenieTitle, e.Name)
+		title = fmt.Sprintf(defaultOpsgenieTitle, e.PodName)
 	}
 	payload.Message = title
 
 	// use custom text if it's provided, otherwise use default
 	text := m.text
 	if len(text) == 0 {
-		text = fmt.Sprintf(defaultOpsgenieText, e.Container, e.Name)
+		text = fmt.Sprintf(defaultOpsgenieText, e.ContainerName, e.PodName)
 	}
 
 	payload.Description = text
 	payload.Details = map[string]string{
 		"Cluster":   m.appCfg.ClusterName,
-		"Name":      e.Name,
-		"Container": e.Container,
+		"Name":      e.PodName,
+		"Container": e.ContainerName,
 		"Namespace": e.Namespace,
 		"Reason":    e.Reason,
 		"Events":    events,

alertmanager/opsgenie/opsgenie_test.go

@@ -61,11 +61,11 @@ func TestSendEvent(t *testing.T) {
 	c.url = s.URL
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}
@@ -91,11 +91,11 @@ func TestSendEventError(t *testing.T) {
 	c.url = s.URL
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}
@@ -113,11 +113,11 @@ func TestInvaildHttpRequest(t *testing.T) {
 	c.url = "h ttp://localhost"
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/pagerduty/pagerduty.go

@@ -118,11 +118,11 @@ func (s *Pagerduty) buildRequestBodyPagerDuty(
 		}
 	  }`,
 		key,
-		fmt.Sprintf(defaultEventTitle, ev.Container),
-		ev.Container,
+		fmt.Sprintf(defaultEventTitle, ev.ContainerName),
+		ev.ContainerName,
 		s.appCfg.ClusterName,
-		ev.Name,
-		ev.Container,
+		ev.PodName,
+		ev.ContainerName,
 		ev.Namespace,
 		ev.Reason,
 		eventsText,

alertmanager/pagerduty/pagerduty_test.go

@@ -59,11 +59,11 @@ func TestSendEvent(t *testing.T) {
 	assert.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}
@@ -88,11 +88,11 @@ func TestSendEventError(t *testing.T) {
 	c.url = s.URL
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}
@@ -110,11 +110,11 @@ func TestInvaildHttpRequest(t *testing.T) {
 	c.url = "h ttp://localhost"
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/rocketchat/rocketchat_test.go

@@ -84,11 +84,11 @@ func TestSendEvent(t *testing.T) {
 	assert.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}

alertmanager/slack/slack.go

@@ -83,8 +83,8 @@ func (s *Slack) SendEvent(ev *event.Event) error {
 			Type: "section",
 			Fields: []*slackClient.TextBlockObject{
 				markdownF("*Cluster*\n%s", s.appCfg.ClusterName),
-				markdownF("*Name*\n%s", ev.Name),
-				markdownF("*Container*\n%s", ev.Container),
+				markdownF("*Name*\n%s", ev.PodName),
+				markdownF("*Container*\n%s", ev.ContainerName),
 				markdownF("*Namespace*\n%s", ev.Namespace),
 				markdownF("*Reason*\n%s", ev.Reason),
 			},

alertmanager/slack/slack_test.go

@@ -55,10 +55,10 @@ func TestSendEvent(t *testing.T) {
 	s.send = mockedSend
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
 		Logs: "Nam quis nulla. Integer malesuada. In in enim a arcu " +
 			"imperdiet malesuada. Sed vel lectus. Donec odio urna, tempus " +
 			"molestie, porttitor ut, iaculis quis, sem. Phasellus rhoncus.\n" +

alertmanager/teams/teams_test.go

@@ -84,11 +84,11 @@ func TestSendEvent(t *testing.T) {
 	assert.NotNil(c)
 
 	ev := event.Event{
-		Name:      "test-pod",
-		Container: "test-container",
-		Namespace: "default",
-		Reason:    "OOMKILLED",
-		Logs:      "test\ntestlogs",
+		PodName:       "test-pod",
+		ContainerName: "test-container",
+		Namespace:     "default",
+		Reason:        "OOMKILLED",
+		Logs:          "test\ntestlogs",
 		Events: "event1-event2-event3-event1-event2-event3-event1-event2-" +
 			"event3\nevent5\nevent6-event8-event11-event12",
 	}