pager-stats/pager-stats.go at master · morganda/pager-stats · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package main

import (
	"bufio"
	"encoding/csv"
	"fmt"
	"io"
	"log"
	"os"
	"strings"
)

const policyName = "Cloud SaaS Incident Management"

// Strings to match on a page
const oldctorOutOfCapacity = "has logged a NotEnoughCapacity"
const ctorOutOfCapacity = "cannot find enough available allocator capacity"
const allocatorsDown = "Website | Your site 'Allocators:"
const soteriaallocatorsDown = "Soteria :: Allocator is Unhealthy"
const esspallocatorsDown = "for check 'Allocators'"
const loggingDown = "Website | Your site 'Logging:"
const metricsDown = "Website | Your site 'Metrics:"
const monitorDown = "Website | Your site 'Monitor:"
const othersDown = "went down"
const esspothersDown = "Heartbeat Alert"
const indexFreshness = "Index freshness alert"
const terminatedOnHostError = "Instance(s) Terminated on Host Error"
const incidents = "Cloudbot's created a new incident"
const zookeeperDisk = "Sent bytes for cloud-production-168820 director"

type pageInfo struct {
	PageNumber  string
	Description string
	PolicyName  string
	CreatedOn   string
}

// extractPage maps csv line to a pageInfo
func extractPage(rawPageInfo []string) pageInfo {
	ii := pageInfo{
		PageNumber:  rawPageInfo[1],
		Description: rawPageInfo[2],
		PolicyName:  rawPageInfo[6],
		CreatedOn:   rawPageInfo[7],
	}
	return ii
}

func extractPageInfo(csvReader *csv.Reader) []pageInfo {
	var pageInfos []pageInfo
	for {
		line, error := csvReader.Read()
		if error == io.EOF {
			break
		} else if error != nil {
			log.Fatal(error)
		}
		page := extractPage(line)
		if page.PolicyName == policyName {
			pageInfos = append(pageInfos, page)
		}
	}
	return pageInfos
}

func getMatchPageCount(pageInfos []pageInfo, descriptionMatch string) int {
	count := 0
	for _, page := range pageInfos {
		if strings.Contains(page.Description, descriptionMatch) {
			count++
		}
	}
	return count
}

func printPageStats(pageInfos []pageInfo) {
	oldctorooc := getMatchPageCount(pageInfos, oldctorOutOfCapacity)
	ctorooc := getMatchPageCount(pageInfos, ctorOutOfCapacity)
	othersdown := getMatchPageCount(pageInfos, othersDown)
	esspothersdown := getMatchPageCount(pageInfos, esspothersDown)
	allocatorsdown := getMatchPageCount(pageInfos, allocatorsDown)
	soteriaallocatorsdown := getMatchPageCount(pageInfos, soteriaallocatorsDown)
	esspallocatorsdown := getMatchPageCount(pageInfos, esspallocatorsDown)
	alldown := othersdown + esspothersdown
	nonsoteriaallocatorsdown := esspallocatorsdown + allocatorsdown
	allallocators := nonsoteriaallocatorsdown + soteriaallocatorsdown
	loggingMetricsDown := getMatchPageCount(pageInfos, loggingDown) + getMatchPageCount(pageInfos, metricsDown) + getMatchPageCount(pageInfos, monitorDown)

	template := "%d pages in the past month, which break down to %d related to capacity (0 needing more capacity, %d constructor out of capacity), %d pages for failed allocators, %d GCP allocators rebuilt with old templates, %d pages for incidents, %d for logging or metrics down, %d for index freshness and %d pages for non-allocator host failures.\n"
	fmt.Printf(template, len(pageInfos), ctorooc+oldctorooc, ctorooc+oldctorooc, allallocators, getMatchPageCount(pageInfos, terminatedOnHostError), getMatchPageCount(pageInfos, incidents), loggingMetricsDown, getMatchPageCount(pageInfos, indexFreshness), alldown-loggingMetricsDown-nonsoteriaallocatorsdown)

	fmt.Printf("\n\nCopy the following into a spreadsheet to create a pretty piechart graph. It should paste cleanly into separate cells.\n\n")
	fmt.Printf("Total Alerts:\t%d\n", len(pageInfos))
	fmt.Printf("Ctor Out of Capacity Alerts:\t%d\n", ctorooc+oldctorooc)
	fmt.Printf("Total Zookeeper Disk Alerts:\t%d\n", getMatchPageCount(pageInfos, zookeeperDisk))
	fmt.Printf("Bad Allocators:\t%d\n", allallocators)
	fmt.Printf("Allocators on Old Templates:\t%d\n", getMatchPageCount(pageInfos, terminatedOnHostError))
	fmt.Printf("Total Incidents:\t%d\n", getMatchPageCount(pageInfos, incidents))
	fmt.Printf("Total Logging/Metrics:\t%d\n", loggingMetricsDown)
	fmt.Printf("Total Index Freshness:\t%d\n", getMatchPageCount(pageInfos, indexFreshness))
	fmt.Printf("Non-allocator-failures:\t%d\n", alldown-loggingMetricsDown-nonsoteriaallocatorsdown)
}

func main() {
	if len(os.Args) != 2 {
		fmt.Println("Usage: ./pager-stats <pager-duty csv file>")
		os.Exit(1)
	}
	csvFileName := os.Args[1]
	csvFile, _ := os.Open(csvFileName)
	reader := csv.NewReader(bufio.NewReader(csvFile))
	pageInfos := extractPageInfo(reader)
	printPageStats(pageInfos)
}