controllers

Documentation

Index

• Constants
• func CloneAndAddLabel(labels map[string]string, labelKey, labelValue string) map[string]string
• func CloneSelectorAndAddLabel(selector *metav1.LabelSelector, labelKey, labelValue string) *metav1.LabelSelector
• func ComputeHash(template interface{}) string
• func MatchSchedule(now time.Time, startTime, endTime time.Time, recurrenceRule RecurrenceRule) (*Period, *Period, error)
• type HorizontalRunnerAutoscalerGitHubWebhook
  • func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) Handle(w http.ResponseWriter, r *http.Request)
  • func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) MatchCheckRunEvent(event *github.CheckRunEvent) func(scaleUpTrigger v1alpha1.ScaleUpTrigger) bool
  • func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) MatchPullRequestEvent(event *github.PullRequestEvent) func(scaleUpTrigger v1alpha1.ScaleUpTrigger) bool
  • func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) MatchPushEvent(event *github.PushEvent) func(scaleUpTrigger v1alpha1.ScaleUpTrigger) bool
  • func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) SetupWithManager(mgr ctrl.Manager) error
• type HorizontalRunnerAutoscalerReconciler
  • func (r *HorizontalRunnerAutoscalerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *HorizontalRunnerAutoscalerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Override
• type Period
  • func (r *Period) String() string
• type RecurrenceRule
• type RunnerDeploymentReconciler
  • func (r *RunnerDeploymentReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *RunnerDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RunnerReconciler
  • func (r *RunnerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *RunnerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RunnerReplicaSetReconciler
  • func (r *RunnerReplicaSetReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *RunnerReplicaSetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ScaleTarget

Constants

const (
	LabelKeyRunnerTemplateHash   = "runner-template-hash"
	LabelKeyRunnerDeploymentName = "runner-deployment-name"
)

const (
	DefaultScaleDownDelay = 10 * time.Minute
)

const (
	LabelKeyPodTemplateHash = "pod-template-hash"
)

Functions

func CloneAndAddLabel

func CloneAndAddLabel(labels map[string]string, labelKey, labelValue string) map[string]string

Clones the given map and returns a new map with the given key and value added. Returns the given map, if labelKey is empty.

Proudly copied from k8s.io/kubernetes/pkg/util/labels.CloneAndAddLabel

func CloneSelectorAndAddLabel

func CloneSelectorAndAddLabel(selector *metav1.LabelSelector, labelKey, labelValue string) *metav1.LabelSelector

Clones the given selector and returns a new selector with the given key and value added. Returns the given selector, if labelKey is empty.

Proudly copied from k8s.io/kubernetes/pkg/util/labels.CloneSelectorAndAddLabel

func ComputeHash

func ComputeHash(template interface{}) string

ComputeHash returns a hash value calculated from pod template and a collisionCount to avoid hash collision. The hash will be safe encoded to avoid bad words.

Proudly modified and adopted from k8s.io/kubernetes/pkg/util/hash.DeepHashObject and k8s.io/kubernetes/pkg/controller.ComputeHash.

func MatchSchedule

func MatchSchedule(now time.Time, startTime, endTime time.Time, recurrenceRule RecurrenceRule) (*Period, *Period, error)

Types

type HorizontalRunnerAutoscalerGitHubWebhook

type HorizontalRunnerAutoscalerGitHubWebhook struct {
	client.Client
	Log      logr.Logger
	Recorder record.EventRecorder
	Scheme   *runtime.Scheme

	// SecretKeyBytes is the byte representation of the Webhook secret token
	// the administrator is generated and specified in GitHub Web UI.
	SecretKeyBytes []byte

	// Namespace is the namespace to watch for HorizontalRunnerAutoscaler's to be
	// scaled on Webhook.
	// Set to empty for letting it watch for all namespaces.
	Namespace string
	Name      string
}

HorizontalRunnerAutoscalerGitHubWebhook autoscales a HorizontalRunnerAutoscaler and the RunnerDeployment on each GitHub Webhook received

func (*HorizontalRunnerAutoscalerGitHubWebhook) Handle

func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) Handle(w http.ResponseWriter, r *http.Request)

func (*HorizontalRunnerAutoscalerGitHubWebhook) MatchCheckRunEvent

func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) MatchCheckRunEvent(event *github.CheckRunEvent) func(scaleUpTrigger v1alpha1.ScaleUpTrigger) bool

func (*HorizontalRunnerAutoscalerGitHubWebhook) MatchPullRequestEvent

func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) MatchPullRequestEvent(event *github.PullRequestEvent) func(scaleUpTrigger v1alpha1.ScaleUpTrigger) bool

func (*HorizontalRunnerAutoscalerGitHubWebhook) MatchPushEvent

func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) MatchPushEvent(event *github.PushEvent) func(scaleUpTrigger v1alpha1.ScaleUpTrigger) bool

