handler

Documentation

Index

• func New(lrpBifrost LRPBifrost, dockerStagingBifrost StagingBifrost, ...) http.Handler
• type App
  • func NewAppHandler(lrpBifrost LRPBifrost, logger lager.Logger) *App
  • func (a *App) Desire(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (a *App) Get(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (a *App) GetInstances(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (a *App) List(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
  • func (a *App) Stop(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (a *App) StopInstance(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (a *App) Update(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
• type LRPBifrost
• type Stage
  • func NewStageHandler(dockerStagingBifrost StagingBifrost, logger lager.Logger) *Stage
  • func (s *Stage) Run(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)
• type StagingBifrost
• type Task
  • func NewTaskHandler(logger lager.Logger, taskBifrost TaskBifrost) *Task
  • func (t *Task) Cancel(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)
  • func (t *Task) Get(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)
  • func (t *Task) List(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)
  • func (t *Task) Run(resp http.ResponseWriter, req *http.Request, ps httprouter.Params)
• type TaskBifrost

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
}