Method GetRunnerByName

util/github/scalesets/runners.go:130–165

(ctx context.Context, runnerName string)

}

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

	path := fmt.Sprintf("%s?agentName=%s", runnerEndpoint, runnerName)

	req, err := s.newActionsRequest(ctx, http.MethodGet, path, nil)
	if err != nil {
		return params.RunnerReference{}, fmt.Errorf("failed to construct request: %w", err)
	}

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

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

	if runnerList.Count == 0 {
		return params.RunnerReference{}, fmt.Errorf("could not find runner with name %q: %w", runnerName, runnerErrors.ErrNotFound)
	}

	if runnerList.Count > 1 {
		return params.RunnerReference{}, fmt.Errorf("failed to decode response: %w", err)
	}

	return runnerList.RunnerReferences[0], nil
}

func (s *ScaleSetClient) RemoveRunner(ctx context.Context, runnerID int64) (err error) {
	s.recordOperation("RemoveRunner")