Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var BackendsIndex = func(backends []*domain.Backend, cluster ClusterManager) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { backendsJSON, err := json.Marshal(Backends(backends).AsV0JSON(cluster)) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } w.Header().Set("Content-Type", "application/json; charset=utf-8") _, err = w.Write(backendsJSON) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } }) }
View Source
var Cluster = func(cluster ClusterManager, logger lager.Logger) http.HandlerFunc { return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { switch req.Method { case "GET": writeClusterResponse(w, cluster) return case "PATCH": handleUpdate(w, req, cluster, logger) writeClusterResponse(w, cluster) return default: http.Error(w, "Method not allowed", http.StatusMethodNotAllowed) } }) }
Functions ¶
Types ¶
type BackendJSON ¶
type Backends ¶
func (Backends) AsV0JSON ¶
func (bs Backends) AsV0JSON(cluster ClusterManager) (json []V0BackendResponse)
type ClusterAPI ¶
type ClusterAPI struct {
// contains filtered or unexported fields
}
func NewClusterAPI ¶
func (*ClusterAPI) AsJSON ¶
func (c *ClusterAPI) AsJSON() ClusterJSON
func (*ClusterAPI) DisableTraffic ¶
func (c *ClusterAPI) DisableTraffic(message string)
func (*ClusterAPI) EnableTraffic ¶
func (c *ClusterAPI) EnableTraffic(message string)
func (*ClusterAPI) ListenForActiveBackend ¶
func (c *ClusterAPI) ListenForActiveBackend()
type ClusterJSON ¶
type ClusterJSON struct {
ActiveBackend *BackendJSON `json:"activeBackend"`
TrafficEnabled bool `json:"trafficEnabled"`
Message string `json:"message"`
LastUpdated time.Time `json:"lastUpdated"`
}
type ClusterManager ¶
type ClusterManager interface {
AsJSON() ClusterJSON
EnableTraffic(string)
DisableTraffic(string)
}
type V0BackendResponse ¶
type V0BackendResponse struct {
Host string `json:"host"`
Port uint `json:"port"`
Healthy bool `json:"healthy"`
Name string `json:"name"`
CurrentSessionCount uint `json:"currentSessionCount"`
Active bool `json:"active"` // For Backwards Compatibility
TrafficEnabled bool `json:"trafficEnabled"` // For Backwards Compatibility
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.