actions

Documentation

Index

• type AppLogs
  • func NewAppLogs(appRepo shared.CFAppRepository, buildRepo shared.CFBuildRepository, ...) *AppLogs
  • func (a *AppLogs) Read(ctx context.Context, logger logr.Logger, authInfo authorization.Info, ...) ([]repositories.LogRecord, error)
• type Applier
• type Manifest
  • func NewManifest(domainRepo shared.CFDomainRepository, defaultDomainName string, ...) *Manifest
  • func (a *Manifest) Apply(ctx context.Context, authInfo authorization.Info, spaceGUID string, ...) error
• type Normalizer
• type ProcessScaler
  • func NewProcessScaler(appRepo shared.CFAppRepository, processRepo shared.CFProcessRepository) *ProcessScaler
  • func (a *ProcessScaler) ScaleAppProcess(ctx context.Context, authInfo authorization.Info, appGUID string, ...) (repositories.ProcessRecord, error)
  • func (a *ProcessScaler) ScaleProcess(ctx context.Context, authInfo authorization.Info, processGUID string, ...) (repositories.ProcessRecord, error)
• type ProcessStats
  • func NewProcessStats(processRepo shared.CFProcessRepository, podRepo shared.PodRepository, ...) *ProcessStats
  • func (a *ProcessStats) FetchStats(ctx context.Context, authInfo authorization.Info, processGUID string) ([]repositories.PodStatsRecord, error)
• type StateCollector

Types

type AppLogs

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

func NewAppLogs

func NewAppLogs(appRepo shared.CFAppRepository, buildRepo shared.CFBuildRepository, podRepo shared.PodRepository) *AppLogs

func (*AppLogs) Read

func (a *AppLogs) Read(ctx context.Context, logger logr.Logger, authInfo authorization.Info, appGUID string, read payloads.LogRead) ([]repositories.LogRecord, error)

type Applier

type Applier interface {
	Apply(ctx context.Context, authInfo authorization.Info, spaceGUID string, appInfo payloads.ManifestApplication, appState manifest.AppState) error
}

type Manifest

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

func NewManifest

func NewManifest(domainRepo shared.CFDomainRepository, defaultDomainName string, stateCollector StateCollector, normalizer Normalizer, applier Applier,
) *Manifest

func (*Manifest) Apply

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

type Normalizer

type Normalizer interface {
	Normalize(appInfo payloads.ManifestApplication, appState manifest.AppState) payloads.ManifestApplication
}

type ProcessScaler

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

func NewProcessScaler

func NewProcessScaler(appRepo shared.CFAppRepository, processRepo shared.CFProcessRepository) *ProcessScaler

func (*ProcessScaler) ScaleAppProcess

func (a *ProcessScaler) ScaleAppProcess(ctx context.Context, authInfo authorization.Info, appGUID string, processType string, scale repositories.ProcessScaleValues) (repositories.ProcessRecord, error)

func (*ProcessScaler) ScaleProcess

func (a *ProcessScaler) ScaleProcess(ctx context.Context, authInfo authorization.Info, processGUID string, scale repositories.ProcessScaleValues) (repositories.ProcessRecord, error)

type ProcessStats

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

func NewProcessStats

func NewProcessStats(processRepo shared.CFProcessRepository, podRepo shared.PodRepository, appRepo shared.CFAppRepository) *ProcessStats

func (*ProcessStats) FetchStats

func (a *ProcessStats) FetchStats(ctx context.Context, authInfo authorization.Info, processGUID string) ([]repositories.PodStatsRecord, error)

type StateCollector

type StateCollector interface {
	CollectState(ctx context.Context, authInfo authorization.Info, appName, spaceGUID string) (manifest.AppState, error)
}