fixture

package
v3.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2026 License: Apache-2.0 Imports: 51 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultTestUserPassword = "password"
	TestingLabel            = "e2e.argoproj.io"
	ArgoCDNamespace         = "argocd-e2e"
	ArgoCDAppNamespace      = "argocd-e2e-external"

	GuestbookPath = "guestbook"

	ProjectName = "argo-project"

	// cmp plugin sock file path
	PluginSockFilePath = "/app/config/plugin"

	// finalizer to add to resources during tests. Make sure that the resource Kind of your object
	// is included in the test EnsureCleanState code
	TestFinalizer = TestingLabel + "/finalizer"

	// Account for batch events processing (set to 1ms in e2e tests)
	WhenThenSleepInterval = 5 * time.Millisecond
)
View Source 
const (
	EnvAdminUsername           = "ARGOCD_E2E_ADMIN_USERNAME"
	EnvAdminPassword           = "ARGOCD_E2E_ADMIN_PASSWORD"
	EnvArgoCDServerName        = "ARGOCD_E2E_SERVER_NAME"
	EnvArgoCDRedisHAProxyName  = "ARGOCD_E2E_REDIS_HAPROXY_NAME"
	EnvArgoCDRedisName         = "ARGOCD_E2E_REDIS_NAME"
	EnvArgoCDRepoServerName    = "ARGOCD_E2E_REPO_SERVER_NAME"
	EnvArgoCDAppControllerName = "ARGOCD_E2E_APPLICATION_CONTROLLER_NAME"
)
View Source 
const (
	RepoURLTypeFile                 = "file"
	RepoURLTypeHTTPS                = "https"
	RepoURLTypeHTTPSOrg             = "https-org"
	RepoURLTypeHTTPSClientCert      = "https-cc"
	RepoURLTypeHTTPSSubmodule       = "https-sub"
	RepoURLTypeHTTPSSubmoduleParent = "https-par"
	RepoURLTypeSSH                  = "ssh"
	RepoURLTypeSSHSubmodule         = "ssh-sub"
	RepoURLTypeSSHSubmoduleParent   = "ssh-par"
	RepoURLTypeHelm                 = "helm"
	RepoURLTypeHelmParent           = "helm-par"
	RepoURLTypeHelmOCI              = "helm-oci"
	RepoURLTypeOCI                  = "oci"
	GitUsername                     = "admin"
	GitPassword                     = "password"
	GitBearerToken                  = "test"
	GithubAppID                     = "2978632978"
	GithubAppInstallationID         = "7893789433789"
	GpgGoodKeyID                    = "D56C4FCA57A46444"
	HelmOCIRegistryURL              = "localhost:5000/myrepo"
	HelmAuthenticatedOCIRegistryURL = "localhost:5001/myrepo"
	OCIRegistryURL                  = "oci://localhost:5000/my-oci-repo"
	OCIHostURL                      = "oci://localhost:5000"
	AuthenticatedOCIHostURL         = "oci://localhost:5001"
)
View Source 
const (
	EnvRepoURLTypeSSH                  = "ARGOCD_E2E_REPO_SSH"
	EnvRepoURLTypeSSHSubmodule         = "ARGOCD_E2E_REPO_SSH_SUBMODULE"
	EnvRepoURLTypeSSHSubmoduleParent   = "ARGOCD_E2E_REPO_SSH_SUBMODULE_PARENT"
	EnvRepoURLTypeHTTPS                = "ARGOCD_E2E_REPO_HTTPS"
	EnvRepoURLTypeHTTPSOrg             = "ARGOCD_E2E_REPO_HTTPS_ORG"
	EnvRepoURLTypeHTTPSClientCert      = "ARGOCD_E2E_REPO_HTTPS_CLIENT_CERT"
	EnvRepoURLTypeHTTPSSubmodule       = "ARGOCD_E2E_REPO_HTTPS_SUBMODULE"
	EnvRepoURLTypeHTTPSSubmoduleParent = "ARGOCD_E2E_REPO_HTTPS_SUBMODULE_PARENT"
	EnvRepoURLTypeHelm                 = "ARGOCD_E2E_REPO_HELM"
	EnvRepoURLDefault                  = "ARGOCD_E2E_REPO_DEFAULT"
)

Variables

View Source 
var (
	KubeClientset    kubernetes.Interface
	KubeConfig       *rest.Config
	DynamicClientset dynamic.Interface
	AppClientset     appclientset.Interface
	ArgoCDClientset  apiclient.Client

	AdminPassword string
)

Functions

func AddAnnotatedTag added in v3.0.21 

func AddAnnotatedTag(t *testing.T, name string, message string)

func AddFile 

func AddFile(t *testing.T, path, contents string)

func AddSignedFile 

