fixtures

Sep 18, 2024 GO-2024-3226

  GO-2024-3226: Argo Workflows Controller: Denial of Service via malicious daemon Workflows in github.com/argoproj/argo-workflows

Jun 17, 2024

Changes in this version

type When

+ func (w *When) GetWorkflow() *wfv1.Workflow

May 27, 2024

Changes in this version

+ var ToHaveFailedPod Condition = func(wf *wfv1.Workflow) (bool, string)

May 13, 2024

Changes in this version

type Then

+ func (t *Then) ExpectWorkflowTaskSet(block func(t *testing.T, wfts *wfv1.WorkflowTaskSet)) *Then

Mar 30, 2023

Changes in this version

type Then

+ func (t *Then) ExpectPVCDeleted() *Then

Feb 7, 2023

Changes in this version

type When

+ func (w *When) WorkflowCondition(condition func(wf *wfv1.Workflow) bool) bool

Sep 17, 2022

Changes in this version

type Then

+ func (t *Then) ExpectArtifactByKey(key string, bucketName string, ...)

type When

+ func (w *When) RemoveFinalizers(shouldErr bool) *When

+ func (w *When) WaitForWorkflowDeletion() *When

+ type WorkflowCompletionOkay bool

Aug 9, 2022

Changes in this version

+ var EnvFactor = env.LookupEnvIntOr("E2E_ENV_FACTOR", 1)

Mar 14, 2022

Changes in this version

type Then

+ func (t *Then) ExpectPods(f func(t *testing.T, pods []apiv1.Pod)) *Then

type When

+ func (w *When) ResumeCronWorkflow(string) *When

+ func (w *When) ShutdownWorkflow(strategy wfv1.ShutdownStrategy) *When

+ func (w *When) SuspendCronWorkflow() *When

+ func (w *When) WaitForWorkflowList(listOptions metav1.ListOptions, condition func(list []wfv1.Workflow) bool) *When

Dec 15, 2021

Changes in this version

+ type PodCondition func(p *corev1.Pod) bool

+ var PodCompleted PodCondition = func(p *corev1.Pod) bool { ... }

+ var PodDeleted PodCondition = func(p *corev1.Pod) bool { ... }

type When

+ func (w *When) WaitForPod(condition PodCondition) *When

Oct 6, 2021

Changes in this version

type When

+ func (w *When) UpdateConfigMap(name string, data map[string]string) *When

Aug 4, 2021 GO-2022-0388 +2 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

  GO-2022-0928: Workflow re-write vulnerability using input parameter in github.com/argoproj/argo-workflows

Aug 3, 2021 GO-2022-0388 +2 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

  GO-2022-0928: Workflow re-write vulnerability using input parameter in github.com/argoproj/argo-workflows

Jul 27, 2021 GO-2022-0388 +2 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

  GO-2022-0928: Workflow re-write vulnerability using input parameter in github.com/argoproj/argo-workflows

Jul 15, 2021 GO-2022-0388 +2 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

  GO-2022-0928: Workflow re-write vulnerability using input parameter in github.com/argoproj/argo-workflows

Jun 28, 2021 GO-2022-0388 +2 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

  GO-2022-0928: Workflow re-write vulnerability using input parameter in github.com/argoproj/argo-workflows

Jun 21, 2021 GO-2022-0388 +2 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

  GO-2022-0928: Workflow re-write vulnerability using input parameter in github.com/argoproj/argo-workflows

Changes in this version

+ var Emissary = Executor("emissary")

+ var ToHaveRunningPod Condition = func(wf *wfv1.Workflow) (bool, string)

type E2ESuite

+ func (s *E2ESuite) AfterTest(suiteName, testName string)

type Then

+ func (t *Then) ExpectArtifact(nodeName, artifactName string, f func(t *testing.T, data []byte))

Jun 21, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

May 25, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

May 24, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

May 24, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

May 14, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

May 11, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

Changes in this version

+ var ToBeErrored = ToHavePhase(wfv1.WorkflowError)

+ var ToHavePhase = func(p wfv1.WorkflowPhase) Condition

Apr 20, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

Apr 1, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

Mar 30, 2021 GO-2022-0388 +1 more

  GO-2022-0388: Argo Server TLS requests could be forged by attacker with network access in github.com/argoproj/argo-workflows

  GO-2022-0405: Potential privilege escalation on Kubernetes >= v1.19 when the Argo Sever is run with `--auth-mode=client` in github.com/argoproj/argo-workflows

Changes in this version

+ const Label

+ const Namespace

+ var BaseLayerArtifacts Need = func(s *E2ESuite) (bool, string)

+ var CI Need = func(s *E2ESuite) (bool, string)

+ var Docker = Executor("docker")

+ var HasInvolvedObject = func(kind string, uid types.UID) func(event apiv1.Event) bool

+ var HasInvolvedObjectWithName = func(kind string, name string) func(event apiv1.Event) bool

+ var K8SAPI = Executor("k8sapi")

