Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func New

func New(
	logger,
	accessLogger lager.Logger,
	updateWorkers int,
	convergenceWorkersSize int,
	maxTaskPlacementRetries int,
	emitter middleware.Emitter,
	db db.DB,
	desiredHub, actualHub, actualLRPInstanceHub, taskHub events.Hub,
	taskCompletionClient taskworkpool.TaskCompletionClient,
	serviceClient serviceclient.ServiceClient,
	auctioneerClient auctioneer.Client,
	repClientFactory rep.ClientFactory,
	taskStatMetronNotifier metrics.TaskStatMetronNotifier,
	migrationsDone <-chan struct{},
	exitChan 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(db db.ActualLRPDB, exitChan chan<- struct{}) *ActualLRPHandler

func (*ActualLRPHandler) ActualLRPGroupByProcessGuidAndIndex

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

    DEPRECATED

    func (*ActualLRPHandler) ActualLRPGroups

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

      DEPRECATED

      func (*ActualLRPHandler) ActualLRPGroupsByProcessGuid

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

        DEPRECATED

        func (*ActualLRPHandler) ActualLRPs

        func (h *ActualLRPHandler) ActualLRPs(logger lager.Logger, w http.ResponseWriter, req *http.Request)

        type ActualLRPLifecycleController

        type ActualLRPLifecycleController interface {
        	ClaimActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32, actualLRPInstanceKey *models.ActualLRPInstanceKey) error
        	StartActualLRP(ctx context.Context, logger lager.Logger, actualLRPKey *models.ActualLRPKey, actualLRPInstanceKey *models.ActualLRPInstanceKey, actualLRPNetInfo *models.ActualLRPNetInfo) error
        	CrashActualLRP(ctx context.Context, logger lager.Logger, actualLRPKey *models.ActualLRPKey, actualLRPInstanceKey *models.ActualLRPInstanceKey, errorMessage string) error
        	FailActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey, errorMessage string) error
        	RemoveActualLRP(ctx context.Context, logger lager.Logger, processGuid string, index int32, instanceKey *models.ActualLRPInstanceKey) error
        	RetireActualLRP(ctx context.Context, logger lager.Logger, key *models.ActualLRPKey) error
        }

        type ActualLRPLifecycleHandler

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

        func NewActualLRPLifecycleHandler

        func NewActualLRPLifecycleHandler(
        	controller ActualLRPLifecycleController,
        	exitChan chan<- struct{},
        ) *ActualLRPLifecycleHandler

        func (*ActualLRPLifecycleHandler) ClaimActualLRP

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

        func (*ActualLRPLifecycleHandler) CrashActualLRP

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

        func (*ActualLRPLifecycleHandler) FailActualLRP

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

        func (*ActualLRPLifecycleHandler) RemoveActualLRP

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

        func (*ActualLRPLifecycleHandler) RetireActualLRP

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

        func (*ActualLRPLifecycleHandler) StartActualLRP

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

        type CellHandler

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

        func NewCellHandler

        func NewCellHandler(serviceClient serviceclient.ServiceClient, exitChan chan<- struct{}) *CellHandler

        func (*CellHandler) Cells

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

        type DesiredLRPHandler

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

        func NewDesiredLRPHandler

        func NewDesiredLRPHandler(
        	updateWorkersCount int,
        	desiredLRPDB db.DesiredLRPDB,
        	actualLRPDB db.ActualLRPDB,
        	desiredHub events.Hub,
        	actualHub events.Hub,
        	actualLRPInstanceHub events.Hub,
        	auctioneerClient auctioneer.Client,
        	repClientFactory rep.ClientFactory,
        	serviceClient serviceclient.ServiceClient,
        	exitChan chan<- struct{},
        ) *DesiredLRPHandler

        func (*DesiredLRPHandler) DesireDesiredLRP

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

        func (*DesiredLRPHandler) DesiredLRPByProcessGuid

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

        func (*DesiredLRPHandler) DesiredLRPByProcessGuid_r2

        func (h *DesiredLRPHandler) DesiredLRPByProcessGuid_r2(logger lager.Logger, w http.ResponseWriter, req *http.Request)

        func (*DesiredLRPHandler) DesiredLRPSchedulingInfos

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

        func (*DesiredLRPHandler) DesiredLRPs

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

        func (*DesiredLRPHandler) DesiredLRPs_r2

        func (h *DesiredLRPHandler) DesiredLRPs_r2(logger lager.Logger, w http.ResponseWriter, req *http.Request)

        func (*DesiredLRPHandler) RemoveDesiredLRP

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

        func (*DesiredLRPHandler) UpdateDesiredLRP

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

        type DomainHandler

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

        func NewDomainHandler

        func NewDomainHandler(db db.DomainDB, exitChan chan<- struct{}) *DomainHandler

        func (*DomainHandler) Domains

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

        func (*DomainHandler) Upsert

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

        type EvacuationHandler

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

        func NewEvacuationHandler

        func NewEvacuationHandler(
        	controller EvacuationController,
        	exitChan chan<- struct{},
        ) *EvacuationHandler

        func (*EvacuationHandler) EvacuateClaimedActualLRP

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

        func (*EvacuationHandler) EvacuateCrashedActualLRP

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

        func (*EvacuationHandler) EvacuateRunningActualLRP

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

        func (*EvacuationHandler) EvacuateStoppedActualLRP

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

        func (*EvacuationHandler) RemoveEvacuatingActualLRP

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

        type EventController

        type EventController interface {
        	Subscribe_r0(logger lager.Logger, w http.ResponseWriter, req *http.Request)
        	Subscribe_r1(logger lager.Logger, w http.ResponseWriter, req *http.Request)
        }

        type EventFetcher

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

        type LRPGroupEventsHandler

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

          DEPRECATED

          func NewLRPGroupEventsHandler

          func NewLRPGroupEventsHandler(desiredHub, actualHub events.Hub) *LRPGroupEventsHandler

            DEPRECATED

            func (*LRPGroupEventsHandler) Subscribe_r0

            func (h *LRPGroupEventsHandler) Subscribe_r0(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            func (*LRPGroupEventsHandler) Subscribe_r1

            func (h *LRPGroupEventsHandler) Subscribe_r1(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            type LRPInstanceEventHandler

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

            func NewLRPInstanceEventHandler

            func NewLRPInstanceEventHandler(desiredHub, lrpInstanceHub events.Hub) *LRPInstanceEventHandler

            func (*LRPInstanceEventHandler) Subscribe_r0

            func (h *LRPInstanceEventHandler) Subscribe_r0(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            func (*LRPInstanceEventHandler) Subscribe_r1

            func (h *LRPInstanceEventHandler) Subscribe_r1(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            type MessageValidator

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

            type PingHandler

            type PingHandler struct {
            }

            func NewPingHandler

            func NewPingHandler() *PingHandler

            func (*PingHandler) Ping

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

            type TaskController

            type TaskController interface {
            	Tasks(ctx context.Context, logger lager.Logger, domain, cellId string) ([]*models.Task, error)
            	TaskByGuid(ctx context.Context, logger lager.Logger, taskGuid string) (*models.Task, error)
            	DesireTask(ctx context.Context, logger lager.Logger, taskDefinition *models.TaskDefinition, taskGuid, domain string) error
            	StartTask(ctx context.Context, logger lager.Logger, taskGuid, cellId string) (shouldStart bool, err error)
            	CancelTask(ctx context.Context, logger lager.Logger, taskGuid string) error
            	FailTask(ctx context.Context, logger lager.Logger, taskGuid, failureReason string) error
            	RejectTask(ctx context.Context, logger lager.Logger, taskGuid, failureReason string) error
            	CompleteTask(ctx context.Context, logger lager.Logger, taskGuid, cellId string, failed bool, failureReason, result string) error
            	ResolvingTask(ctx context.Context, logger lager.Logger, taskGuid string) error
            	DeleteTask(ctx context.Context, logger lager.Logger, taskGuid string) error
            	ConvergeTasks(ctx context.Context, logger lager.Logger, kickTaskDuration, expirePendingTaskDuration, expireCompletedTaskDuration time.Duration) error
            }

            type TaskEventHandler

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

            func NewTaskEventHandler

            func NewTaskEventHandler(taskHub events.Hub) *TaskEventHandler

            func (*TaskEventHandler) Subscribe_r0

            func (h *TaskEventHandler) Subscribe_r0(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            func (*TaskEventHandler) Subscribe_r1

            func (h *TaskEventHandler) Subscribe_r1(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            type TaskHandler

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

            func NewTaskHandler

            func NewTaskHandler(
            	controller TaskController,
            	exitChan chan<- struct{},
            ) *TaskHandler

            func (*TaskHandler) CancelTask

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

            func (*TaskHandler) CompleteTask

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

            func (*TaskHandler) DeleteTask

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

            func (*TaskHandler) DesireTask

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

            func (*TaskHandler) FailTask

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

            func (*TaskHandler) RejectTask

            func (h *TaskHandler) RejectTask(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            func (*TaskHandler) ResolvingTask

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

            func (*TaskHandler) StartTask

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

            func (*TaskHandler) TaskByGuid

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

            func (*TaskHandler) TaskByGuid_r2

            func (h *TaskHandler) TaskByGuid_r2(logger lager.Logger, w http.ResponseWriter, req *http.Request)

            func (*TaskHandler) Tasks

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

            func (*TaskHandler) Tasks_r2

            func (h *TaskHandler) Tasks_r2(logger lager.Logger, 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)

            Directories

            Path Synopsis
            Code generated by counterfeiter.
            Code generated by counterfeiter.
            fakes
            Code generated by counterfeiter.
            Code generated by counterfeiter.