actions

Documentation

Index

• Constants
• 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 MetricsRepository
• type Normalizer
• type PodStatsRecord
• type ProcessStats
  • func NewProcessStats(processRepo shared.CFProcessRepository, appRepo shared.CFAppRepository, ...) *ProcessStats
  • func (a *ProcessStats) FetchStats(ctx context.Context, authInfo authorization.Info, processGUID string) ([]PodStatsRecord, error)
• type StateCollector
• type Usage

Constants

const (
	ApplicationContainerName = "application"
	EnvCFInstanceIndex       = "CF_INSTANCE_INDEX"
	LabelGUID                = "korifi.cloudfoundry.org/guid"
	LabelVersion             = "korifi.cloudfoundry.org/version"
)

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, manifesto payloads.Manifest) error

type MetricsRepository

type MetricsRepository interface {
	GetMetrics(ctx context.Context, authInfo authorization.Info, namespace string, podSelector client.MatchingLabels) ([]repositories.PodMetrics, error)
}

type Normalizer

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

type PodStatsRecord

type PodStatsRecord struct {
	Type      string
	Index     int
	State     string `default:"DOWN"`
	Usage     Usage
	MemQuota  *int64
	DiskQuota *int64
}

type ProcessStats

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

func NewProcessStats

func NewProcessStats(processRepo shared.CFProcessRepository, appRepo shared.CFAppRepository, metricsRepo MetricsRepository) *ProcessStats

func (*ProcessStats) FetchStats

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

type StateCollector

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

type Usage

type Usage struct {
	Time *string
	CPU  *float64
	Mem  *int64
	Disk *int64
}