Method GenerateJitRunnerConfig

util/github/scalesets/runners.go:33–72

(ctx context.Context, runnerName string, scaleSetID int)

}

func (s *ScaleSetClient) GenerateJitRunnerConfig(ctx context.Context, runnerName string, scaleSetID int) (_ params.RunnerScaleSetJitRunnerConfig, err error) {
	s.recordOperation("GenerateJitRunnerConfig")
	defer func() {
		if err != nil {
			s.recordFailedOperation("GenerateJitRunnerConfig")
		}
	}()

	runnerSettings := scaleSetJitRunnerConfig{
		Name:       runnerName,
		WorkFolder: "_work",
	}

	body, err := json.Marshal(runnerSettings)
	if err != nil {
		return params.RunnerScaleSetJitRunnerConfig{}, err
	}

	if err := s.ensureAdminInfo(ctx); err != nil {
		return params.RunnerScaleSetJitRunnerConfig{}, fmt.Errorf("failed to ensure admin info: %w", err)
	}

	jitConfigPath := fmt.Sprintf("%s/%d/generatejitconfig", scaleSetEndpoint, scaleSetID)
	req, err := s.newActionsRequest(ctx, http.MethodPost, jitConfigPath, bytes.NewBuffer(body))
	if err != nil {
		return params.RunnerScaleSetJitRunnerConfig{}, fmt.Errorf("failed to create request: %w", err)
	}

	resp, err := s.Do(req)
	if err != nil {
		return params.RunnerScaleSetJitRunnerConfig{}, fmt.Errorf("request failed for %s: %w", req.URL.String(), err)
	}
	defer resp.Body.Close()

	var runnerJitConfig params.RunnerScaleSetJitRunnerConfig
	if err := json.NewDecoder(resp.Body).Decode(&runnerJitConfig); err != nil {
		return params.RunnerScaleSetJitRunnerConfig{}, fmt.Errorf("failed to decode response: %w", err)
	}
	return runnerJitConfig, nil
}

func (s *ScaleSetClient) GetRunner(ctx context.Context, runnerID int64) (_ params.RunnerReference, err error) {
	s.recordOperation("GetRunner")