foosinn/viewercount
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Compare commits

base: foosinn:4f41e275d6e38a016a858c2e33bda0dd92495147
Branches Tags
foosinn:main
...
compare: foosinn:bfa35c8640e926088159249a099ed5fea4d2690e
Branches Tags
foosinn:main

3 commits
4f41e275d6 ... bfa35c8640

Author SHA1 Message Date
Stefan Schwarz
bfa35c8640 get stdout logs 2020-12-28 02:39:56 +01:00
Stefan Schwarz
9785bd983b use api version 1.40 (debian) 2020-12-28 02:39:33 +01:00
Stefan Schwarz
7492095dd1 configurable listen address 2020-12-28 02:39:08 +01:00
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
main.go
View file

@ -22,13 +22,19 @@ func main() {
if !ok { if !ok {
log.Fatalf("unable to read CONTAINER_NAME") log.Fatalf("unable to read CONTAINER_NAME")
} }
listen, ok := os.LookupEnv("LISTEN")
if !ok {
listen = ":8080"
}
defaultHeaders := map[string]string{"User-Agent": "engine-api-cli-1.0"} defaultHeaders := map[string]string{"User-Agent": "engine-api-cli-1.0"}
cli, err := client.NewClient("unix:///var/run/docker.sock", "v1.44", nil, defaultHeaders) cli, err := client.NewClient("unix:///var/run/docker.sock", "v1.40", nil, defaultHeaders)
if err != nil { if err != nil {
log.Fatalf("unread: %s", err) log.Fatalf("unread: %s", err)
} }
logs, err := cli.ContainerLogs(context.TODO(), containerName, types.ContainerLogsOptions{}) logs, err := cli.ContainerLogs(context.TODO(), containerName, types.ContainerLogsOptions{
ShowStdout: true,
})
if err != nil { if err != nil {
log.Fatalf("unread: %s", err) log.Fatalf("unread: %s", err)
} }
@ -38,7 +44,7 @@ func main() {
go counter.Scan(logs) go counter.Scan(logs)
http.HandleFunc("/", counter.MetricsHandler) http.HandleFunc("/", counter.MetricsHandler)
err = http.ListenAndServe(":8080", nil) err = http.ListenAndServe(listen, nil)
log.Fatalf("unable to listen: %s", err) log.Fatalf("unable to listen: %s", err)
} }