server

Documentation

Index

• func NewServer(logger lager.Logger, conf *config.Config, scalingEngineDB db.ScalingEngineDB, ...) (ifrit.Runner, error)
• type ScalingHandler
  • func NewScalingHandler(logger lager.Logger, scalingEngineDB db.ScalingEngineDB, ...) *ScalingHandler
  • func (h *ScalingHandler) GetActiveSchedule(w http.ResponseWriter, r *http.Request, vars map[string]string)
  • func (h *ScalingHandler) GetScalingHistories(w http.ResponseWriter, r *http.Request, vars map[string]string)
  • func (h *ScalingHandler) RemoveActiveSchedule(w http.ResponseWriter, r *http.Request, vars map[string]string)
  • func (h *ScalingHandler) Scale(w http.ResponseWriter, r *http.Request, vars map[string]string)
  • func (h *ScalingHandler) StartActiveSchedule(w http.ResponseWriter, r *http.Request, vars map[string]string)
• type SyncHandler
  • func NewSyncHandler(logger lager.Logger, sychronizer schedule.ActiveScheduleSychronizer) *SyncHandler
  • func (s *SyncHandler) Sync(w http.ResponseWriter, r *http.Request, vars map[string]string)
• type VarsFunc
  • func (vh VarsFunc) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func NewServer

func NewServer(logger lager.Logger, conf *config.Config, scalingEngineDB db.ScalingEngineDB, scalingEngine scalingengine.ScalingEngine, synchronizer schedule.ActiveScheduleSychronizer, httpStatusCollector healthendpoint.HTTPStatusCollector) (ifrit.Runner, error)

Types

type ScalingHandler

type ScalingHandler struct {
	// contains filtered or unexported fields
}

func NewScalingHandler

func NewScalingHandler(logger lager.Logger, scalingEngineDB db.ScalingEngineDB, scalingEngine scalingengine.ScalingEngine) *ScalingHandler

func (*ScalingHandler) GetActiveSchedule

func (h *ScalingHandler) GetActiveSchedule(w http.ResponseWriter, r *http.Request, vars map[string]string)

func (*ScalingHandler) GetScalingHistories

func (h *ScalingHandler) GetScalingHistories(w http.ResponseWriter, r *http.Request, vars map[string]string)

func (*ScalingHandler) RemoveActiveSchedule

func (h *ScalingHandler) RemoveActiveSchedule(w http.ResponseWriter, r *http.Request, vars map[string]string)

func (*ScalingHandler) Scale

func (h *ScalingHandler) Scale(w http.ResponseWriter, r *http.Request, vars map[string]string)

func (*ScalingHandler) StartActiveSchedule

func (h *ScalingHandler) StartActiveSchedule(w http.ResponseWriter, r *http.Request, vars map[string]string)

type SyncHandler

type SyncHandler struct {
	// contains filtered or unexported fields
}

func NewSyncHandler

func NewSyncHandler(logger lager.Logger, sychronizer schedule.ActiveScheduleSychronizer) *SyncHandler

func (*SyncHandler) Sync

func (s *SyncHandler) Sync(w http.ResponseWriter, r *http.Request, vars map[string]string)

type VarsFunc

type VarsFunc func(w http.ResponseWriter, r *http.Request, vars map[string]string)

func (VarsFunc) ServeHTTP

func (vh VarsFunc) ServeHTTP(w http.ResponseWriter, r *http.Request)