Remove some dead code in stats

sandeepone · Feb 29, 2020 · 25dd85c · 25dd85c
1 parent 1a5e258
commit 25dd85c
Showing 1 changed file with 2 additions and 82 deletions.
diff --git a/river/status.go b/river/status.go
@@ -49,18 +49,8 @@ type stat struct {
 	DeleteAffectedRows  sync2.AtomicUint64
 	DeleteQueries       sync2.AtomicUint64
 	DeleteQueryDocs     sync2.AtomicUint64
-
-	// RebuildLog []buildLogRecord
 }
 
-// type buildLogRecord struct {
-// 	ID         string
-// 	IndexList  []string
-// 	StartedAt  time.Time
-// 	FinishedAt *time.Time
-// 	Success    bool
-// }
-
 type statusInfo struct {
 	Uptime               string
 	UptimeNano           int64
@@ -85,10 +75,8 @@ type statusInfo struct {
 	DeleteAffectedRows   uint64
 	DeleteQueries        uint64
 	DeleteQueryDocs      uint64
-	// RebuildInProgress    []string
-	// RebuildLog           []buildLogRecord
-	Running bool
-	Syncing bool
+	Running              bool
+	Syncing              bool
 }
 
 var getStatusInfo func() interface{}
@@ -157,31 +145,6 @@ func (s *stat) getStatusInfo() interface{} {
 	return status
 }
 
-// func (s *stat) logRebuildStart(b indexGroupBuild) {
-// 	s.m.Lock()
-// 	defer s.m.Unlock()
-// 	r := buildLogRecord{
-// 		ID:        b.id,
-// 		IndexList: b.indexSlice(),
-// 		StartedAt: time.Now(),
-// 	}
-// 	s.RebuildLog = append(s.RebuildLog, r)
-// }
-
-// func (s *stat) logRebuildFinish(buildID string, err error) {
-// 	s.m.Lock()
-// 	defer s.m.Unlock()
-// 	for i, r := range s.RebuildLog {
-// 		if r.ID == buildID {
-// 			now := time.Now()
-// 			r.FinishedAt = &now
-// 			r.Success = err == nil
-// 			s.RebuildLog[i] = r
-// 			break
-// 		}
-// 	}
-// }
-
 func (s *stat) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	var buf bytes.Buffer
 	encoder := json.NewEncoder(&buf)
@@ -306,49 +269,6 @@ func handleReadyz(s *stat) http.HandlerFunc {
 	})
 }
 
-// func handleRebuildRedir() http.HandlerFunc {
-// 	return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
-// 		w.Header().Add("Link", "</rebuild/sync>; rel=\"alternate\"")
-// 		w.Header().Add("Link", "</rebuild/async>; rel=\"alternate\"")
-// 		w.WriteHeader(http.StatusMultipleChoices)
-// 		w.Write([]byte(`
-// <html>
-// 	<body>
-// 		<p>You can rebuild all configured indexes by making a POST request to one of these endpoints:</p>
-// 		<ul>
-// 			<li><a href="/rebuild/sync">/rebuild/sync</a> - synchronously</li>
-// 			<li><a href="/rebuild/async">/rebuild/async</a> - asynchronously</li>
-// 		</ul>
-// 	</body>
-// </html>
-// 		`))
-// 	})
-// }
-
-// func handleRebuild(r *River, sync bool) http.HandlerFunc {
-// 	return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
-// 		w.Header().Set("Content-Type", "text/plain; charset=utf-8")
-// 		if req.Method != http.MethodPost {
-// 			w.WriteHeader(http.StatusMethodNotAllowed)
-// 			w.Write([]byte("unexpected method\n"))
-// 			return
-// 		}
-// 		reason := "requested via http endpoint"
-// 		if sync {
-// 			err := r.rebuildAll(req.Context(), reason)
-// 			if err != nil {
-// 				w.WriteHeader(http.StatusInternalServerError)
-// 				w.Write([]byte(errors.ErrorStack(err)))
-// 			} else {
-// 				w.WriteHeader(http.StatusNoContent)
-// 			}
-// 		} else {
-// 			go r.rebuildAll(nil, reason)
-// 			w.WriteHeader(http.StatusAccepted)
-// 		}
-// 	})
-// }
-
 func handleStartSync(r *River, sync bool) http.HandlerFunc {
 	return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
 		w.Header().Set("Content-Type", "text/plain; charset=utf-8")