func AddSignedFile(t *testing.T, path, contents string)

func AddSignedTag 

func AddSignedTag(t *testing.T, name string)

func AddTag 

func AddTag(t *testing.T, name string)

func AddTagWithForce added in v3.0.21 

func AddTagWithForce(t *testing.T, name string)

func AppNamespace 

func AppNamespace() string

func CreateSubmoduleRepos 

func CreateSubmoduleRepos(t *testing.T, repoType string)

func Declarative 

func Declarative(t *testing.T, filename string, values any) (string, error)

create the resource by creating using "kubectl apply", with bonus templating

func Delete 

func Delete(t *testing.T, path string)

func DnsFriendly 

func DnsFriendly(str string, postfix string) string

returns dns friends string which is no longer than 63 characters and has specified postfix at the end

func DoHttpJsonRequest 

func DoHttpJsonRequest(method string, path string, result any, data ...byte) error

DoHttpJsonRequest executes a http request against the Argo CD API server and unmarshals the response body as JSON

func DoHttpRequest 

func DoHttpRequest(method string, path string, host string, data ...byte) (*http.Response, error)

DoHttpRequest executes a http request against the Argo CD API server

func GetApiResources 

func GetApiResources(t *testing.T) string

func GetApiServerAddress 

func GetApiServerAddress() string

func GetEnvWithDefault 

func GetEnvWithDefault(envName, defaultValue string) string

func GetNotificationServerAddress 

func GetNotificationServerAddress() string

func GetToken 

func GetToken() string

func IsLocal 

func IsLocal() bool

IsLocal returns when the tests are being run against a local workload

func IsRemote 

func IsRemote() bool

IsRemote returns true when the tests are being run against a workload that is running in a remote cluster.

func LocalOrRemotePath 

func LocalOrRemotePath(base string) string

LocalOrRemotePath selects a path for a given application based on whether tests are running local or remote.

func LoginAs 

func LoginAs(username string) error

func NormalizeOutput 

func NormalizeOutput(text string) string

utility method to deal with white-space

func Patch 

func Patch(t *testing.T, path string, jsonPatch string)

func RecordTestRun 

func RecordTestRun(t *testing.T)

RecordTestRun records a test that has been run successfully to a text file, so that it can be automatically skipped if requested.

func RegisterKustomizeVersion added in v3.2.0 

func RegisterKustomizeVersion(version, path string) error

func RemoveSubmodule 

func RemoveSubmodule(t *testing.T)

func RepoBaseURL 

func RepoBaseURL(urlType RepoURLType) string

func RepoURL 

func RepoURL(urlType RepoURLType) string

func RestartAPIServer 

func RestartAPIServer(t *testing.T)

RestartAPIServer performs a restart of the API server deployemt and waits until the rollout has completed.

func RestartRepoServer 

func RestartRepoServer(t *testing.T)

RestartRepoServer performs a restart of the repo server deployment and waits until the rollout has completed.

func Run 

func Run(workDir, name string, args ...string) (string, error)

func RunCli 

func RunCli(args ...string) (string, error)

RunCli executes an Argo CD CLI command with no stdin input and default server authentication.

func RunCliWithRetry 

func RunCliWithRetry(maxRetries int, args ...string) (string, error)

RunCliWithRetry executes an Argo CD CLI command with retry logic.

func RunCliWithStdin 

func RunCliWithStdin(stdin string, isKubeConextOnlyCli bool, args ...string) (string, error)

RunCliWithStdin executes an Argo CD CLI command with optional stdin input and authentication.

func RunFunctionsInParallelAndCheckErrors 

func RunFunctionsInParallelAndCheckErrors(t *testing.T, functions []func() error)

func RunPluginCli added in v3.1.0 

func RunPluginCli(stdin string, args ...string) (string, error)

RunPluginCli executes an Argo CD CLI plugin with optional stdin input.

func RunWithStdin 

func RunWithStdin(stdin, workDir, name string, args ...string) (string, error)

func RunWithStdinWithRedactor added in v3.2.0 

func RunWithStdinWithRedactor(stdin, workDir, name string, redactor func(string) string, args ...string) (string, error)

func SetAccounts 

func SetAccounts(accounts map[string][]string) error

func SetEnableManifestGeneration 

func SetEnableManifestGeneration(val map[v1alpha1.ApplicationSourceType]bool) error

func SetImpersonationEnabled 

func SetImpersonationEnabled(impersonationEnabledFlag string) error

func SetInstallationID 

func SetInstallationID(installationID string) error

func SetParamInNotificationsConfigMap 

func SetParamInNotificationsConfigMap(key, value string) error

func SetParamInSettingConfigMap 

func SetParamInSettingConfigMap(key, value string) error

func SetPermissions 

