controllers

Documentation

Index

• type GarbageCollectPredicate
  • func (gc GarbageCollectPredicate) Delete(e event.DeleteEvent) bool
• type GitRepositoryReconciler
  • func (r *GitRepositoryReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *GitRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *GitRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts GitRepositoryReconcilerOptions) error
• type GitRepositoryReconcilerOptions
• type HelmChartReconciler
  • func (r *HelmChartReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *HelmChartReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *HelmChartReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts HelmChartReconcilerOptions) error
• type HelmChartReconcilerOptions
• type HelmRepositoryReconciler
  • func (r *HelmRepositoryReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *HelmRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *HelmRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts HelmRepositoryReconcilerOptions) error
• type HelmRepositoryReconcilerOptions
• type SourceChangePredicate
  • func (SourceChangePredicate) Update(e event.UpdateEvent) bool
• type Storage
  • func NewStorage(basePath string, hostname string, timeout time.Duration) (*Storage, error)
  • func (s *Storage) Archive(artifact sourcev1.Artifact, dir string, excludes string, integrityCheck bool) error
  • func (s *Storage) ArtifactExist(artifact sourcev1.Artifact) bool
  • func (s *Storage) ArtifactFor(kind string, metadata metav1.Object, fileName, revision string) sourcev1.Artifact
  • func (s *Storage) Checksum(b []byte) string
  • func (s *Storage) Lock(artifact sourcev1.Artifact) (unlock func(), err error)
  • func (s *Storage) MkdirAll(artifact sourcev1.Artifact) error
  • func (s *Storage) RemoveAll(artifact sourcev1.Artifact) error
  • func (s *Storage) RemoveAllButCurrent(artifact sourcev1.Artifact) error
  • func (s *Storage) Symlink(artifact sourcev1.Artifact, linkName string) (string, error)
  • func (s *Storage) WriteFile(artifact sourcev1.Artifact, data []byte) error

Types

type GarbageCollectPredicate

type GarbageCollectPredicate struct {
	predicate.Funcs
	Scheme  *runtime.Scheme
	Log     logr.Logger
	Storage *Storage
}

func (GarbageCollectPredicate) Delete

func (gc GarbageCollectPredicate) Delete(e event.DeleteEvent) bool

Delete removes all artifacts from storage that belong to the referenced object.

type GitRepositoryReconciler

type GitRepositoryReconciler struct {
	client.Client
	Log     logr.Logger
	Scheme  *runtime.Scheme
	Storage *Storage
}

GitRepositoryReconciler reconciles a GitRepository object

func (*GitRepositoryReconciler) Reconcile

func (r *GitRepositoryReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*GitRepositoryReconciler) SetupWithManager

func (r *GitRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error

func (*GitRepositoryReconciler) SetupWithManagerAndOptions

func (r *GitRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts GitRepositoryReconcilerOptions) error

type GitRepositoryReconcilerOptions

type GitRepositoryReconcilerOptions struct {
	MaxConcurrentReconciles int
}

type HelmChartReconciler

type HelmChartReconciler struct {
	client.Client
	Log     logr.Logger
	Scheme  *runtime.Scheme
	Storage *Storage
	Getters getter.Providers
}

HelmChartReconciler reconciles a HelmChart object

func (*HelmChartReconciler) Reconcile

func (r *HelmChartReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*HelmChartReconciler) SetupWithManager

func (r *HelmChartReconciler) SetupWithManager(mgr ctrl.Manager) error

func (*HelmChartReconciler) SetupWithManagerAndOptions

func (r *HelmChartReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts HelmChartReconcilerOptions) error

type HelmChartReconcilerOptions

type HelmChartReconcilerOptions struct {
	MaxConcurrentReconciles int
}

type HelmRepositoryReconciler

type HelmRepositoryReconciler struct {
	client.Client
	Log     logr.Logger
	Scheme  *runtime.Scheme
	Storage *Storage
	Getters getter.Providers
}

HelmRepositoryReconciler reconciles a HelmRepository object

func (*HelmRepositoryReconciler) Reconcile

func (r *HelmRepositoryReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*HelmRepositoryReconciler) SetupWithManager

func (r *HelmRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error

func (*HelmRepositoryReconciler) SetupWithManagerAndOptions

func (r *HelmRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts HelmRepositoryReconcilerOptions) error

type HelmRepositoryReconcilerOptions

type HelmRepositoryReconcilerOptions struct {
	MaxConcurrentReconciles int
}

type SourceChangePredicate

type SourceChangePredicate struct {
	predicate.Funcs
}

func (SourceChangePredicate) Update

func (SourceChangePredicate) Update(e event.UpdateEvent) bool

Update implements the default UpdateEvent filter for validating source changes.

type Storage

type Storage struct {
	// BasePath is the local directory path where the source artifacts are stored.
	BasePath string `json:"basePath"`

	// Hostname is the file server host name used to compose the artifacts URIs.
	Hostname string `json:"hostname"`

	// Timeout for artifacts operations
	Timeout time.Duration `json:"timeout"`
}

Storage manages artifacts

func NewStorage

func NewStorage(basePath string, hostname string, timeout time.Duration) (*Storage, error)

NewStorage creates the storage helper for a given path and hostname

func (*Storage) Archive

func (s *Storage) Archive(artifact sourcev1.Artifact, dir string, excludes string, integrityCheck bool) error

Archive creates a tar.gz to the artifact path from the given dir excluding the provided file extensions

func (*Storage) ArtifactExist

func (s *Storage) ArtifactExist(artifact sourcev1.Artifact) bool

ArtifactExist returns a boolean indicating whether the artifact file exists in storage

func (*Storage) ArtifactFor

func (s *Storage) ArtifactFor(kind string, metadata metav1.Object, fileName, revision string) sourcev1.Artifact

ArtifactFor returns an artifact for the given Kubernetes object

func (*Storage) Checksum

func (s *Storage) Checksum(b []byte) string

Checksum returns the SHA1 checksum for the given bytes as a string

func (*Storage) Lock

func (s *Storage) Lock(artifact sourcev1.Artifact) (unlock func(), err error)

Lock creates a file lock for the given artifact

func (*Storage) MkdirAll

func (s *Storage) MkdirAll(artifact sourcev1.Artifact) error

MkdirAll calls os.MkdirAll for the given artifact base dir

func (*Storage) RemoveAll

func (s *Storage) RemoveAll(artifact sourcev1.Artifact) error

RemoveAll calls os.RemoveAll for the given artifact base dir

func (*Storage) RemoveAllButCurrent

func (s *Storage) RemoveAllButCurrent(artifact sourcev1.Artifact) error

RemoveAllButCurrent removes all files for the given artifact base dir excluding the current one

func (*Storage) Symlink

func (s *Storage) Symlink(artifact sourcev1.Artifact, linkName string) (string, error)

Symlink creates or updates a symbolic link for the given artifact and returns the URL for the symlink

func (*Storage) WriteFile

func (s *Storage) WriteFile(artifact sourcev1.Artifact, data []byte) error

WriteFile writes the given bytes to the artifact path if the checksum differs