handlers

Documentation

Index

• Variables
• func New(logger lager.Logger, db db.DB, desiredHub, actualHub, taskHub events.Hub, ...) http.Handler
• func UnavailableWrap(handler http.Handler, serviceReady <-chan struct{}) http.HandlerFunc
• type ActualLRPHandler
  • func NewActualLRPHandler(logger lager.Logger, db db.ActualLRPDB) *ActualLRPHandler
  • func (h *ActualLRPHandler) ActualLRPGroupByProcessGuidAndIndex(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPHandler) ActualLRPGroups(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPHandler) ActualLRPGroupsByProcessGuid(w http.ResponseWriter, req *http.Request)
• type ActualLRPLifecycleHandler
  • func NewActualLRPLifecycleHandler(logger lager.Logger, db db.ActualLRPDB) *ActualLRPLifecycleHandler
  • func (h *ActualLRPLifecycleHandler) ClaimActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPLifecycleHandler) CrashActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPLifecycleHandler) FailActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPLifecycleHandler) RemoveActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPLifecycleHandler) RetireActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *ActualLRPLifecycleHandler) StartActualLRP(w http.ResponseWriter, req *http.Request)
• type CellHandler
  • func NewCellHandler(logger lager.Logger, serviceClient bbs.ServiceClient) *CellHandler
  • func (h *CellHandler) Cells(w http.ResponseWriter, req *http.Request)
• type DesiredLRPHandler
  • func NewDesiredLRPHandler(logger lager.Logger, db db.DesiredLRPDB) *DesiredLRPHandler
  • func (h *DesiredLRPHandler) DesireDesiredLRP(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) DesiredLRPByProcessGuid(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) DesiredLRPByProcessGuid_r0(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) DesiredLRPSchedulingInfos(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) DesiredLRPs(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) DesiredLRPs_r0(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) RemoveDesiredLRP(w http.ResponseWriter, req *http.Request)
  • func (h *DesiredLRPHandler) UpdateDesiredLRP(w http.ResponseWriter, req *http.Request)
• type DomainHandler
  • func NewDomainHandler(logger lager.Logger, db db.DomainDB) *DomainHandler
  • func (h *DomainHandler) Domains(w http.ResponseWriter, req *http.Request)
  • func (h *DomainHandler) Upsert(w http.ResponseWriter, req *http.Request)
• type EvacuationHandler
  • func NewEvacuationHandler(logger lager.Logger, db db.EvacuationDB) *EvacuationHandler
  • func (h *EvacuationHandler) EvacuateClaimedActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *EvacuationHandler) EvacuateCrashedActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *EvacuationHandler) EvacuateRunningActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *EvacuationHandler) EvacuateStoppedActualLRP(w http.ResponseWriter, req *http.Request)
  • func (h *EvacuationHandler) RemoveEvacuatingActualLRP(w http.ResponseWriter, req *http.Request)
• type EventFetcher
• type EventHandler
  • func NewEventHandler(logger lager.Logger, desiredHub, actualHub, taskHub events.Hub) *EventHandler
  • func (h *EventHandler) SubscribeToActualLRPEvents(w http.ResponseWriter, req *http.Request)
  • func (h *EventHandler) SubscribeToDesiredLRPEvents(w http.ResponseWriter, req *http.Request)
  • func (h *EventHandler) SubscribeToTaskEvents(w http.ResponseWriter, req *http.Request)
  • func (h *EventHandler) Subscribe_r0(w http.ResponseWriter, req *http.Request)
• type LRPConvergenceHandler
  • func NewLRPConvergenceHandler(logger lager.Logger, db db.LRPDB) *LRPConvergenceHandler
  • func (h *LRPConvergenceHandler) ConvergeLRPs(w http.ResponseWriter, req *http.Request)
• type MessageValidator
• type PingHandler
  • func NewPingHandler(logger lager.Logger) *PingHandler
  • func (h *PingHandler) Ping(w http.ResponseWriter, req *http.Request)
• type TaskHandler
  • func NewTaskHandler(logger lager.Logger, db db.TaskDB) *TaskHandler
  • func (h *TaskHandler) CancelTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) CompleteTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) ConvergeTasks(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) DeleteTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) DesireTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) FailTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) ResolvingTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) StartTask(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) TaskByGuid(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) TaskByGuid_r0(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) Tasks(w http.ResponseWriter, req *http.Request)
  • func (h *TaskHandler) Tasks_r0(w http.ResponseWriter, req *http.Request)
