fixtures

Documentation

Index

• Constants
• func LoadObject(text string) (runtime.Object, error)
• type Diagnostics
  • func (d *Diagnostics) Log(context log.Fields, message string)
  • func (d *Diagnostics) Logf(format string, args ...interface{})
  • func (d *Diagnostics) Print()
• type E2ESuite
  • func (s *E2ESuite) AfterTest(_, _ string)
  • func (s *E2ESuite) BeforeTest(_, _ string)
  • func (s *E2ESuite) DeleteResources(label string)
  • func (s *E2ESuite) GetBasicAuthToken() string
  • func (s *E2ESuite) GetServiceAccountToken() (string, error)
  • func (s *E2ESuite) Given(t *testing.T) *Given
  • func (s *E2ESuite) Run(name string, f func(t *testing.T))
  • func (s *E2ESuite) SetupSuite()
  • func (s *E2ESuite) TearDownSuite()
• type Given
  • func (g *Given) CronWorkflow(text string) *Given
  • func (g *Given) RunCli(args []string, block func(*testing.T, string, error)) *Given
  • func (g *Given) When() *When
  • func (g *Given) Workflow(text string) *Given
  • func (g *Given) WorkflowName(name string) *Given
  • func (g *Given) WorkflowTemplate(text string) *Given
• type Persistence
  • func (s *Persistence) Close()
  • func (s *Persistence) IsEnabled() bool
• type Then
  • func (t *Then) Expect(...) *Then
  • func (t *Then) ExpectAuditEvents(block func(*testing.T, *apiv1.EventList)) *Then
  • func (t *Then) ExpectCron(block func(t *testing.T, cronWf *wfv1.CronWorkflow)) *Then
  • func (t *Then) ExpectWorkflowList(listOptions metav1.ListOptions, ...) *Then
  • func (t *Then) RunCli(args []string, block func(t *testing.T, output string, err error)) *Then
• type When
  • func (w *When) CreateCronWorkflow() *When
  • func (w *When) CreateWorkflowTemplates() *When
  • func (w *When) DeleteWorkflow() *When
  • func (w *When) Given() *Given
  • func (w *When) SubmitWorkflow() *When
  • func (w *When) Then() *Then
  • func (w *When) Wait(timeout time.Duration) *When
  • func (w *When) WaitForWorkflow(timeout time.Duration) *When
  • func (w *When) WaitForWorkflowCondition(test func(wf *wfv1.Workflow) bool, condition string, timeout time.Duration) *When
  • func (w *When) WaitForWorkflowToStart(timeout time.Duration) *When

Constants

const Label = "argo-e2e"

const LabelCron = Label + "-cron"

Cron tests run in parallel, so use a different label so they are not deleted when a new test runs

const Namespace = "argo"

Functions

func LoadObject

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

LoadObject is used to load yaml to runtime.Object

Types

type Diagnostics

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

func (*Diagnostics) Log

func (d *Diagnostics) Log(context log.Fields, message string)

func (*Diagnostics) Logf

func (d *Diagnostics) Logf(format string, args ...interface{})

func (*Diagnostics) Print

func (d *Diagnostics) Print()

type E2ESuite

type E2ESuite struct {
	suite.Suite
	Diagnostics *Diagnostics
	Persistence *Persistence
	RestConfig  *rest.Config

	KubeClient kubernetes.Interface
	// contains filtered or unexported fields
}

func (*E2ESuite) AfterTest

func (s *E2ESuite) AfterTest(_, _ string)

func (*E2ESuite) BeforeTest

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

func (*E2ESuite) DeleteResources

func (s *E2ESuite) DeleteResources(label string)

func (*E2ESuite) GetBasicAuthToken

func (s *E2ESuite) GetBasicAuthToken() string

func (*E2ESuite) GetServiceAccountToken

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

func (*E2ESuite) Given

func (s *E2ESuite) Given(t *testing.T) *Given

func (*E2ESuite) Run

func (s *E2ESuite) Run(name string, f func(t *testing.T))

func (*E2ESuite) SetupSuite

func (s *E2ESuite) SetupSuite()

func (*E2ESuite) TearDownSuite

func (s *E2ESuite) TearDownSuite()

type Given

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

func (*Given) CronWorkflow

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

func (*Given) RunCli

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

func (*Given) When

func (g *Given) When() *When

func (*Given) Workflow

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

creates a workflow based on the parameter, this may be:

1. A file name if it starts with "@" 2. Raw YAML.

func (*Given) WorkflowName

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

func (*Given) WorkflowTemplate

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

type Persistence

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

func (*Persistence) Close

func (s *Persistence) Close()

func (*Persistence) IsEnabled

func (s *Persistence) IsEnabled() bool

type Then

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

func (*Then) Expect

func (t *Then) Expect(block func(t *testing.T, metadata *metav1.ObjectMeta, status *wfv1.WorkflowStatus)) *Then

func (*Then) ExpectAuditEvents

func (t *Then) ExpectAuditEvents(block func(*testing.T, *apiv1.EventList)) *Then

func (*Then) ExpectCron

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

func (*Then) ExpectWorkflowList

func (t *Then) ExpectWorkflowList(listOptions metav1.ListOptions, block func(t *testing.T, wfList *wfv1.WorkflowList)) *Then

func (*Then) RunCli

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

type When

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

func (*When) CreateCronWorkflow

func (w *When) CreateCronWorkflow() *When

func (*When) CreateWorkflowTemplates

func (w *When) CreateWorkflowTemplates() *When

func (*When) DeleteWorkflow

func (w *When) DeleteWorkflow() *When

func (*When) Given

func (w *When) Given() *Given

func (*When) SubmitWorkflow

func (w *When) SubmitWorkflow() *When

func (*When) Then

func (w *When) Then() *Then

func (*When) Wait

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

func (*When) WaitForWorkflow

func (w *When) WaitForWorkflow(timeout time.Duration) *When

func (*When) WaitForWorkflowCondition

func (w *When) WaitForWorkflowCondition(test func(wf *wfv1.Workflow) bool, condition string, timeout time.Duration) *When

func (*When) WaitForWorkflowToStart

func (w *When) WaitForWorkflowToStart(timeout time.Duration) *When