Method CreateOrgPool

runner/organizations.go:208–238

(ctx context.Context, orgID string, param params.CreatePoolParams)

}

func (r *Runner) CreateOrgPool(ctx context.Context, orgID string, param params.CreatePoolParams) (params.Pool, error) {
	if !auth.IsAdmin(ctx) {
		return params.Pool{}, runnerErrors.ErrUnauthorized
	}

	createPoolParams, err := r.appendTagsToCreatePoolParams(param)
	if err != nil {
		return params.Pool{}, fmt.Errorf("error fetching pool params: %w", err)
	}

	if param.RunnerBootstrapTimeout == 0 {
		param.RunnerBootstrapTimeout = appdefaults.DefaultRunnerBootstrapTimeout
	}

	entity, err := r.store.GetForgeEntity(ctx, params.ForgeEntityTypeOrganization, orgID)
	if err != nil {
		return params.Pool{}, fmt.Errorf("failed to get repo: %w", err)
	}

	template, err := r.findTemplate(ctx, entity, param.OSType, param.TemplateID)
	if err != nil {
		return params.Pool{}, fmt.Errorf("failed to find suitable template: %w", err)
	}
	createPoolParams.TemplateID = &template.ID
	pool, err := r.store.CreateEntityPool(ctx, entity, createPoolParams)
	if err != nil {
		return params.Pool{}, fmt.Errorf("error creating pool: %w", err)
	}

	return pool, nil
}

func (r *Runner) GetOrgPoolByID(ctx context.Context, orgID, poolID string) (params.Pool, error) {
	if !auth.IsAdmin(ctx) {