reconciler

package
v0.14.0-alpha.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2025 License: Apache-2.0 Imports: 61 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// The TTL is the grace period for short-lived metrics to be kept alive to
	// make sure Prometheus scrapes them.
	ShortLivedMetricsTTL = 120 * time.Second
)

Variables

View Source 
var (
	GitJobDurationBuckets = []float64{1, 2, 5, 10, 30, 60, 180, 300, 600, 1200, 1800, 3600}
)

Functions

func AuthorizeAndAssignDefaults added in v0.10.6 

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 added in v0.10.1 

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
	SystemNamespace string
	KnownHosts      KnownHostsGetter
}

GitJobReconciler 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 KnownHostsGetter added in v0.10.11 

type KnownHostsGetter interface {
	Get(ctx context.Context, client client.Client, namespace, secretName string) (string, error)
	IsStrict() bool
}

type RealClock added in v0.10.1 

type RealClock struct{}

func (RealClock) Now added in v0.10.1 

func (RealClock) Now() time.Time

func (RealClock) Since added in v0.10.1 

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

type StatusReconciler added in v0.11.0 

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

func (*StatusReconciler) Reconcile added in v0.11.0 

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 added in v0.11.0 

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

type TimeGetter added in v0.10.1 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.