actions

Documentation

Index

• type ApplyManifest
  • func NewApplyManifest(appRepo CFAppRepository, domainRepo CFDomainRepository, ...) *ApplyManifest
  • func (a *ApplyManifest) Invoke(ctx context.Context, authInfo authorization.Info, spaceGUID string, ...) error
• type CFAppRepository
• type CFDomainRepository
• type CFProcessRepository
• type CFRouteRepository
• type FetchProcessStats
  • func NewFetchProcessStats(processRepo CFProcessRepository, podRepo PodRepository, ...) *FetchProcessStats
  • func (a *FetchProcessStats) Invoke(ctx context.Context, authInfo authorization.Info, processGUID string) ([]repositories.PodStatsRecord, error)
• type PodRepository
• type ScaleAppProcess
  • func NewScaleAppProcess(appRepo CFAppRepository, processRepo CFProcessRepository, ...) *ScaleAppProcess
  • func (a *ScaleAppProcess) Invoke(ctx context.Context, authInfo authorization.Info, appGUID string, ...) (repositories.ProcessRecord, error)
• type ScaleProcess
  • func NewScaleProcess(processRepo CFProcessRepository) *ScaleProcess
  • func (a *ScaleProcess) Invoke(ctx context.Context, authInfo authorization.Info, processGUID string, ...) (repositories.ProcessRecord, error)
• type ScaleProcessAction

Types

type ApplyManifest

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

func NewApplyManifest

func NewApplyManifest(appRepo CFAppRepository, domainRepo CFDomainRepository, processRepo CFProcessRepository, routeRepo CFRouteRepository) *ApplyManifest

func (*ApplyManifest) Invoke

func (a *ApplyManifest) Invoke(ctx context.Context, authInfo authorization.Info, spaceGUID string, defaultDomainName string, manifest payloads.Manifest) error

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)