pkgrepository

Documentation

Index

• func NewPackageRepoApp(pkgRepository *pkgingv1alpha1.PackageRepository) (*kcv1alpha1.App, error)
• type App
  • func NewApp(app v1alpha1.App, hooks Hooks, fetchFactory fetch.Factory, ...) *App
  • func (a *App) Name() string
  • func (a *App) Namespace() string
  • func (a *App) Reconcile(force bool) (reconcile.Result, error)
  • func (a *App) SecretRefs() map[reftracker.RefKey]struct{}
  • func (a *App) Status() v1alpha1.AppStatus
  • func (a *App) StatusAsYAMLBytes() ([]byte, error)
• type CRDApp
  • func NewCRDApp(appModel *kcv1alpha1.App, packageRepo *pkgingv1alpha1.PackageRepository, ...) *CRDApp
  • func (a *CRDApp) Reconcile(force bool) (reconcile.Result, error)
  • func (a *CRDApp) ResourceRefs() map[reftracker.RefKey]struct{}
• type Hooks
• type ReconcileTimer
  • func NewReconcileTimer(app v1alpha1.App) ReconcileTimer
  • func (rt ReconcileTimer) DurationUntilReady(err error) time.Duration
  • func (rt ReconcileTimer) IsReadyAt(timeAt time.Time) bool

Functions

func NewPackageRepoApp

func NewPackageRepoApp(pkgRepository *pkgingv1alpha1.PackageRepository) (*kcv1alpha1.App, error)

Types

type App

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

func NewApp

func NewApp(app v1alpha1.App, hooks Hooks,
	fetchFactory fetch.Factory, templateFactory template.Factory,
	deployFactory deploy.Factory, log logr.Logger) *App

func (*App) Name

func (a *App) Name() string

func (*App) Namespace

func (a *App) Namespace() string

func (*App) Reconcile

func (a *App) Reconcile(force bool) (reconcile.Result, error)

Reconcile is not expected to be called concurrently

func (*App) SecretRefs

func (a *App) SecretRefs() map[reftracker.RefKey]struct{}

Get all SecretRefs from App spec

func (*App) Status

func (a *App) Status() v1alpha1.AppStatus

func (*App) StatusAsYAMLBytes

func (a *App) StatusAsYAMLBytes() ([]byte, error)

type CRDApp

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

func NewCRDApp

func NewCRDApp(appModel *kcv1alpha1.App, packageRepo *pkgingv1alpha1.PackageRepository, log logr.Logger,
	appClient kcclient.Interface, fetchFactory fetch.Factory,
	templateFactory template.Factory, deployFactory deploy.Factory) *CRDApp

func (*CRDApp) Reconcile

func (a *CRDApp) Reconcile(force bool) (reconcile.Result, error)

func (*CRDApp) ResourceRefs

func (a *CRDApp) ResourceRefs() map[reftracker.RefKey]struct{}

type Hooks

type Hooks struct {
	BlockDeletion   func() error
	UnblockDeletion func() error
	UpdateStatus    func(string) error
	WatchChanges    func(func(v1alpha1.App), chan struct{}) error
}

type ReconcileTimer

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

func NewReconcileTimer

func NewReconcileTimer(app v1alpha1.App) ReconcileTimer

func (ReconcileTimer) DurationUntilReady

func (rt ReconcileTimer) DurationUntilReady(err error) time.Duration

func (ReconcileTimer) IsReadyAt

func (rt ReconcileTimer) IsReadyAt(timeAt time.Time) bool