Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplyManifest ¶
type ApplyManifest struct {
// contains filtered or unexported fields
}
func NewApplyManifest ¶
func NewApplyManifest(appRepo CFAppRepository, domainRepo CFDomainRepository, processRepo CFProcessRepository, routeRepo CFRouteRepository) *ApplyManifest
type CFAppRepository ¶
type CFAppRepository interface {
GetApp(context.Context, authorization.Info, string) (repositories.AppRecord, error)
GetAppByNameAndSpace(context.Context, authorization.Info, string, string) (repositories.AppRecord, error)
CreateOrPatchAppEnvVars(context.Context, authorization.Info, repositories.CreateOrPatchAppEnvVarsMessage) (repositories.AppEnvVarsRecord, error)
CreateApp(context.Context, authorization.Info, repositories.CreateAppMessage) (repositories.AppRecord, error)
}
type CFDomainRepository ¶
type CFDomainRepository interface {
GetDomainByName(context.Context, authorization.Info, string) (repositories.DomainRecord, error)
}
type CFProcessRepository ¶
type CFProcessRepository interface {
GetProcess(context.Context, authorization.Info, string) (repositories.ProcessRecord, error)
ListProcesses(context.Context, authorization.Info, repositories.ListProcessesMessage) ([]repositories.ProcessRecord, error)
ScaleProcess(context.Context, authorization.Info, repositories.ScaleProcessMessage) (repositories.ProcessRecord, error)
CreateProcess(context.Context, authorization.Info, repositories.CreateProcessMessage) error
GetProcessByAppTypeAndSpace(context.Context, authorization.Info, string, string, string) (repositories.ProcessRecord, error)
PatchProcess(context.Context, authorization.Info, repositories.PatchProcessMessage) (repositories.ProcessRecord, error)
}
type CFRouteRepository ¶
type CFRouteRepository interface {
GetOrCreateRoute(context.Context, authorization.Info, repositories.CreateRouteMessage) (repositories.RouteRecord, error)
ListRoutesForApp(context.Context, authorization.Info, string, string) ([]repositories.RouteRecord, error)
AddDestinationsToRoute(ctx context.Context, c authorization.Info, message repositories.AddDestinationsToRouteMessage) (repositories.RouteRecord, error)
}
type FetchProcessStats ¶
type FetchProcessStats struct {
// contains filtered or unexported fields
}
func NewFetchProcessStats ¶
func NewFetchProcessStats(processRepo CFProcessRepository, podRepo PodRepository, appRepo CFAppRepository) *FetchProcessStats
func (*FetchProcessStats) Invoke ¶
func (a *FetchProcessStats) Invoke(ctx context.Context, authInfo authorization.Info, processGUID string) ([]repositories.PodStatsRecord, error)
type PodRepository ¶
type PodRepository interface {
ListPodStats(ctx context.Context, authInfo authorization.Info, message repositories.ListPodStatsMessage) ([]repositories.PodStatsRecord, error)
}
type ScaleAppProcess ¶
type ScaleAppProcess struct {
// contains filtered or unexported fields
}
func NewScaleAppProcess ¶
func NewScaleAppProcess(appRepo CFAppRepository, processRepo CFProcessRepository, scaleProcessAction ScaleProcessAction) *ScaleAppProcess
func (*ScaleAppProcess) Invoke ¶
func (a *ScaleAppProcess) Invoke(ctx context.Context, authInfo authorization.Info, appGUID string, processType string, scale repositories.ProcessScaleValues) (repositories.ProcessRecord, error)
type ScaleProcess ¶
type ScaleProcess struct {
// contains filtered or unexported fields
}
func NewScaleProcess ¶
func NewScaleProcess(processRepo CFProcessRepository) *ScaleProcess
func (*ScaleProcess) Invoke ¶
func (a *ScaleProcess) Invoke(ctx context.Context, authInfo authorization.Info, processGUID string, scale repositories.ProcessScaleValues) (repositories.ProcessRecord, error)
type ScaleProcessAction ¶
type ScaleProcessAction func(ctx context.Context, authInfo authorization.Info, processGUID string, scale repositories.ProcessScaleValues) (repositories.ProcessRecord, error)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.