• type UnavailableHandler
  • func NewUnavailableHandler(handler http.Handler, serviceReadyChan <-chan struct{}) *UnavailableHandler
  • func (u *UnavailableHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Variables

var (
	ErrDomainMissing = errors.New("domain missing from request")
	ErrMaxAgeMissing = errors.New("max-age directive missing from request")
)

Functions

func New

func New(logger lager.Logger, db db.DB, desiredHub, actualHub, taskHub events.Hub, serviceClient bbs.ServiceClient, migrationsDone <-chan struct{}) http.Handler

func UnavailableWrap

func UnavailableWrap(handler http.Handler, serviceReady <-chan struct{}) http.HandlerFunc

Types

type ActualLRPHandler

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

func NewActualLRPHandler

func NewActualLRPHandler(logger lager.Logger, db db.ActualLRPDB) *ActualLRPHandler

func (*ActualLRPHandler) ActualLRPGroupByProcessGuidAndIndex

func (h *ActualLRPHandler) ActualLRPGroupByProcessGuidAndIndex(w http.ResponseWriter, req *http.Request)

func (*ActualLRPHandler) ActualLRPGroups

func (h *ActualLRPHandler) ActualLRPGroups(w http.ResponseWriter, req *http.Request)

func (*ActualLRPHandler) ActualLRPGroupsByProcessGuid

func (h *ActualLRPHandler) ActualLRPGroupsByProcessGuid(w http.ResponseWriter, req *http.Request)

type ActualLRPLifecycleHandler

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

func NewActualLRPLifecycleHandler

func NewActualLRPLifecycleHandler(logger lager.Logger, db db.ActualLRPDB) *ActualLRPLifecycleHandler

func (*ActualLRPLifecycleHandler) ClaimActualLRP

func (h *ActualLRPLifecycleHandler) ClaimActualLRP(w http.ResponseWriter, req *http.Request)

func (*ActualLRPLifecycleHandler) CrashActualLRP

func (h *ActualLRPLifecycleHandler) CrashActualLRP(w http.ResponseWriter, req *http.Request)

func (*ActualLRPLifecycleHandler) FailActualLRP

func (h *ActualLRPLifecycleHandler) FailActualLRP(w http.ResponseWriter, req *http.Request)

func (*ActualLRPLifecycleHandler) RemoveActualLRP

func (h *ActualLRPLifecycleHandler) RemoveActualLRP(w http.ResponseWriter, req *http.Request)

func (*ActualLRPLifecycleHandler) RetireActualLRP

func (h *ActualLRPLifecycleHandler) RetireActualLRP(w http.ResponseWriter, req *http.Request)

func (*ActualLRPLifecycleHandler) StartActualLRP

func (h *ActualLRPLifecycleHandler) StartActualLRP(w http.ResponseWriter, req *http.Request)

type CellHandler

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

func NewCellHandler

func NewCellHandler(logger lager.Logger, serviceClient bbs.ServiceClient) *CellHandler

func (*CellHandler) Cells

func (h *CellHandler) Cells(w http.ResponseWriter, req *http.Request)

type DesiredLRPHandler

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

func NewDesiredLRPHandler

func NewDesiredLRPHandler(logger lager.Logger, db db.DesiredLRPDB) *DesiredLRPHandler

func (*DesiredLRPHandler) DesireDesiredLRP

func (h *DesiredLRPHandler) DesireDesiredLRP(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) DesiredLRPByProcessGuid

func (h *DesiredLRPHandler) DesiredLRPByProcessGuid(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) DesiredLRPByProcessGuid_r0

func (h *DesiredLRPHandler) DesiredLRPByProcessGuid_r0(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) DesiredLRPSchedulingInfos

func (h *DesiredLRPHandler) DesiredLRPSchedulingInfos(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) DesiredLRPs

func (h *DesiredLRPHandler) DesiredLRPs(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) DesiredLRPs_r0

func (h *DesiredLRPHandler) DesiredLRPs_r0(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) RemoveDesiredLRP

func (h *DesiredLRPHandler) RemoveDesiredLRP(w http.ResponseWriter, req *http.Request)

func (*DesiredLRPHandler) UpdateDesiredLRP

func (h *DesiredLRPHandler) UpdateDesiredLRP(w http.ResponseWriter, req *http.Request)

type DomainHandler

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

func NewDomainHandler

func NewDomainHandler(logger lager.Logger, db db.DomainDB) *DomainHandler

func (*DomainHandler) Domains

func (h *DomainHandler) Domains(w http.ResponseWriter, req *http.Request)

func (*DomainHandler) Upsert

func (h *DomainHandler) Upsert(w http.ResponseWriter, req *http.Request)

type EvacuationHandler

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

func NewEvacuationHandler

func NewEvacuationHandler(logger lager.Logger, db db.EvacuationDB) *EvacuationHandler

func (*EvacuationHandler) EvacuateClaimedActualLRP

func (h *EvacuationHandler) EvacuateClaimedActualLRP(w http.ResponseWriter, req *http.Request)

func (*EvacuationHandler) EvacuateCrashedActualLRP

func (h *EvacuationHandler) EvacuateCrashedActualLRP(w http.ResponseWriter, req *http.Request)

func (*EvacuationHandler) EvacuateRunningActualLRP

func (h *EvacuationHandler) EvacuateRunningActualLRP(w http.ResponseWriter, req *http.Request)

func (*EvacuationHandler) EvacuateStoppedActualLRP

func (h *EvacuationHandler) EvacuateStoppedActualLRP(w http.ResponseWriter, req *http.Request)

func (*EvacuationHandler) RemoveEvacuatingActualLRP

func (h *EvacuationHandler) RemoveEvacuatingActualLRP(w http.ResponseWriter, req *http.Request)

type EventFetcher

type EventFetcher func() (models.Event, error)

type EventHandler

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

func NewEventHandler

func NewEventHandler(logger lager.Logger, desiredHub, actualHub, taskHub events.Hub) *EventHandler

func (*EventHandler) SubscribeToActualLRPEvents

func (h *EventHandler) SubscribeToActualLRPEvents(w http.ResponseWriter, req *http.Request)

func (*EventHandler) SubscribeToDesiredLRPEvents

func (h *EventHandler) SubscribeToDesiredLRPEvents(w http.ResponseWriter, req *http.Request)

func (*EventHandler) SubscribeToTaskEvents

func (h *EventHandler) SubscribeToTaskEvents(w http.ResponseWriter, req *http.Request)

func (*EventHandler) Subscribe_r0

func (h *EventHandler) Subscribe_r0(w http.ResponseWriter, req *http.Request)

type LRPConvergenceHandler

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

func NewLRPConvergenceHandler

func NewLRPConvergenceHandler(logger lager.Logger, db db.LRPDB) *LRPConvergenceHandler

func (*LRPConvergenceHandler) ConvergeLRPs

func (h *LRPConvergenceHandler) ConvergeLRPs(w http.ResponseWriter, req *http.Request)

type MessageValidator

type MessageValidator interface {
	proto.Message
	Validate() error
	Unmarshal(data []byte) error
}

type PingHandler

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

func NewPingHandler

func NewPingHandler(logger lager.Logger) *PingHandler

func (*PingHandler) Ping

func (h *PingHandler) Ping(w http.ResponseWriter, req *http.Request)

type TaskHandler

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

func NewTaskHandler

func NewTaskHandler(logger lager.Logger, db db.TaskDB) *TaskHandler

func (*TaskHandler) CancelTask

func (h *TaskHandler) CancelTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) CompleteTask

func (h *TaskHandler) CompleteTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) ConvergeTasks

func (h *TaskHandler) ConvergeTasks(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) DeleteTask

func (h *TaskHandler) DeleteTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) DesireTask

func (h *TaskHandler) DesireTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) FailTask

func (h *TaskHandler) FailTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) ResolvingTask

func (h *TaskHandler) ResolvingTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) StartTask

func (h *TaskHandler) StartTask(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) TaskByGuid

func (h *TaskHandler) TaskByGuid(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) TaskByGuid_r0

func (h *TaskHandler) TaskByGuid_r0(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) Tasks

func (h *TaskHandler) Tasks(w http.ResponseWriter, req *http.Request)

func (*TaskHandler) Tasks_r0

func (h *TaskHandler) Tasks_r0(w http.ResponseWriter, req *http.Request)

type UnavailableHandler

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

func NewUnavailableHandler

func NewUnavailableHandler(handler http.Handler, serviceReadyChan <-chan struct{}) *UnavailableHandler

func (*UnavailableHandler) ServeHTTP

func (u *UnavailableHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)