worker

Documentation

Index

• Constants
• type BranchDeleteEventWorker
  • func NewBranchDeleteEventWorker(tokenManager customScm.NonImpersonatedTokenManager, cachePath string, ...) *BranchDeleteEventWorker
  • func (r *BranchDeleteEventWorker) Run()
• type GitopsWorker
  • func NewGitopsWorker(store *store.Store, gitopsRepo string, gitopsRepoDeployKeyPath string, ...) *GitopsWorker
  • func (w *GitopsWorker) Run()
• type ReleaseStateWorker
  • func (w *ReleaseStateWorker) Run()

Constants

const Dir_RWX_RX_R = 0754

Types

type BranchDeleteEventWorker

type BranchDeleteEventWorker struct {
	// contains filtered or unexported fields
}

func NewBranchDeleteEventWorker

func NewBranchDeleteEventWorker(
	tokenManager customScm.NonImpersonatedTokenManager,
	cachePath string,
	dao *store.Store,
) *BranchDeleteEventWorker

func (*BranchDeleteEventWorker) Run

func (r *BranchDeleteEventWorker) Run()

type GitopsWorker

type GitopsWorker struct {
	// contains filtered or unexported fields
}

func NewGitopsWorker

func NewGitopsWorker(
	store *store.Store,
	gitopsRepo string,
	gitopsRepoDeployKeyPath string,
	tokenManager customScm.NonImpersonatedTokenManager,
	notificationsManager notifications.Manager,
	eventsProcessed prometheus.Counter,
	repoCache *nativeGit.GitopsRepoCache,
) *GitopsWorker

func (*GitopsWorker) Run

func (w *GitopsWorker) Run()

type ReleaseStateWorker

type ReleaseStateWorker struct {
	GitopsRepo string
	RepoCache  *nativeGit.GitopsRepoCache
	Releases   *prometheus.GaugeVec
	Perf       *prometheus.HistogramVec
}

func (*ReleaseStateWorker) Run

func (w *ReleaseStateWorker) Run()