From e15bc6df11d666ca64c5b8fb4e07ba1639e4b158 Mon Sep 17 00:00:00 2001
From: Philip O'Toole <philip@influxdb.com>
Date: Tue, 1 Sep 2015 23:15:57 -0700
Subject: [PATCH] Remove obsolete TSDB monitor file

This functionality will be superseded by the new monitor service.
---
 tsdb/monitor.go | 83 -------------------------------------------------
 1 file changed, 83 deletions(-)
 delete mode 100644 tsdb/monitor.go

diff --git a/tsdb/monitor.go b/tsdb/monitor.go
deleted file mode 100644
index d0015ec165..0000000000
--- a/tsdb/monitor.go
+++ /dev/null
@@ -1,83 +0,0 @@
-package tsdb
-
-// Monitor represents a TSDB monitoring service.
-type Monitor struct {
-	Store interface{}
-}
-
-func (m *Monitor) Open() error  { return nil }
-func (m *Monitor) Close() error { return nil }
-
-// StartSelfMonitoring starts a goroutine which monitors the InfluxDB server
-// itself and stores the results in the specified database at a given interval.
-/*
-func (s *Server) StartSelfMonitoring(database, retention string, interval time.Duration) error {
-		if interval == 0 {
-			return fmt.Errorf("statistics check interval must be non-zero")
-		}
-
-		go func() {
-			tick := time.NewTicker(interval)
-			for {
-				<-tick.C
-
-				// Create the batch and tags
-				tags := map[string]string{"serverID": strconv.FormatUint(s.ID(), 10)}
-				if h, err := os.Hostname(); err == nil {
-					tags["host"] = h
-				}
-				batch := pointsFromStats(s.stats, tags)
-
-				// Shard-level stats.
-				tags["shardID"] = strconv.FormatUint(s.id, 10)
-				s.mu.RLock()
-				for _, sh := range s.shards {
-					if !sh.HasDataNodeID(s.id) {
-						// No stats for non-local shards.
-						continue
-					}
-					batch = append(batch, pointsFromStats(sh.stats, tags)...)
-				}
-				s.mu.RUnlock()
-
-				// Server diagnostics.
-				for _, row := range s.DiagnosticsAsRows() {
-					points, err := s.convertRowToPoints(row.Name, row)
-					if err != nil {
-						s.Logger.Printf("failed to write diagnostic row for %s: %s", row.Name, err.Error())
-						continue
-					}
-					for _, p := range points {
-						p.AddTag("serverID", strconv.FormatUint(s.ID(), 10))
-					}
-					batch = append(batch, points...)
-				}
-
-				s.WriteSeries(database, retention, batch)
-			}
-		}()
-	return nil
-}
-
-// Function for local use turns stats into a slice of points
-func pointsFromStats(st *Stats, tags map[string]string) []tsdb.Point {
-	var points []tsdb.Point
-	now := time.Now()
-	st.Walk(func(k string, v int64) {
-		point := tsdb.NewPoint(
-			st.name+"_"+k,
-			make(map[string]string),
-			map[string]interface{}{"value": int(v)},
-			now,
-		)
-		// Specifically create a new map.
-		for k, v := range tags {
-			tags[k] = v
-			point.AddTag(k, v)
-		}
-		points = append(points, point)
-	})
-
-	return points
-}
-*/