actions

Documentation

Index

• type AppLogs
  • func NewAppLogs(appRepo CFAppRepository, buildRepo CFBuildRepository, podRepo PodRepository) *AppLogs
  • func (a *AppLogs) Read(ctx context.Context, logger logr.Logger, authInfo authorization.Info, ...) ([]repositories.LogRecord, error)
• type CFAppRepository
• type CFBuildRepository
• type CFDomainRepository
• type CFProcessRepository
• type CFRouteRepository
• type Manifest
  • func NewManifest(appRepo CFAppRepository, domainRepo CFDomainRepository, ...) *Manifest
  • func (a *Manifest) Apply(ctx context.Context, authInfo authorization.Info, spaceGUID string, ...) error
• type PodRepository
• type ProcessScaler
  • func NewProcessScaler(appRepo CFAppRepository, processRepo 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 CFProcessRepository, podRepo PodRepository, ...) *ProcessStats
  • func (a *ProcessStats) FetchStats(ctx context.Context, authInfo authorization.Info, processGUID string) ([]repositories.PodStatsRecord, error)

Types

type AppLogs

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

func NewAppLogs

func NewAppLogs(appRepo CFAppRepository, buildRepo CFBuildRepository, podRepo 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 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 CFBuildRepository

type CFBuildRepository interface {
	GetLatestBuildByAppGUID(context.Context, authorization.Info, string, string) (repositories.BuildRecord, error)
	GetBuildLogs(context.Context, authorization.Info, string, string) ([]repositories.LogRecord, 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 Manifest

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

func NewManifest

func NewManifest(appRepo CFAppRepository, domainRepo CFDomainRepository, processRepo CFProcessRepository, routeRepo CFRouteRepository, defaultDomainName string) *Manifest

func (*Manifest) Apply

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

type PodRepository

type PodRepository interface {
	ListPodStats(ctx context.Context, authInfo authorization.Info, message repositories.ListPodStatsMessage) ([]repositories.PodStatsRecord, error)
	GetRuntimeLogsForApp(context.Context, logr.Logger, authorization.Info, repositories.RuntimeLogsMessage) ([]repositories.LogRecord, error)
}

type ProcessScaler

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

func NewProcessScaler

func NewProcessScaler(appRepo CFAppRepository, processRepo 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 CFProcessRepository, podRepo PodRepository, appRepo CFAppRepository) *ProcessStats

func (*ProcessStats) FetchStats

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