reconciler

Documentation

Index

• func AuthorizeAndAssignDefaults(ctx context.Context, c client.Client, gitrepo *fleet.GitRepo) error
• type GitFetcher
• type GitJobReconciler
  • func (r *GitJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *GitJobReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RealClock
  • func (RealClock) Now() time.Time
  • func (RealClock) Since(t time.Time) time.Duration
• type StatusReconciler
  • func (r *StatusReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *StatusReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TimeGetter
• type TypedResourceVersionUnchangedPredicate
  • func (TypedResourceVersionUnchangedPredicate[T]) Create(e event.CreateEvent) bool
  • func (TypedResourceVersionUnchangedPredicate[T]) Delete(e event.DeleteEvent) bool
  • func (TypedResourceVersionUnchangedPredicate[T]) Generic(e event.GenericEvent) bool
  • func (TypedResourceVersionUnchangedPredicate[T]) Update(e event.TypedUpdateEvent[T]) bool

Functions

func AuthorizeAndAssignDefaults

func AuthorizeAndAssignDefaults(ctx context.Context, c client.Client, gitrepo *fleet.GitRepo) error

AuthorizeAndAssignDefaults applies restrictions and mutates the passed in GitRepo if it passes the restrictions

Types

type GitFetcher

type GitFetcher interface {
	LatestCommit(ctx context.Context, gitrepo *v1alpha1.GitRepo, client client.Client) (string, error)
}

type GitJobReconciler

type GitJobReconciler struct {
	client.Client
	Scheme          *runtime.Scheme
	Image           string
	Scheduler       quartz.Scheduler
	Workers         int
	ShardID         string
	JobNodeSelector string
	GitFetcher      GitFetcher
	Clock           TimeGetter
	Recorder        record.EventRecorder
}

CronJobReconciler reconciles a GitRepo resource to create a git cloning k8s job

func (*GitJobReconciler) Reconcile

func (r *GitJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile compares the state specified by the GitRepo object against the actual cluster state. It checks the Git repository for new commits and creates a job to clone the repository if a new commit is found. In case of an error, the output of the job is stored in the status.

func (*GitJobReconciler) SetupWithManager

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

type RealClock

type RealClock struct{}

func (RealClock) Now

func (RealClock) Now() time.Time

func (RealClock) Since

func (RealClock) Since(t time.Time) time.Duration

type StatusReconciler

type StatusReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	Workers int
	ShardID string
}

func (*StatusReconciler) Reconcile

func (r *StatusReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reads the stat of the GitRepo and BundleDeployments and computes status fields for the GitRepo. This status is used to display information to the user.

func (*StatusReconciler) SetupWithManager

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

type TimeGetter

type TimeGetter interface {
	Now() time.Time
	Since(t time.Time) time.Duration
}

TimeGetter interface is used to mock the time.Now() call in unit tests

type TypedResourceVersionUnchangedPredicate

type TypedResourceVersionUnchangedPredicate[T metav1.Object] struct {
	predicate.TypedFuncs[T]
}

TypedResourceVersionUnchangedPredicate implements a update predicate to allow syncPeriod to trigger the reconciler

func (TypedResourceVersionUnchangedPredicate[T]) Create

func (TypedResourceVersionUnchangedPredicate[T]) Create(e event.CreateEvent) bool

func (TypedResourceVersionUnchangedPredicate[T]) Delete

func (TypedResourceVersionUnchangedPredicate[T]) Delete(e event.DeleteEvent) bool

func (TypedResourceVersionUnchangedPredicate[T]) Generic

func (TypedResourceVersionUnchangedPredicate[T]) Generic(e event.GenericEvent) bool

func (TypedResourceVersionUnchangedPredicate[T]) Update

func (TypedResourceVersionUnchangedPredicate[T]) Update(e event.TypedUpdateEvent[T]) bool

Update implements default UpdateEvent filter for validating resource version change.