controllers

Documentation

Index

• type RunnerManager
  • func NewRunnerManager(log logr.Logger, k8sClient client.Client, scheme *runtime.Scheme, ...) RunnerManager
• type RunnerPoolReconciler
  • func NewRunnerPoolReconciler(log logr.Logger, client client.Client, scheme *runtime.Scheme, ...) *RunnerPoolReconciler
  • func (r *RunnerPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RunnerPoolReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SecretUpdater
  • func NewSecretUpdater(log logr.Logger, k8sClient client.Client, ...) SecretUpdater

Types

type RunnerManager

type RunnerManager interface {
	StartOrUpdate(*meowsv1alpha1.RunnerPool, *github.ClientCredential) error
	Stop(*meowsv1alpha1.RunnerPool) error
	StopAll()
}

RunnerManager manages runner pods and runners registered in GitHub. It generates one goroutine for each RunnerPool CR to manage them.

func NewRunnerManager

func NewRunnerManager(log logr.Logger, k8sClient client.Client, scheme *runtime.Scheme, githubClientFactory github.ClientFactory, runnerPodClient runner.Client, interval time.Duration) RunnerManager

type RunnerPoolReconciler

type RunnerPoolReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

RunnerPoolReconciler reconciles a RunnerPool object

func NewRunnerPoolReconciler

func NewRunnerPoolReconciler(
	log logr.Logger, client client.Client, scheme *runtime.Scheme, runnerImage string,
	runnerManager RunnerManager, secretUpdater SecretUpdater,
	organizationRegexp, repositoryRegexp *regexp.Regexp) *RunnerPoolReconciler

NewRunnerPoolReconciler creates RunnerPoolReconciler

func (*RunnerPoolReconciler) Reconcile

func (r *RunnerPoolReconciler) 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.

func (*RunnerPoolReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SecretUpdater

type SecretUpdater interface {
	Start(*meowsv1alpha1.RunnerPool, *github.ClientCredential) error
	Stop(*meowsv1alpha1.RunnerPool) error
	StopAll()
}

SecretUpdater creates a registration token for self-hosted runners and updates a secret periodically. It generates one goroutine for each RunnerPool CR.

func NewSecretUpdater

func NewSecretUpdater(log logr.Logger, k8sClient client.Client, githubClientFactory github.ClientFactory) SecretUpdater