func (*HorizontalRunnerAutoscalerGitHubWebhook) Reconcile

func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) Reconcile(request reconcile.Request) (reconcile.Result, error)

func (*HorizontalRunnerAutoscalerGitHubWebhook) SetupWithManager

func (autoscaler *HorizontalRunnerAutoscalerGitHubWebhook) SetupWithManager(mgr ctrl.Manager) error

type HorizontalRunnerAutoscalerReconciler

type HorizontalRunnerAutoscalerReconciler struct {
	client.Client
	GitHubClient *github.Client
	Log          logr.Logger
	Recorder     record.EventRecorder
	Scheme       *runtime.Scheme

	CacheDuration time.Duration
	Name          string
}

HorizontalRunnerAutoscalerReconciler reconciles a HorizontalRunnerAutoscaler object

func (*HorizontalRunnerAutoscalerReconciler) Reconcile

func (r *HorizontalRunnerAutoscalerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*HorizontalRunnerAutoscalerReconciler) SetupWithManager

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

type Override

type Override struct {
	ScheduledOverride v1alpha1.ScheduledOverride
	Period            Period
}

type Period

type Period struct {
	StartTime time.Time
	EndTime   time.Time
}

func (*Period) String

func (r *Period) String() string

type RecurrenceRule

type RecurrenceRule struct {
	Frequency string
	UntilTime time.Time
}

type RunnerDeploymentReconciler

type RunnerDeploymentReconciler struct {
	client.Client
	Log                logr.Logger
	Recorder           record.EventRecorder
	Scheme             *runtime.Scheme
	CommonRunnerLabels []string
	Name               string
}

RunnerDeploymentReconciler reconciles a Runner object

func (*RunnerDeploymentReconciler) Reconcile

func (r *RunnerDeploymentReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*RunnerDeploymentReconciler) SetupWithManager

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

type RunnerReconciler

type RunnerReconciler struct {
	client.Client
	Log                         logr.Logger
	Recorder                    record.EventRecorder
	Scheme                      *runtime.Scheme
	GitHubClient                *github.Client
	RunnerImage                 string
	DockerImage                 string
	Name                        string
	RegistrationRecheckInterval time.Duration
	RegistrationRecheckJitter   time.Duration
}

RunnerReconciler reconciles a Runner object

func (*RunnerReconciler) Reconcile

func (r *RunnerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*RunnerReconciler) SetupWithManager

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

type RunnerReplicaSetReconciler

type RunnerReplicaSetReconciler struct {
	client.Client
	Log          logr.Logger
	Recorder     record.EventRecorder
	Scheme       *runtime.Scheme
	GitHubClient *github.Client
	Name         string
}

RunnerReplicaSetReconciler reconciles a Runner object

func (*RunnerReplicaSetReconciler) Reconcile

func (r *RunnerReplicaSetReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*RunnerReplicaSetReconciler) SetupWithManager

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

type ScaleTarget

type ScaleTarget struct {
	v1alpha1.HorizontalRunnerAutoscaler
	v1alpha1.ScaleUpTrigger
}