Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f66276c24f |
+3
-58
@@ -45,70 +45,15 @@ trigger:
|
|||||||
- refs/tags/v*
|
- refs/tags/v*
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: build all binaries
|
|
||||||
image: golang:1.12
|
|
||||||
commands:
|
|
||||||
- make all
|
|
||||||
|
|
||||||
- name: push image - arm
|
# Might consider moving this step into the previous pipeline
|
||||||
|
- name: push image
|
||||||
image: plugins/docker
|
image: plugins/docker
|
||||||
settings:
|
settings:
|
||||||
repo: iamthefij/minitor-go
|
repo: iamthefij/minitor-go
|
||||||
|
dockerfile: Dockerfile.multi-stage
|
||||||
auto_tag: true
|
auto_tag: true
|
||||||
auto_tag_suffix: linux-arm
|
|
||||||
username:
|
username:
|
||||||
from_secret: docker_username
|
from_secret: docker_username
|
||||||
password:
|
password:
|
||||||
from_secret: docker_password
|
from_secret: docker_password
|
||||||
build_args:
|
|
||||||
- ARCH=arm
|
|
||||||
- REPO=arm32v7
|
|
||||||
|
|
||||||
- name: push image - arm64
|
|
||||||
image: plugins/docker
|
|
||||||
settings:
|
|
||||||
repo: iamthefij/minitor-go
|
|
||||||
auto_tag: true
|
|
||||||
auto_tag_suffix: linux-arm64
|
|
||||||
username:
|
|
||||||
from_secret: docker_username
|
|
||||||
password:
|
|
||||||
from_secret: docker_password
|
|
||||||
build_args:
|
|
||||||
- ARCH=arm64
|
|
||||||
- REPO=arm64v8
|
|
||||||
|
|
||||||
- name: push image - amd64
|
|
||||||
image: plugins/docker
|
|
||||||
settings:
|
|
||||||
repo: iamthefij/minitor-go
|
|
||||||
auto_tag: true
|
|
||||||
auto_tag_suffix: linux-amd64
|
|
||||||
username:
|
|
||||||
from_secret: docker_username
|
|
||||||
password:
|
|
||||||
from_secret: docker_password
|
|
||||||
|
|
||||||
- name: publish manifest
|
|
||||||
image: plugins/manifest
|
|
||||||
settings:
|
|
||||||
spec: manifest.tmpl
|
|
||||||
auto_tag: true
|
|
||||||
ignore_missing: true
|
|
||||||
username:
|
|
||||||
from_secret: docker_username
|
|
||||||
password:
|
|
||||||
from_secret: docker_password
|
|
||||||
|
|
||||||
- name: notify
|
|
||||||
image: drillster/drone-email
|
|
||||||
settings:
|
|
||||||
host:
|
|
||||||
from_secret: SMTP_HOST
|
|
||||||
username:
|
|
||||||
from_secret: SMTP_USER
|
|
||||||
password:
|
|
||||||
from_secret: SMTP_PASS
|
|
||||||
from: drone@iamthefij.com
|
|
||||||
when:
|
|
||||||
status: [changed, failure]
|
|
||||||
|
|||||||
Vendored
+1
-3
@@ -16,6 +16,4 @@
|
|||||||
config.yml
|
config.yml
|
||||||
|
|
||||||
# Output binary
|
# Output binary
|
||||||
minitor
|
minitor-go
|
||||||
minitor-linux-*
|
|
||||||
minitor-darwin-amd64
|
|
||||||
|
|||||||
+5
-9
@@ -1,13 +1,12 @@
|
|||||||
ARG REPO=library
|
ARG REPO=library
|
||||||
FROM multiarch/qemu-user-static:4.2.0-2 as qemu-user-static
|
|
||||||
FROM ${REPO}/alpine:3.10
|
FROM ${REPO}/alpine:3.10
|
||||||
|
|
||||||
# Copying all qemu files because amd64 doesn't exist and cannot condional copy
|
|
||||||
COPY --from=qemu-user-static /usr/bin/qemu-* /usr/bin/
|
|
||||||
|
|
||||||
RUN mkdir /app
|
RUN mkdir /app
|
||||||
WORKDIR /app/
|
WORKDIR /app/
|
||||||
|
|
||||||
|
# Copy minitor in
|
||||||
|
ARG ARCH=amd64
|
||||||
|
COPY ./minitor-go ./minitor
|
||||||
|
|
||||||
# Add common checking tools
|
# Add common checking tools
|
||||||
RUN apk --no-cache add bash=~5.0 curl=~7.66 jq=~1.6
|
RUN apk --no-cache add bash=~5.0 curl=~7.66 jq=~1.6
|
||||||
|
|
||||||
@@ -16,12 +15,9 @@ RUN addgroup -S minitor && adduser -S minitor -G minitor
|
|||||||
|
|
||||||
# Copy scripts
|
# Copy scripts
|
||||||
COPY ./scripts /app/scripts
|
COPY ./scripts /app/scripts
|
||||||
|
RUN chown -R minitor:minitor /app
|
||||||
RUN chmod -R 755 /app/scripts
|
RUN chmod -R 755 /app/scripts
|
||||||
|
|
||||||
# Copy minitor in
|
|
||||||
ARG ARCH=amd64
|
|
||||||
COPY ./minitor-linux-${ARCH} ./minitor
|
|
||||||
|
|
||||||
# Drop to non-root user
|
# Drop to non-root user
|
||||||
USER minitor
|
USER minitor
|
||||||
|
|
||||||
|
|||||||
@@ -31,6 +31,7 @@ RUN addgroup -S minitor && adduser -S minitor -G minitor
|
|||||||
|
|
||||||
# Copy scripts
|
# Copy scripts
|
||||||
COPY ./scripts /app/scripts
|
COPY ./scripts /app/scripts
|
||||||
|
RUN chown -R minitor:minitor /app
|
||||||
RUN chmod -R 755 /app/scripts
|
RUN chmod -R 755 /app/scripts
|
||||||
|
|
||||||
# Drop to non-root user
|
# Drop to non-root user
|
||||||
|
|||||||
@@ -1,28 +1,23 @@
|
|||||||
DOCKER_TAG ?= minitor-go-${USER}
|
|
||||||
GIT_TAG_NAME := $(shell git tag -l --contains HEAD)
|
|
||||||
GIT_SHA := $(shell git rev-parse HEAD)
|
|
||||||
VERSION := $(if $(GIT_TAG_NAME),$(GIT_TAG_NAME),$(GIT_SHA))
|
|
||||||
|
|
||||||
.PHONY: all
|
.PHONY: all
|
||||||
all: minitor-linux-amd64 minitor-linux-arm minitor-linux-arm64
|
DOCKER_TAG ?= minitor-go-${USER}
|
||||||
|
|
||||||
.PHONY: default
|
.PHONY: default
|
||||||
default: test
|
default: test
|
||||||
|
|
||||||
.PHONY: build
|
.PHONY: build
|
||||||
build: minitor
|
build:
|
||||||
|
go build
|
||||||
|
|
||||||
minitor:
|
minitor-go:
|
||||||
@echo Version: $(VERSION)
|
go build
|
||||||
go build -ldflags '-X "main.version=${VERSION}"' -o minitor
|
|
||||||
|
|
||||||
.PHONY: run
|
.PHONY: run
|
||||||
run: minitor build
|
run: minitor-go build
|
||||||
./minitor -debug
|
./minitor-go -debug
|
||||||
|
|
||||||
.PHONY: run-metrics
|
.PHONY: run-metrics
|
||||||
run-metrics: minitor build
|
run-metrics: minitor-go build
|
||||||
./minitor -debug -metrics
|
./minitor-go -debug -metrics
|
||||||
|
|
||||||
.PHONY: test
|
.PHONY: test
|
||||||
test:
|
test:
|
||||||
@@ -46,56 +41,13 @@ check:
|
|||||||
|
|
||||||
.PHONY: clean
|
.PHONY: clean
|
||||||
clean:
|
clean:
|
||||||
rm -f ./minitor
|
rm -f ./minitor-go
|
||||||
rm -f ./minitor-linux-*
|
|
||||||
rm -f ./minitor-darwin-amd64
|
|
||||||
rm -f ./coverage.out
|
rm -f ./coverage.out
|
||||||
|
|
||||||
.PHONY: docker-build
|
.PHONY: docker-build
|
||||||
docker-build:
|
docker-build:
|
||||||
docker build -f ./Dockerfile.multi-stage -t $(DOCKER_TAG)-linux-amd64 .
|
docker build -f ./Dockerfile.multi-stage -t $(DOCKER_TAG) .
|
||||||
|
|
||||||
.PHONY: docker-run
|
.PHONY: docker-run
|
||||||
docker-run: docker-build
|
docker-run: docker-build
|
||||||
docker run --rm -v $(shell pwd)/config.yml:/root/config.yml $(DOCKER_TAG)
|
docker run --rm -v $(shell pwd)/config.yml:/root/config.yml $(DOCKER_TAG)
|
||||||
|
|
||||||
## Multi-arch targets
|
|
||||||
|
|
||||||
# Arch specific go build targets
|
|
||||||
minitor-darwin-amd64:
|
|
||||||
GOOS=darwin GOARCH=amd64 CGO_ENABLED=0 \
|
|
||||||
go build -ldflags '-X "main.version=${VERSION}"' -a -installsuffix nocgo \
|
|
||||||
-o minitor-darwin-amd64
|
|
||||||
|
|
||||||
minitor-linux-amd64:
|
|
||||||
GOOS=linux GOARCH=amd64 CGO_ENABLED=0 \
|
|
||||||
go build -ldflags '-X "main.version=${VERSION}"' -a -installsuffix nocgo \
|
|
||||||
-o minitor-linux-amd64
|
|
||||||
|
|
||||||
minitor-linux-arm:
|
|
||||||
GOOS=linux GOARCH=arm CGO_ENABLED=0 \
|
|
||||||
go build -ldflags '-X "main.version=${VERSION}"' -a -installsuffix nocgo \
|
|
||||||
-o minitor-linux-arm
|
|
||||||
|
|
||||||
minitor-linux-arm64:
|
|
||||||
GOOS=linux GOARCH=arm64 CGO_ENABLED=0 \
|
|
||||||
go build -ldflags '-X "main.version=${VERSION}"' -a -installsuffix nocgo \
|
|
||||||
-o minitor-linux-arm64
|
|
||||||
|
|
||||||
# Arch specific docker build targets
|
|
||||||
.PHONY: docker-build-arm
|
|
||||||
docker-build-arm: minitor-linux-arm
|
|
||||||
docker build --build-arg REPO=arm32v7 --build-arg ARCH=arm . -t ${DOCKER_TAG}-linux-arm
|
|
||||||
|
|
||||||
.PHONY: docker-build-arm
|
|
||||||
docker-build-arm64: minitor-linux-arm64
|
|
||||||
docker build --build-arg REPO=arm64v8 --build-arg ARCH=arm64 . -t ${DOCKER_TAG}-linux-arm64
|
|
||||||
|
|
||||||
# Cross run on host architechture
|
|
||||||
.PHONY: docker-run-arm
|
|
||||||
docker-run-arm: docker-build-arm
|
|
||||||
docker run --rm -v /var/run/docker.sock:/var/run/docker.sock --name $(DOCKER_TAG)-run ${DOCKER_TAG}-linux-arm
|
|
||||||
|
|
||||||
.PHONY: docker-run-arm64
|
|
||||||
docker-run-arm64: docker-build-arm64
|
|
||||||
docker run --rm -v /var/run/docker.sock:/var/run/docker.sock --name $(DOCKER_TAG)-run ${DOCKER_TAG}-linux-arm64
|
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"log"
|
"log"
|
||||||
|
"os"
|
||||||
|
|
||||||
"gopkg.in/yaml.v2"
|
"gopkg.in/yaml.v2"
|
||||||
)
|
)
|
||||||
@@ -77,7 +78,9 @@ func LoadConfig(filePath string) (config Config, err error) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
err = yaml.Unmarshal(data, &config)
|
// TODO: Decide if this is better expanded here, or only when executing
|
||||||
|
envExpanded := os.ExpandEnv(string(data))
|
||||||
|
err = yaml.Unmarshal([]byte(envExpanded), &config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-66
@@ -23,74 +23,9 @@ func TestLoadConfig(t *testing.T) {
|
|||||||
_, err := LoadConfig(c.configPath)
|
_, err := LoadConfig(c.configPath)
|
||||||
hasErr := (err != nil)
|
hasErr := (err != nil)
|
||||||
if hasErr != c.expectErr {
|
if hasErr != c.expectErr {
|
||||||
t.Errorf("LoadConfig(%v), expected_error=%v actual=%v", c.name, c.expectErr, err)
|
t.Errorf("LoadConfig(%v), expected=%v actual=%v", c.name, "Err", err)
|
||||||
log.Printf("Case failed: %s", c.name)
|
log.Printf("Case failed: %s", c.name)
|
||||||
}
|
}
|
||||||
log.Println("-----")
|
log.Println("-----")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TestMultiLineConfig is a more complicated test stepping through the parsing
|
|
||||||
// and execution of mutli-line strings presented in YAML
|
|
||||||
func TestMultiLineConfig(t *testing.T) {
|
|
||||||
log.Println("Testing multi-line string config")
|
|
||||||
config, err := LoadConfig("./test/valid-verify-multi-line.yml")
|
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("TestMultiLineConfig(load), expected=no_error actual=%v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Println("-----")
|
|
||||||
log.Println("TestMultiLineConfig(parse > string)")
|
|
||||||
expected := "echo 'Some string with stuff'; echo \"<angle brackets>\"; exit 1\n"
|
|
||||||
actual := config.Monitors[0].CommandShell
|
|
||||||
if expected != actual {
|
|
||||||
t.Errorf("TestMultiLineConfig(>) failed")
|
|
||||||
t.Logf("string expected=`%v`", expected)
|
|
||||||
t.Logf("string actual =`%v`", actual)
|
|
||||||
t.Logf("bytes expected=%v", []byte(expected))
|
|
||||||
t.Logf("bytes actual =%v", []byte(actual))
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Println("-----")
|
|
||||||
log.Println("TestMultiLineConfig(execute > string)")
|
|
||||||
_, notice := config.Monitors[0].Check()
|
|
||||||
if notice == nil {
|
|
||||||
t.Fatalf("Did not receive an alert notice")
|
|
||||||
}
|
|
||||||
expected = "Some string with stuff\n<angle brackets>\n"
|
|
||||||
actual = notice.LastCheckOutput
|
|
||||||
if expected != actual {
|
|
||||||
t.Errorf("TestMultiLineConfig(execute > string) check failed")
|
|
||||||
t.Logf("string expected=`%v`", expected)
|
|
||||||
t.Logf("string actual =`%v`", actual)
|
|
||||||
t.Logf("bytes expected=%v", []byte(expected))
|
|
||||||
t.Logf("bytes actual =%v", []byte(actual))
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Println("-----")
|
|
||||||
log.Println("TestMultiLineConfig(parse | string)")
|
|
||||||
expected = "echo 'Some string with stuff'\necho '<angle brackets>'\n"
|
|
||||||
actual = config.Alerts["log_shell"].CommandShell
|
|
||||||
if expected != actual {
|
|
||||||
t.Errorf("TestMultiLineConfig(|) failed")
|
|
||||||
t.Logf("string expected=`%v`", expected)
|
|
||||||
t.Logf("string actual =`%v`", actual)
|
|
||||||
t.Logf("bytes expected=%v", []byte(expected))
|
|
||||||
t.Logf("bytes actual =%v", []byte(actual))
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Println("-----")
|
|
||||||
log.Println("TestMultiLineConfig(execute | string)")
|
|
||||||
actual, err = config.Alerts["log_shell"].Send(AlertNotice{})
|
|
||||||
if err != nil {
|
|
||||||
t.Errorf("Execution of alert failed")
|
|
||||||
}
|
|
||||||
expected = "Some string with stuff\n<angle brackets>\n"
|
|
||||||
if expected != actual {
|
|
||||||
t.Errorf("TestMultiLineConfig(execute | string) check failed")
|
|
||||||
t.Logf("string expected=`%v`", expected)
|
|
||||||
t.Logf("string actual =`%v`", actual)
|
|
||||||
t.Logf("bytes expected=%v", []byte(expected))
|
|
||||||
t.Logf("bytes actual =%v", []byte(actual))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,25 +0,0 @@
|
|||||||
image: iamthefij/minitor-go:{{#if build.tag}}{{trimPrefix "v" build.tag}}{{else}}latest{{/if}}
|
|
||||||
{{#if build.tags}}
|
|
||||||
tags:
|
|
||||||
{{#each build.tags}}
|
|
||||||
- {{this}}
|
|
||||||
{{/each}}
|
|
||||||
{{/if}}
|
|
||||||
manifests:
|
|
||||||
-
|
|
||||||
image: iamthefij/minitor-go:{{#if build.tag}}{{trimPrefix "v" build.tag}}-{{/if}}linux-amd64
|
|
||||||
platform:
|
|
||||||
architecture: amd64
|
|
||||||
os: linux
|
|
||||||
-
|
|
||||||
image: iamthefij/minitor-go:{{#if build.tag}}{{trimPrefix "v" build.tag}}-{{/if}}linux-arm64
|
|
||||||
platform:
|
|
||||||
architecture: arm64
|
|
||||||
os: linux
|
|
||||||
variant: v8
|
|
||||||
-
|
|
||||||
image: iamthefij/minitor-go:{{#if build.tag}}{{trimPrefix "v" build.tag}}-{{/if}}linux-arm
|
|
||||||
platform:
|
|
||||||
architecture: arm
|
|
||||||
os: linux
|
|
||||||
variant: v7
|
|
||||||
+4
-2
@@ -155,16 +155,18 @@ func (monitor Monitor) getAlertAfter() int16 {
|
|||||||
// Zero is one!
|
// Zero is one!
|
||||||
if monitor.AlertAfter == 0 {
|
if monitor.AlertAfter == 0 {
|
||||||
return 1
|
return 1
|
||||||
}
|
} else {
|
||||||
return monitor.AlertAfter
|
return monitor.AlertAfter
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// GetAlertNames gives a list of alert names for a given monitor status
|
// GetAlertNames gives a list of alert names for a given monitor status
|
||||||
func (monitor Monitor) GetAlertNames(up bool) []string {
|
func (monitor Monitor) GetAlertNames(up bool) []string {
|
||||||
if up {
|
if up {
|
||||||
return monitor.AlertUp
|
return monitor.AlertUp
|
||||||
}
|
} else {
|
||||||
return monitor.AlertDown
|
return monitor.AlertDown
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (monitor Monitor) createAlertNotice(isUp bool) *AlertNotice {
|
func (monitor Monitor) createAlertNotice(isUp bool) *AlertNotice {
|
||||||
|
|||||||
@@ -1,10 +1,9 @@
|
|||||||
---
|
|
||||||
check_interval: 1
|
check_interval: 1
|
||||||
|
|
||||||
monitors:
|
monitors:
|
||||||
- name: Command
|
- name: Command
|
||||||
command: ['echo', '$PATH']
|
command: ['echo', '$PATH']
|
||||||
alert_down: ['log_command', 'log_shell']
|
alert_down: [ 'log_command', 'log_shell' ]
|
||||||
alert_every: 0
|
alert_every: 0
|
||||||
- name: Shell
|
- name: Shell
|
||||||
command_shell: >
|
command_shell: >
|
||||||
@@ -12,12 +11,12 @@ monitors:
|
|||||||
echo 'another line';
|
echo 'another line';
|
||||||
echo $PATH;
|
echo $PATH;
|
||||||
exit 1
|
exit 1
|
||||||
alert_down: ['log_command', 'log_shell']
|
alert_down: [ 'log_command', 'log_shell' ]
|
||||||
alert_after: 5
|
alert_after: 5
|
||||||
alert_every: 0
|
alert_every: 0
|
||||||
|
|
||||||
alerts:
|
alerts:
|
||||||
log_command:
|
log_command:
|
||||||
command: ['echo', 'regular', '"command!!!"', "{{.MonitorName}}"]
|
command: [ 'echo', 'regular', '"command!!!"', "{{.MonitorName}}" ]
|
||||||
log_shell:
|
log_shell:
|
||||||
command_shell: echo "Failure on {{.MonitorName}} User is $USER"
|
command_shell: echo "Failure on {{.MonitorName}} User is $USER"
|
||||||
|
|||||||
@@ -1,18 +0,0 @@
|
|||||||
---
|
|
||||||
check_interval: 1
|
|
||||||
|
|
||||||
monitors:
|
|
||||||
- name: Shell
|
|
||||||
command_shell: >
|
|
||||||
echo 'Some string with stuff';
|
|
||||||
echo "<angle brackets>";
|
|
||||||
exit 1
|
|
||||||
alert_down: ['log_shell']
|
|
||||||
alert_after: 1
|
|
||||||
alert_every: 0
|
|
||||||
|
|
||||||
alerts:
|
|
||||||
log_shell:
|
|
||||||
command_shell: |
|
|
||||||
echo 'Some string with stuff'
|
|
||||||
echo '<angle brackets>'
|
|
||||||
@@ -5,9 +5,19 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// escapeCommandShell accepts a command to be executed by a shell and escapes it
|
||||||
|
func escapeCommandShell(command string) string {
|
||||||
|
// Remove extra spaces and newlines from ends
|
||||||
|
command = strings.TrimSpace(command)
|
||||||
|
// TODO: Not sure if this part is actually needed. Should verify
|
||||||
|
// Escape double quotes since this will be passed in as an argument
|
||||||
|
command = strings.Replace(command, `"`, `\"`, -1)
|
||||||
|
return command
|
||||||
|
}
|
||||||
|
|
||||||
// ShellCommand takes a string and executes it as a command using `sh`
|
// ShellCommand takes a string and executes it as a command using `sh`
|
||||||
func ShellCommand(command string) *exec.Cmd {
|
func ShellCommand(command string) *exec.Cmd {
|
||||||
shellCommand := []string{"sh", "-c", strings.TrimSpace(command)}
|
shellCommand := []string{"sh", "-c", escapeCommandShell(command)}
|
||||||
//log.Printf("Shell command: %v", shellCommand)
|
//log.Printf("Shell command: %v", shellCommand)
|
||||||
return exec.Command(shellCommand[0], shellCommand[1:]...)
|
return exec.Command(shellCommand[0], shellCommand[1:]...)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user