reconciler

Documentation

Index

• 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 TimeGetter

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 is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. The Reconcile function compares the state specified by the GitRepo object against the actual cluster state, and then performs operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile

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 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