func SetPermissions(permissions []ACL, username string, roleName string) error

func SetProjectSpec 

func SetProjectSpec(project string, spec v1alpha1.AppProjectSpec) error

func SetResourceFilter 

func SetResourceFilter(filters settings.ResourcesFilter) error

func SetResourceOverrides 

func SetResourceOverrides(overrides map[string]v1alpha1.ResourceOverride) error

func SetResourceOverridesSplitKeys 

func SetResourceOverridesSplitKeys(overrides map[string]v1alpha1.ResourceOverride) error

func SetTrackingLabel 

func SetTrackingLabel(trackingLabel string) error

func SetTrackingMethod 

func SetTrackingMethod(trackingMethod string) error

func SkipIfAlreadyRun 

func SkipIfAlreadyRun(t *testing.T)

SkipIfAlreadyRun skips a test if it has been already run by a previous test cycle and was recorded.

func SkipOnEnv 

func SkipOnEnv(t *testing.T, suffixes ...string)

SkipOnEnv allows to skip a test when a given environment variable is set. Environment variable names follow the ARGOCD_E2E_SKIP_<suffix> pattern, and must be set to the string value 'true' in order to skip a test.

func TestNamespace 

func TestNamespace() string

TestNamespace returns the namespace where Argo CD E2E test instance will be running in.

func TmpDir 

func TmpDir() string

TmpDir returns the base directory for e2e test data. It can be overridden via the ARGOCD_E2E_DIR environment variable.

func Tmpl 

func Tmpl(t *testing.T, text string, values any) string

utility method to template a string using a map

func WriteFile 

func WriteFile(t *testing.T, path, contents string)

Types

type ACL 

type ACL struct {
	Resource string
	Action   string
	Scope    string
}

type RepoURLType 

type RepoURLType string

type TestContext added in v3.3.1 

type TestContext interface {
	// SetName sets the DNS-friendly name for this context
	SetName(name string)
	// GetName returns the DNS-friendly name for this context
	GetName() string
	// DeploymentNamespace returns the namespace where test resources are deployed
	DeploymentNamespace() string
	// ID returns the unique identifier for this test run
	ID() string
	// ShortID returns the short unique identifier suffix for this test run
	ShortID() string
	// Token returns the authentication token for API calls
	Token() string
	// SetToken sets the authentication token
	SetToken(token string)
	// T returns the testing.T instance for this test
	T() *testing.T
}

TestContext defines the interface for test-specific state that enables parallel test execution. All fixture Context types should implement this interface by embedding TestState.

type TestOption 

type TestOption func(option *testOption)

func WithTestData 

func WithTestData(testdata string) TestOption

type TestState added in v3.3.1 

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

TestState holds test-specific variables that were previously global. Embed this in Context structs to enable parallel test execution.

func EnsureCleanState 

func EnsureCleanState(t *testing.T, opts ...TestOption) *TestState

func NewTestState added in v3.3.1 

func NewTestState(t *testing.T) *TestState

NewTestState creates a new TestState with unique identifiers for this test run. This generates fresh id, name, and deploymentNamespace values.

func NewTestStateFromContext added in v3.3.1 

func NewTestStateFromContext(ctx TestContext) *TestState

NewTestStateFromContext creates a TestState from an existing TestContext. This allows GivenWithSameState functions to work across different Context types.

func (*TestState) DeploymentNamespace added in v3.3.1 

func (s *TestState) DeploymentNamespace() string

DeploymentNamespace returns the namespace where test resources are deployed

func (*TestState) GetName added in v3.3.1 

func (s *TestState) GetName() string

GetName returns the DNS-friendly name for this context

func (*TestState) ID added in v3.3.1 

func (s *TestState) ID() string

ID returns the unique identifier for this test run

func (*TestState) SetName added in v3.3.1 

func (s *TestState) SetName(name string)

Name sets the DNS-friendly name for this context

func (*TestState) SetToken added in v3.3.1 

func (s *TestState) SetToken(token string)

SetToken sets the authentication token

func (*TestState) ShortID added in v3.3.1 

func (s *TestState) ShortID() string

ShortID returns the short unique identifier suffix for this test run

func (*TestState) T added in v3.3.1 

func (s *TestState) T() *testing.T

T returns the testing.T instance for this test

func (*TestState) Token added in v3.3.1 

func (s *TestState) Token() string

Token returns the authentication token for API calls

type Version 

type Version struct {
	Major, Minor string
}

func (Version) Format 

func (v Version) Format(format string) string

func (Version) String 

func (v Version) String() string

type Versions 

type Versions struct {
	ServerVersion Version
}

func GetVersions 

func GetVersions(t *testing.T) *Versions

Source Files

View all Source files

Directories

Path Synopsis
utils
utils

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.