Function getScaletestWorkspaces

cli/exp_scaletest.go:2216–2266

(ctx context.Context, client *codersdk.Client, owner, template string)

}

func getScaletestWorkspaces(ctx context.Context, client *codersdk.Client, owner, template string) ([]codersdk.Workspace, int, error) {
	var (
		pageNumber = 0
		limit      = 100
		workspaces []codersdk.Workspace
		skipped    int
	)

	me, err := client.User(ctx, codersdk.Me)
	if err != nil {
		return nil, 0, xerrors.Errorf("check logged-in user")
	}

	dv, err := client.DeploymentConfig(ctx)
	if err != nil {
		return nil, 0, xerrors.Errorf("fetch deployment config: %w", err)
	}
	noOwnerAccess := dv.Values != nil && dv.Values.DisableOwnerWorkspaceExec.Value()

	for {
		page, err := client.Workspaces(ctx, codersdk.WorkspaceFilter{
			Name:     "scaletest-",
			Template: template,
			Owner:    owner,
			Offset:   pageNumber * limit,
			Limit:    limit,
		})
		if err != nil {
			return nil, 0, xerrors.Errorf("fetch scaletest workspaces page %d: %w", pageNumber, err)
		}

		pageNumber++
		if len(page.Workspaces) == 0 {
			break
		}

		pageWorkspaces := make([]codersdk.Workspace, 0, len(page.Workspaces))
		for _, w := range page.Workspaces {
			if !loadtestutil.IsScaleTestWorkspace(w.Name, w.OwnerName) {
				continue
			}
			if noOwnerAccess && w.OwnerID != me.ID {
				skipped++
				continue
			}
			pageWorkspaces = append(pageWorkspaces, w)
		}
		workspaces = append(workspaces, pageWorkspaces...)
	}
	return workspaces, skipped, nil
}

func getScaletestUsers(ctx context.Context, client *codersdk.Client) ([]codersdk.User, error) {
	var (