runner

type ECSClient ¶

type ECSClient interface {
	RunTask(ctx context.Context, input *ecs.RunTaskInput, opts ...func(*ecs.Options)) (*ecs.RunTaskOutput, error)
	StopTask(ctx context.Context, input *ecs.StopTaskInput, opts ...func(*ecs.Options)) (*ecs.StopTaskOutput, error)
	ListTasks(ctx context.Context, input *ecs.ListTasksInput, opts ...func(*ecs.Options)) (*ecs.ListTasksOutput, error)
	DescribeTasks(ctx context.Context, input *ecs.DescribeTasksInput, opts ...func(*ecs.Options)) (*ecs.DescribeTasksOutput, error)
}

ECSClient is the subset of the ECS API that the runner package needs.

type ECSRunner ¶

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

ECSRunner manages ECS tasks for GitHub Actions runners.

func NewECSRunner(client ECSClient, cluster string, logger *slog.Logger) *ECSRunner

func (r *ECSRunner) RunTask(ctx context.Context, input RunTaskInput) (string, error)

func (r *ECSRunner) StopTask(ctx context.Context, taskARN, reason string) error

type Reaper ¶

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

Reaper periodically checks for stale runner tasks and stops them. It handles two cases:

• Tasks stuck in PENDING state beyond the pending timeout
• Tasks running longer than the configured max runtime

func NewReaper(client ECSClient, cluster, scaleSetName string, maxRuntime, pendingTimeout time.Duration, logger *slog.Logger) *Reaper

func (r *Reaper) Run(ctx context.Context, interval time.Duration)

func (r *Reaper) Sweep(ctx context.Context) (int, error)

type RunTaskInput ¶

type RunTaskInput struct {
	TaskDefinition   string
	JITConfigEncoded string
	RunnerName       string
	ScaleSetName     string
	Subnets          []string
	SecurityGroups   []string
	CapacityProvider string
	LaunchType       ecsTypes.LaunchType
}

RunTaskInput holds the parameters for creating a new runner ECS task.

type State ¶

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

State tracks runner tasks and their lifecycle (idle -> busy -> done). It is safe for concurrent use.

func NewState() *State

func (s *State) AddIdle(name, taskARN string)

func (s *State) Count() int

func (s *State) IdleCount() int

func (s *State) MarkBusy(name string)

func (s *State) MarkDone(name string) string