poll

Jul 12, 2024

Changes in this version

+ func GitRepoPollKey(gitRepo v1alpha1.GitRepo) *quartz.JobKey

+ type GitFetcher interface

+ LatestCommit func(ctx context.Context, gitrepo *v1alpha1.GitRepo, client client.Client) (string, error)

+ type GitRepoPollJob struct

+ GitRepo v1alpha1.GitRepo

+ func NewGitRepoPollJob(c client.Client, f GitFetcher, gitRepo v1alpha1.GitRepo) *GitRepoPollJob

+ func (j *GitRepoPollJob) Description() string

+ func (j *GitRepoPollJob) Execute(ctx context.Context) error

+ func (j *GitRepoPollJob) String() string

+ type Handler struct

+ func NewHandler(ctx context.Context, client client.Client) *Handler

+ func (h *Handler) AddOrModifyGitRepoPollJob(ctx context.Context, gitRepo v1alpha1.GitRepo)

+ func (h *Handler) CleanUpGitRepoPollJobs(ctx context.Context)

+ type Watcher interface

+ Finish func()

+ GetSyncInterval func() float64

+ Restart func(ctx context.Context)

+ StartBackgroundSync func(ctx context.Context)

+ UpdateGitRepo func(gitRepo v1alpha1.GitRepo)