Contents

package main

import (
	"encoding/json"
	"flapjack"
	"fmt"
	"gopkg.in/alecthomas/kingpin.v2"
	"os"
	"strings"
	"time"
)

var (
	app      = kingpin.New("oneoff", "Submits a single event to Flapjack.")
	entity   = app.Arg("entity", "Entity name").Required().String()
	check    = app.Arg("check", "Check name").Required().String()
	state    = app.Arg("state", "Current state").Required().String()
	summary  = app.Arg("summary", "Summary of event").Required().String()
	debug    = app.Flag("debug", "Enable verbose output (default false)").Bool()
	server   = app.Flag("server", "Redis server to connect to (default localhost:6380)").Default("localhost:6380").String()
	database = app.Flag("database", "Redis database to connect to (default 0)").Int()
)

func main() {
	app.Version("0.0.1")
	app.Writer(os.Stdout) // direct help to stdout
	kingpin.MustParse(app.Parse(os.Args[1:]))
	app.Writer(os.Stderr) // ... but ensure errors go to stderr

	if *debug {
		fmt.Println("Entity:", *entity)
		fmt.Println("Check:", *check)
		fmt.Println("State:", *state)
		fmt.Println("Summary:", *summary)
		fmt.Println("Debug:", *debug)
		fmt.Println("Server:", *server)
		fmt.Println("Database:", *database)
	}

	addr := strings.Split(*server, ":")
	if len(addr) != 2 {
		fmt.Println("Error: invalid address specified:", *server)
		fmt.Println("Should be in format `addr:port` (e.g. 127.0.0.1:6380)")
		os.Exit(1)
	}

	event := flapjack.Event{
		Entity:  *entity,
		Check:   *check,
		Type:    "service",
		State:   *state,
		Summary: *summary,
		Time:    time.Now().Unix(),
	}

	if *debug {
		data, _ := json.Marshal(event)
		fmt.Printf("Event data: %s\n", data)
	}

	transport, err := flapjack.Dial(*server, *database)
	if *debug {
		fmt.Printf("Transport: %+v\n", transport)
	}
	if err != nil {
		fmt.Println("Error: couldn't connect to Redis:", err)
		os.Exit(1)
	}

	reply, err := transport.Send(event)
	if *debug {
		fmt.Println("Reply from Redis:", reply)
	}
	if err != nil {
		fmt.Println("Error: couldn't send event:", err)
		os.Exit(1)
	}
}

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
flapjack-2.0.0	libexec/oneoff.go
flapjack-2.0.0rc1	libexec/oneoff.go
flapjack-2.0.0b1	libexec/oneoff.go