handler

package
v0.0.0-...-db62745 Latest Latest
Warning

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

Go to latest
Published: Aug 31, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(lrpBifrost LRPBifrost,
	dockerStagingBifrost StagingBifrost,
	taskBifrost TaskBifrost,
	lager lager.Logger,
) http.Handler

Types

type App

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

func NewAppHandler

func NewAppHandler(lrpBifrost LRPBifrost, logger lager.Logger) *App

func (*App) Desire

func (a *App) Desire(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*App) Get

func (a *App) Get(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*App) GetInstances

func (a *App) GetInstances(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*App) List

func (a *App) List(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

func (*App) Stop

func (a *App) Stop(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*App) StopInstance

func (a *App) StopInstance(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*App) Update

func (a *App) Update(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

type LRPBifrost

type LRPBifrost interface {
	Transfer(ctx context.Context, request cf.DesireLRPRequest) error
	List(ctx context.Context) ([]cf.DesiredLRPSchedulingInfo, error)
	Update(ctx context.Context, update cf.UpdateDesiredLRPRequest) error
	Stop(ctx context.Context, identifier api.LRPIdentifier) error
	StopInstance(ctx context.Context, identifier api.LRPIdentifier, index uint) error
	GetApp(ctx context.Context, identifier api.LRPIdentifier) (cf.DesiredLRP, error)
	GetInstances(ctx context.Context, identifier api.LRPIdentifier) ([]*cf.Instance, error)
}

type Stage

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

func NewStageHandler

func NewStageHandler(dockerStagingBifrost StagingBifrost, logger lager.Logger) *Stage

func (*Stage) Run

func (s *Stage) Run(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)

type StagingBifrost

type StagingBifrost interface {
	TransferStaging(ctx context.Context, stagingGUID string, request cf.StagingRequest) error
	CompleteStaging(ctx context.Context, request cf.StagingCompletedRequest) error
}

type Task

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

func NewTaskHandler

func NewTaskHandler(logger lager.Logger, taskBifrost TaskBifrost) *Task

func (*Task) Cancel

func (t *Task) Cancel(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*Task) Get

func (t *Task) Get(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*Task) List

func (t *Task) List(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*Task) Run

func (t *Task) Run(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)

type TaskBifrost

type TaskBifrost interface {
	GetTask(ctx context.Context, taskGUID string) (cf.TaskResponse, error)
	ListTasks(ctx context.Context) (cf.TasksResponse, error)
	TransferTask(ctx context.Context, taskGUID string, request cf.TaskRequest) error
	CancelTask(ctx context.Context, taskGUID string) error
}

Directories

Path Synopsis
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