Versions in this module Expand all Collapse all v2 v2.11.4 Oct 1, 2020 Changes in this version + const Label + const Namespace + 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 NoError = func(t *testing.T, output string, err error) + var OutputContains = func(contains string) func(t *testing.T, output string, err error) + func Exec(name string, args ...string) (string, error) + func LoadObject(text string) (runtime.Object, error) + type Condition func(wf *wfv1.Workflow) bool + var ToFinish Condition = func(wf *wfv1.Workflow) bool { ... } + var ToStart Condition = func(wf *wfv1.Workflow) bool { ... } + type E2ESuite struct + KubeClient kubernetes.Interface + Persistence *Persistence + RestConfig *rest.Config + func (s *E2ESuite) AfterTest(_, _ string) + 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) 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 Persistence struct + func (s *Persistence) Close() + func (s *Persistence) IsEnabled() bool + type Then struct + func (t *Then) ExpectAuditEvents(filter func(event apiv1.Event) bool, blocks ...func(*testing.T, apiv1.Event)) *Then + func (t *Then) ExpectCron(block func(t *testing.T, cronWf *wfv1.CronWorkflow)) *Then + func (t *Then) ExpectWorkflow(...) *Then + func (t *Then) ExpectWorkflowList(listOptions metav1.ListOptions, ...) *Then + func (t *Then) ExpectWorkflowName(workflowName string, ...) *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) Then() *Then + func (w *When) Wait(timeout time.Duration) *When + func (w *When) WaitForWorkflow(options ...interface{}) *When Other modules containing this package github.com/alexec/argo