mirror of
https://github.com/actions/actions-runner-controller.git
synced 2025-12-10 19:50:30 +00:00
ab1c39de57
* feat: HorizontalRunnerAutoscaler Webhook server This introduces a Webhook server that responds GitHub `check_run`, `pull_request`, and `push` events by scaling up matched HorizontalRunnerAutoscaler by 1 replica. This allows you to immediately add "resource slack" for future GitHub Actions job runs, without waiting next sync period to add insufficient runners. This feature is highly inspired by https://github.com/philips-labs/terraform-aws-github-runner. terraform-aws-github-runner can manage one set of runners per deployment, where actions-runner-controller with this feature can manage as many sets of runners as you declare with HorizontalRunnerAutoscaler and RunnerDeployment pairs. On each GitHub event received, the webhook server queries repository-wide and organizational runners from the cluster and searches for the single target to scale up. The webhook server tries to match HorizontalRunnerAutoscaler.Spec.ScaleUpTriggers[].GitHubEvent.[CheckRun|Push|PullRequest] against the event and if it finds only one HRA, it is the scale target. If none or two or more targets are found for repository-wide runners, it does the same on organizational runners. Changes: * Fix integration test * Update manifests * chart: Add support for github webhook server * dockerfile: Include github-webhook-server binary * Do not import unversioned go-github * Update README
75 lines
1.6 KiB
Go
75 lines
1.6 KiB
Go
package fake
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"strconv"
|
|
|
|
"github.com/google/go-github/v33/github"
|
|
"github.com/gorilla/mux"
|
|
)
|
|
|
|
type RunnersList struct {
|
|
runners []*github.Runner
|
|
}
|
|
|
|
func NewRunnersList() *RunnersList {
|
|
return &RunnersList{
|
|
runners: make([]*github.Runner, 0),
|
|
}
|
|
}
|
|
|
|
func (r *RunnersList) Add(runner *github.Runner) {
|
|
if !exists(r.runners, runner) {
|
|
r.runners = append(r.runners, runner)
|
|
}
|
|
}
|
|
|
|
func (r *RunnersList) GetServer() *httptest.Server {
|
|
router := mux.NewRouter()
|
|
|
|
router.Handle("/repos/{owner}/{repo}/actions/runners", r.HandleList())
|
|
router.Handle("/repos/{owner}/{repo}/actions/runners/{id}", r.handleRemove())
|
|
router.Handle("/orgs/{org}/actions/runners", r.HandleList())
|
|
router.Handle("/orgs/{org}/actions/runners/{id}", r.handleRemove())
|
|
|
|
return httptest.NewServer(router)
|
|
}
|
|
|
|
func (r *RunnersList) HandleList() http.HandlerFunc {
|
|
return func(w http.ResponseWriter, res *http.Request) {
|
|
j, err := json.Marshal(github.Runners{
|
|
TotalCount: len(r.runners),
|
|
Runners: r.runners,
|
|
})
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
w.Write(j)
|
|
}
|
|
}
|
|
|
|
func (r *RunnersList) handleRemove() http.HandlerFunc {
|
|
return func(w http.ResponseWriter, res *http.Request) {
|
|
vars := mux.Vars(res)
|
|
for i, runner := range r.runners {
|
|
if runner.ID != nil && vars["id"] == strconv.FormatInt(*runner.ID, 10) {
|
|
r.runners = append(r.runners[:i], r.runners[i+1:]...)
|
|
}
|
|
}
|
|
w.WriteHeader(http.StatusOK)
|
|
}
|
|
}
|
|
|
|
func exists(runners []*github.Runner, runner *github.Runner) bool {
|
|
for _, r := range runners {
|
|
if *r.Name == *runner.Name {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|