handlers

package
v0.0.0-...-2bebce4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 29, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const BbsLogSource = "DIEGO-API"

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{},
	metronClient loggingclient.IngressClient,
) 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 deprecated 

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

Deprecated: use ActaulLRPs instead

func (*ActualLRPHandler) ActualLRPGroups deprecated 

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

Deprecated: use ActaulLRPs instead

func (*ActualLRPHandler) ActualLRPGroupsByProcessGuid deprecated 

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

Deprecated: use ActaulLRPs instead

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,
		actualLRPInternalRoutes []*models.ActualLRPInternalRoute,
		actualLRPMetricTags map[string]string,
		routable bool,
		availabilityZone string,
	) 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)

func (*ActualLRPLifecycleHandler) StartActualLRP_r0 

func (h *ActualLRPLifecycleHandler) StartActualLRP_r0(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{},
	metronClient loggingclient.IngressClient,
) *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) DesiredLRPRoutingInfos 

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

func (*DesiredLRPHandler) DesiredLRPSchedulingInfoByProcessGuid 

func (h *DesiredLRPHandler) DesiredLRPSchedulingInfoByProcessGuid(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 EvacuationController 

type EvacuationController interface {
	RemoveEvacuatingActualLRP(context.Context, lager.Logger, *models.ActualLRPKey, *models.ActualLRPInstanceKey) error
	EvacuateClaimedActualLRP(context.Context, lager.Logger, *models.ActualLRPKey, *models.ActualLRPInstanceKey) (bool, error)
	EvacuateCrashedActualLRP(context.Context, lager.Logger, *models.ActualLRPKey, *models.ActualLRPInstanceKey, string) error
	EvacuateRunningActualLRP(context.Context, lager.Logger, *models.ActualLRPKey, *models.ActualLRPInstanceKey, *models.ActualLRPNetInfo, []*models.ActualLRPInternalRoute, map[string]string, bool, string) (bool, error)
	EvacuateStoppedActualLRP(context.Context, lager.Logger, *models.ActualLRPKey, *models.ActualLRPInstanceKey) error
}

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) EvacuateRunningActualLRP_r0 

func (h *EvacuationHandler) EvacuateRunningActualLRP_r0(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 deprecated 

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

Deprecated: use LRPInstanceEventHandler instead

func NewLRPGroupEventsHandler deprecated 

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

Deprecated: use LRPInstanceEventHandler instead

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 deprecated 

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

Deprecated: do not use

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)

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.