From 9aa1a692d0709b419dded5009dc2cf78dd0759c2 Mon Sep 17 00:00:00 2001 From: Nick White Date: Tue, 12 Nov 2019 12:51:58 +0000 Subject: Add spotme command to start appropriate spot instances --- cmd/spotme/main.go | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 53 insertions(+) create mode 100644 cmd/spotme/main.go (limited to 'cmd') diff --git a/cmd/spotme/main.go b/cmd/spotme/main.go new file mode 100644 index 0000000..99404cb --- /dev/null +++ b/cmd/spotme/main.go @@ -0,0 +1,53 @@ +package main + +import ( + "flag" + "fmt" + "log" + + "rescribe.xyz/bookpipeline" +) + +const usage = `Usage: spotme [-n num] + +Create new spot instances for the book pipeline. +` + +type SpotPipeliner interface { + Init() error + StartInstances(n int) error +} + +// NullWriter is used so non-verbose logging may be discarded +type NullWriter bool + +func (w NullWriter) Write(p []byte) (n int, err error) { + return len(p), nil +} + +func main() { + num := flag.Int("n", 1, "number of instances to start") + flag.Usage = func() { + fmt.Fprintf(flag.CommandLine.Output(), usage) + flag.PrintDefaults() + } + flag.Parse() + + var verboselog *log.Logger + var n NullWriter + verboselog = log.New(n, "", 0) + + var conn SpotPipeliner + conn = &bookpipeline.AwsConn{Region: "eu-west-2", Logger: verboselog} + err := conn.Init() + if err != nil { + log.Fatalln("Failed to set up cloud connection:", err) + } + + log.Println("Starting spot instances") + err = conn.StartInstances(*num) + if err != nil { + log.Fatalln("Failed to start a spot instance:", err) + } + log.Println("Spot instance request sent successfully") +} -- cgit v1.2.1-24-ge1ad