controller

Jul 3, 2023

Changes in this version

+ const GarbageCountLimit

+ type ArchiveFileFilter func(p string, fi os.FileInfo) bool

+ func SourceIgnoreFilter(ps []gitignore.Pattern, domain []string) ArchiveFileFilter

+ type BucketProvider interface

+ BucketExists func(ctx context.Context, bucketName string) (bool, error)

+ Close func(context.Context)

+ FGetObject func(ctx context.Context, bucketName, objectKey, targetPath string) (etag string, err error)

+ ObjectIsNotFound func(error) bool

+ VisitObjects func(ctx context.Context, bucketName string, visit func(key, etag string) error) error

+ type BucketReconciler struct

+ ControllerName string

+ Storage *Storage

+ func (r *BucketReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)

+ func (r *BucketReconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *BucketReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts BucketReconcilerOptions) error

+ type BucketReconcilerOptions struct

+ RateLimiter ratelimiter.RateLimiter

+ type GitRepositoryReconciler struct

+ ControllerName string

+ Storage *Storage

+ func (r *GitRepositoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr 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

+ RateLimiter ratelimiter.RateLimiter

+ type HelmChartReconciler struct

+ Cache *cache.Cache

+ ControllerName string

+ Getters helmgetter.Providers

+ RegistryClientGenerator RegistryClientGeneratorFunc

+ Storage *Storage

+ TTL time.Duration

+ func (r *HelmChartReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)

+ func (r *HelmChartReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

+ func (r *HelmChartReconciler) SetupWithManagerAndOptions(ctx context.Context, mgr ctrl.Manager, opts HelmChartReconcilerOptions) error

+ type HelmChartReconcilerOptions struct

+ RateLimiter ratelimiter.RateLimiter

+ type HelmRepositoryOCIReconciler struct

+ ControllerName string

+ Getters helmgetter.Providers

+ RegistryClientGenerator RegistryClientGeneratorFunc

+ func (r *HelmRepositoryOCIReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)

+ func (r *HelmRepositoryOCIReconciler) SetupWithManager(mgr ctrl.Manager) error

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

+ type HelmRepositoryReconciler struct

+ Cache *cache.Cache

+ ControllerName string

+ Getters helmgetter.Providers

+ Storage *Storage

+ TTL time.Duration

+ func (r *HelmRepositoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)

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

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

+ type HelmRepositoryReconcilerOptions struct

+ RateLimiter ratelimiter.RateLimiter

+ type OCIRepositoryReconciler struct

+ ControllerName string

+ Storage *Storage

+ func (r *OCIRepositoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)

+ func (r *OCIRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *OCIRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts OCIRepositoryReconcilerOptions) error

+ type OCIRepositoryReconcilerOptions struct

+ DependencyRequeueInterval time.Duration

+ RateLimiter ratelimiter.RateLimiter

+ type RegistryClientGeneratorFunc func(isLogin bool) (*helmreg.Client, string, error)

+ 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

+ ArtifactRetentionRecords int

+ ArtifactRetentionTTL time.Duration

+ BasePath string

+ Hostname string

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

+ func (s Storage) Archive(artifact *v1.Artifact, dir string, filter ArchiveFileFilter) (err error)

+ func (s Storage) ArtifactExist(artifact v1.Artifact) bool

+ func (s Storage) AtomicWriteFile(artifact *v1.Artifact, reader io.Reader, mode os.FileMode) (err error)

+ func (s Storage) Copy(artifact *v1.Artifact, reader io.Reader) (err error)

+ func (s Storage) CopyFromPath(artifact *v1.Artifact, path string) (err error)

+ func (s Storage) CopyToPath(artifact *v1.Artifact, subPath, toPath string) error

+ func (s Storage) GarbageCollect(ctx context.Context, artifact v1.Artifact, timeout time.Duration) ([]string, error)

+ func (s Storage) LocalPath(artifact v1.Artifact) string

+ func (s Storage) Lock(artifact v1.Artifact) (unlock func(), err error)

+ func (s Storage) MkdirAll(artifact v1.Artifact) error

+ func (s Storage) NewArtifactFor(kind string, metadata metav1.Object, revision, fileName string) v1.Artifact

+ func (s Storage) Remove(artifact v1.Artifact) error

+ func (s Storage) RemoveAll(artifact v1.Artifact) (string, error)

+ func (s Storage) RemoveAllButCurrent(artifact v1.Artifact) ([]string, error)

+ func (s Storage) SetArtifactURL(artifact *v1.Artifact)

+ func (s Storage) SetHostname(URL string) string

+ func (s Storage) Symlink(artifact v1.Artifact, linkName string) (string, error)

+ func (s Storage) VerifyArtifact(artifact v1.Artifact) error