+ var Kubelet = Executor("kubelet")

+ var NoError = func(t *testing.T, output string, err error)

+ var Offloading Need = func(s *E2ESuite) (bool, string)

+ var OutputRegexp = func(rx string) func(t *testing.T, output string, err error)

+ var PNS = Executor("pns")

+ var RBAC Need = func(s *E2ESuite) (bool, string)

+ var WorkflowArchive Need = func(s *E2ESuite) (bool, string)

+ func Exec(name string, args ...string) (string, error)

+ func LoadObject(text string) (runtime.Object, error)

+ type Condition func(wf *wfv1.Workflow) (bool, string)

+ var ToBeArchived Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToBeCompleted Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToBeDone Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToBeFailed Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToBeRunning Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToBeSucceeded Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToBeWaitingOnAMutex Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ var ToStart Condition = func(wf *wfv1.Workflow) (bool, string) { ... }

+ type E2ESuite struct

+ Config *config.Config

+ KubeClient kubernetes.Interface

+ Persistence *Persistence

+ RestConfig *rest.Config

+ func (s *E2ESuite) BeforeTest(string, string)

+ func (s *E2ESuite) CheckError(err error)

+ func (s *E2ESuite) DeleteResources()

+ func (s *E2ESuite) GetBasicAuthToken() string

+ func (s *E2ESuite) GetServiceAccountToken() (string, error)

+ func (s *E2ESuite) Given() *Given

+ func (s *E2ESuite) Need(needs ...Need)

+ func (s *E2ESuite) SetupSuite()

+ func (s *E2ESuite) TearDownSuite()

+ type Given struct

+ func (g *Given) ClusterWorkflowTemplate(text string) *Given

+ func (g *Given) CronWorkflow(text string) *Given

+ func (g *Given) Exec(name string, args []string, block func(t *testing.T, output string, err error)) *Given

+ func (g *Given) RunCli(args []string, block func(t *testing.T, output string, err error)) *Given

+ func (g *Given) When() *When

+ func (g *Given) Workflow(text string) *Given

+ func (g *Given) WorkflowEventBinding(text string) *Given

+ func (g *Given) WorkflowName(name string) *Given

+ func (g *Given) WorkflowTemplate(text string) *Given

+ type Need func(s *E2ESuite) (met bool, message string)

+ func All(needs ...Need) Need

+ func Any(needs ...Need) Need

+ func Executor(e string) Need

+ func None(needs ...Need) Need

+ type Persistence struct

+ func (s *Persistence) Close()

+ func (s *Persistence) IsEnabled() bool

+ type Then struct

+ func (t *Then) ExpectAuditEvents(filter func(event apiv1.Event) bool, num int, ...) *Then

+ func (t *Then) ExpectCron(block func(t *testing.T, cronWf *wfv1.CronWorkflow)) *Then

+ func (t *Then) ExpectWorkflow(...) *Then

+ func (t *Then) ExpectWorkflowDeleted() *Then

+ func (t *Then) ExpectWorkflowList(listOptions metav1.ListOptions, ...) *Then

+ func (t *Then) ExpectWorkflowName(workflowName string, ...) *Then

+ func (t *Then) ExpectWorkflowNode(selector func(status wfv1.NodeStatus) bool, ...) *Then

+ func (t *Then) RunCli(args []string, block func(t *testing.T, output string, err error)) *Then

+ func (t *Then) When() *When

+ type When struct

+ func (w *When) And(block func()) *When

+ func (w *When) CreateClusterWorkflowTemplates() *When

+ func (w *When) CreateConfigMap(name string, data map[string]string) *When

+ func (w *When) CreateCronWorkflow() *When

+ func (w *When) CreateWorkflowEventBinding() *When

+ func (w *When) CreateWorkflowTemplates() *When

+ func (w *When) DeleteConfigMap(name string) *When

+ func (w *When) DeleteMemoryQuota() *When

+ func (w *When) DeletePodsQuota() *When

+ func (w *When) DeleteStorageQuota() *When

+ func (w *When) DeleteWorkflow() *When

+ func (w *When) Exec(name string, args []string, block func(t *testing.T, output string, err error)) *When

+ func (w *When) Given() *Given

+ func (w *When) MemoryQuota(memoryLimit string) *When

+ func (w *When) PodsQuota(podLimit int) *When

+ func (w *When) RunCli(args []string, block func(t *testing.T, output string, err error)) *When

+ func (w *When) StorageQuota(storageLimit string) *When

+ func (w *When) SubmitWorkflow() *When

+ func (w *When) SubmitWorkflowsFromClusterWorkflowTemplates() *When

+ func (w *When) SubmitWorkflowsFromCronWorkflows() *When

+ func (w *When) SubmitWorkflowsFromWorkflowTemplates() *When

+ func (w *When) Then() *Then

+ func (w *When) Wait(timeout time.Duration) *When

+ func (w *When) WaitForWorkflow(options ...interface{}) *When