Versions in this module Expand all Collapse all v1 v1.2.8 Feb 22, 2023 v1.2.6 Feb 22, 2023 v1.2.5 Feb 22, 2023 v1.2.4 Feb 22, 2023 Changes in this version + const ENV_CLI_MAX_STATUS_ATTEMPTS + const ENV_CLI_NO_PARALLEL + const ENV_CLI_VERBOSE_COMMANDS + const ENV_POLICY_NO_GET_WAIT + const ENV_POST_POLICY_CHANGE_SLEEP + const ENV_RUN_ISSUE_TESTS + const ENV_SKIP_DEBUG + const ENV_SKIP_NAMESPACE_SETUP + const ENV_SKIP_NAMESPACE_TEARDOWN + var FlagsParsed bool = false + var TestFlags testFlags + func ConnectSimplePublicPrivate(ctx context.Context, r *ClusterTestRunnerBase) error + func EdgeKubeConfigs() []string + func GetConsoleData(cc *ClusterContext, consoleUser, consolePass string) (data.ConsoleData, error) + func HandleInterruptSignal(fn func()) + func IsMaxStatusAttemptsReached(currentAttempt int) bool + func IsTestInterrupted() bool + func IsVerboseCommandOutput() bool + func KubeConfigDefault() string + func KubeConfigFiles(includeEdge, includePublic bool) []string + func KubeConfigFilesCount(includeEdge, includePublic bool) int + func KubeConfigs() []string + func MultipleClusters() bool + func ParseFlags() + func PostPolicyChangeSleep() + func RemoveNamespacesForContexts(r *ClusterTestRunnerBase, public []int, priv []int) error + func RunBasicTopologyTests(m *testing.M, topology BasicTopologySetup) + func SetupSimplePublicPrivate(ctx context.Context, r *ClusterTestRunnerBase) error + func ShouldPolicyWaitOnGet() bool + func ShouldRunScenariosInParallel() bool + func ShouldSkipNamespaceSetup() bool + func ShouldSkipNamespaceTeardown() bool + func SkipIssueTests(t *testing.T) + func StopIfInterrupted(t *testing.T) + func TearDownSimplePublicAndPrivate(r *ClusterTestRunnerBase) + func WaitForSkupperConnectedSites(ctx context.Context, cc *ClusterContext, sitesTotal int) error + func WaitSkupperComponentRunning(c *ClusterContext, component string) error + func WaitSkupperRunning(c *ClusterContext) error + type BasicTopologySetup struct + NamespaceId string + PostSkupperSetup func(testRunner *ClusterTestRunnerBase) error + PreSkupperSetup func(testRunner *ClusterTestRunnerBase) error + TestRunner *ClusterTestRunnerBase + type ClusterContext struct + Id int + KubeConfig string + Namespace string + Private bool + VanClient *vanClient.VanClient + func (cc *ClusterContext) CreateNamespace() error + func (cc *ClusterContext) DeleteNamespace() error + func (cc *ClusterContext) DumpTestInfo(dirName string) + func (cc *ClusterContext) KubectlExec(command string) ([]byte, error) + func (cc *ClusterContext) LabelNamespace(label string, value string) (err error) + type ClusterNeeds struct + NamespaceId string + PrivateClusters int + PublicClusters int + type ClusterTestRunner interface + Build func(needs ClusterNeeds, vanClientProvider VanClientProvider) ([]*ClusterContext, error) + GetContext func(private bool, id int) (*ClusterContext, error) + GetPrivateContext func(id int) (*ClusterContext, error) + GetPublicContext func(id int) (*ClusterContext, error) + Validate func(needs ClusterNeeds) error + type ClusterTestRunnerBase struct + ClusterContexts []*ClusterContext + Needs ClusterNeeds + func (c *ClusterTestRunnerBase) Build(needs ClusterNeeds, vanClientProvider VanClientProvider) ([]*ClusterContext, error) + func (c *ClusterTestRunnerBase) DumpTestInfo(dirname string) + func (c *ClusterTestRunnerBase) GetContext(private bool, id int) (*ClusterContext, error) + func (c *ClusterTestRunnerBase) GetPrivateContext(id int) (*ClusterContext, error) + func (c *ClusterTestRunnerBase) GetPublicContext(id int) (*ClusterContext, error) + func (c *ClusterTestRunnerBase) Validate(needs ClusterNeeds) error + type VanClientProvider func(namespace string, context string, kubeConfigPath string) (*vanClient.VanClient, error)
Go to main page