Track CloudFormation template sizes.

scheduler/cloudformation/cloudformation.go

@@ -25,6 +25,7 @@ import (
 	"github.com/remind101/empire/pkg/bytesize"
 	pglock "github.com/remind101/empire/pkg/pg/lock"
 	"github.com/remind101/empire/scheduler"
+	"github.com/remind101/empire/stats"
 	"github.com/remind101/pkg/logger"
 	"golang.org/x/net/context"
 )
@@ -217,6 +218,10 @@ func (s *Scheduler) submit(ctx context.Context, tx *sql.Tx, app *scheduler.App,
 		return err
 	}
 
+	stats.Histogram(ctx, "scheduler.cloudformation.template_size", float32(t.Size), 1.0, []string{
+		fmt.Sprintf("stack:%s", stackName),
+	})
+
 	scheduler.Publish(ctx, ss, fmt.Sprintf("Created cloudformation template: %v (%d/%d bytes)", *t.URL, t.Size, MaxTemplateSize))
 
 	tags := append(s.Tags,

stats/dogstatsd.go

@@ -36,3 +36,7 @@ func (s *Dogstatsd) Timing(name string, value time.Duration, rate float32, tags
 func (s *Dogstatsd) Gauge(name string, value float32, rate float32, tags []string) error {
 	return s.Client.Gauge(name, float64(value), tags, float64(rate))
 }
+
+func (s *Dogstatsd) Histogram(name string, value float32, rate float32, tags []string) error {
+	return s.Client.Histogram(name, float64(value), tags, float64(rate))
+}

stats/stats.go

@@ -13,6 +13,7 @@ type Stats interface {
 	Inc(name string, value int64, rate float32, tags []string) error
 	Timing(name string, value time.Duration, rate float32, tags []string) error
 	Gauge(name string, value float32, rate float32, tags []string) error
+	Histogram(name string, value float32, rate float32, tags []string) error
 }
 
 type nullStats struct{}
@@ -29,6 +30,10 @@ func (s *nullStats) Gauge(name string, value float32, rate float32, tags []strin
 	return nil
 }
 
+func (s *nullStats) Histogram(name string, value float32, rate float32, tags []string) error {
+	return nil
+}
+
 var Null = &nullStats{}
 
 // taggedStats wraps a Stats implementation to include some additional tags.
@@ -49,6 +54,10 @@ func (s *taggedStats) Gauge(name string, value float32, rate float32, tags []str
 	return s.stats.Gauge(name, value, rate, append(tags, s.tags...))
 }
 
+func (s *taggedStats) Histogram(name string, value float32, rate float32, tags []string) error {
+	return s.stats.Histogram(name, value, rate, append(tags, s.tags...))
+}
+
 // WithStats returns a new context.Context with the Stats implementation
 // embedded.
 func WithStats(ctx context.Context, stats Stats) context.Context {
@@ -92,6 +101,13 @@ func Gauge(ctx context.Context, name string, value float32, rate float32, tags [
 	return nil
 }
 
+func Histogram(ctx context.Context, name string, value float32, rate float32, tags []string) error {
+	if stats, ok := FromContext(ctx); ok {
+		return stats.Histogram(name, value, rate, tags)
+	}
+	return nil
+}
+
 type key int
 
 const (

stats/statsd.go

@@ -33,3 +33,7 @@ func (s *Statsd) Timing(name string, value time.Duration, rate float32, tags []s
 func (s *Statsd) Gauge(name string, value float32, rate float32, tags []string) error {
 	return s.client.Gauge(name, int64(value), rate)
 }
+
+func (s *Statsd) Histogram(name string, value float32, rate float32, tags []string) error {
+	return s.client.Gauge(name, int64(value), rate)
+}