Method ServeHTTP

pkg/ha/ha_tracker_http.go:64–109

(w http.ResponseWriter, req *http.Request)

}

func (h *HATracker) ServeHTTP(w http.ResponseWriter, req *http.Request) {
	h.electedLock.RLock()
	type replica struct {
		UserID       string        `json:"userID"`
		Cluster      string        `json:"cluster"`
		Replica      string        `json:"replica"`
		ElectedAt    time.Time     `json:"electedAt"`
		UpdateTime   time.Duration `json:"updateDuration"`
		FailoverTime time.Duration `json:"failoverDuration"`
	}

	electedReplicas := []replica{}
	for key, desc := range h.elected {
		chunks := strings.SplitN(key, "/", 2)

		electedReplicas = append(electedReplicas, replica{
			UserID:       chunks[0],
			Cluster:      chunks[1],
			Replica:      desc.Replica,
			ElectedAt:    timestamp.Time(desc.ReceivedAt),
			UpdateTime:   time.Until(timestamp.Time(desc.ReceivedAt).Add(h.cfg.UpdateTimeout)),
			FailoverTime: time.Until(timestamp.Time(desc.ReceivedAt).Add(h.cfg.FailoverTimeout)),
		})
	}
	h.electedLock.RUnlock()

	sort.Slice(electedReplicas, func(i, j int) bool {
		first := electedReplicas[i]
		second := electedReplicas[j]

		if first.UserID != second.UserID {
			return first.UserID < second.UserID
		}
		return first.Cluster < second.Cluster
	})

	util.RenderHTTPResponse(w, struct {
		Elected []replica             `json:"elected"`
		Now     time.Time             `json:"now"`
		Config  HATrackerStatusConfig `json:"config"`
	}{
		Elected: electedReplicas,
		Now:     time.Now(),
		Config:  h.trackerStatusConfig,
	}, trackerTmpl, req)
}