Versions in this module Expand all Collapse all v0 v0.21.1 Feb 24, 2022 Changes in this version + type ArchiveFileFilter func(p string, fi os.FileInfo) bool + func SourceIgnoreFilter(ps []gitignore.Pattern, domain []string) ArchiveFileFilter + type BucketReconciler struct + EventRecorder kuberecorder.EventRecorder + ExternalEventRecorder *events.Recorder + MetricsRecorder *metrics.Recorder + Scheme *runtime.Scheme + Storage *Storage + func (r *BucketReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *BucketReconciler) SetupWithManager(mgr ctrl.Manager) error + func (r *BucketReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts BucketReconcilerOptions) error + type BucketReconcilerOptions struct + MaxConcurrentReconciles int + type GitRepositoryReconciler struct + EventRecorder kuberecorder.EventRecorder + ExternalEventRecorder *events.Recorder + MetricsRecorder *metrics.Recorder + Scheme *runtime.Scheme + Storage *Storage + func (r *GitRepositoryReconciler) Reconcile(ctx context.Context, 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 struct + DependencyRequeueInterval time.Duration + MaxConcurrentReconciles int + type HelmChartReconciler struct + EventRecorder kuberecorder.EventRecorder + ExternalEventRecorder *events.Recorder + Getters helmgetter.Providers + MetricsRecorder *metrics.Recorder + Scheme *runtime.Scheme + Storage *Storage + func (r *HelmChartReconciler) Reconcile(ctx context.Context, 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 struct + MaxConcurrentReconciles int + type HelmRepositoryReconciler struct + EventRecorder kuberecorder.EventRecorder + ExternalEventRecorder *events.Recorder + Getters helmgetter.Providers + MetricsRecorder *metrics.Recorder + Scheme *runtime.Scheme + Storage *Storage + func (r *HelmRepositoryReconciler) Reconcile(ctx context.Context, 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 struct + MaxConcurrentReconciles int + type SourceRevisionChangePredicate struct + func (SourceRevisionChangePredicate) Create(e event.CreateEvent) bool + func (SourceRevisionChangePredicate) Delete(e event.DeleteEvent) bool + func (SourceRevisionChangePredicate) Update(e event.UpdateEvent) bool + type Storage struct + BasePath string + Hostname string + Timeout time.Duration + func NewStorage(basePath string, hostname string, timeout time.Duration) (*Storage, error) + func (s *Storage) Archive(artifact *sourcev1.Artifact, dir string, filter ArchiveFileFilter) (err error) + func (s *Storage) ArtifactExist(artifact sourcev1.Artifact) bool + func (s *Storage) AtomicWriteFile(artifact *sourcev1.Artifact, reader io.Reader, mode os.FileMode) (err error) + func (s *Storage) Checksum(reader io.Reader) string + func (s *Storage) Copy(artifact *sourcev1.Artifact, reader io.Reader) (err error) + func (s *Storage) CopyFromPath(artifact *sourcev1.Artifact, path string) (err error) + func (s *Storage) CopyToPath(artifact *sourcev1.Artifact, subPath, toPath string) error + func (s *Storage) LocalPath(artifact sourcev1.Artifact) string + func (s *Storage) Lock(artifact sourcev1.Artifact) (unlock func(), err error) + func (s *Storage) MkdirAll(artifact sourcev1.Artifact) error + func (s *Storage) NewArtifactFor(kind string, metadata metav1.Object, revision, fileName string) sourcev1.Artifact + 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) SetArtifactURL(artifact *sourcev1.Artifact) + func (s Storage) SetHostname(URL string) string