fixtures

Documentation

Index

• Constants
• func CopyFile(src, dst string) error
• func PodPortForward(config *rest.Config, namespace, podName string, localPort, remotePort int, ...) error
• type E2ESuite
  • func (s *E2ESuite) AfterTest(suiteName, testName string)
  • func (s *E2ESuite) BeforeTest(suiteName, testName string)
  • func (s *E2ESuite) CheckError(err error)
  • func (s *E2ESuite) Given() *Given
  • func (s *E2ESuite) SetupSuite()
  • func (s *E2ESuite) TearDownSuite()
• type Expect
  • func (e *Expect) ResourcesDontExist(resourceType string, resources []string) *Expect
  • func (e *Expect) ResourcesExist(resourceType string, resources []string) *Expect
  • func (e *Expect) When() *When
• type Given
  • func (g *Given) GitSync(text string) *Given
  • func (g *Given) InitializeGitRepo() *Given
  • func (g *Given) When() *When
  • func (g *Given) WithGitSync(gs *v1alpha1.GitSync) *Given
• type When
  • func (w *When) CreateGitSyncAndWait() *When
  • func (w *When) DeleteGitSyncAndWait() *When
  • func (w *When) Expect() *Expect
  • func (w *When) Given() *Given
  • func (w *When) PushToGitRepo(directory string, fileNames []string) *When

Constants

const (
	/* resource names */
	Namespace       = "numaplane-system"
	TargetNamespace = "numaflow-pipeline"
	E2ELabel        = "numaplane-e2e"
	E2ELabelValue   = "true"
)

Functions

func CopyFile

func CopyFile(src, dst string) error

func PodPortForward

func PodPortForward(config *rest.Config, namespace, podName string,
	localPort, remotePort int, stopCh <-chan struct{}) error

Types

type E2ESuite

type E2ESuite struct {
	suite.Suite
	// contains filtered or unexported fields
}

func (*E2ESuite) AfterTest

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

func (*E2ESuite) BeforeTest

func (s *E2ESuite) BeforeTest(suiteName, testName string)

func (*E2ESuite) CheckError

func (s *E2ESuite) CheckError(err error)

func (*E2ESuite) Given

func (s *E2ESuite) Given() *Given

func (*E2ESuite) SetupSuite

func (s *E2ESuite) SetupSuite()

func (*E2ESuite) TearDownSuite

func (s *E2ESuite) TearDownSuite()

type Expect

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

func (*Expect) ResourcesDontExist

func (e *Expect) ResourcesDontExist(resourceType string, resources []string) *Expect

check that resources are deleted

func (*Expect) ResourcesExist

func (e *Expect) ResourcesExist(resourceType string, resources []string) *Expect

check that resources are created

func (*Expect) When

func (e *Expect) When() *When

type Given

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

func (*Given) GitSync

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

create GitSync using raw YAML or @filename

func (*Given) InitializeGitRepo

func (g *Given) InitializeGitRepo() *Given

initializes Git repo specified by GitSync's RepoURL by pushing initial commit files these files should be located at testdata/<gitSync.Spec.Path>

func (*Given) When

func (g *Given) When() *When

func (*Given) WithGitSync

func (g *Given) WithGitSync(gs *v1alpha1.GitSync) *Given

type When

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

func (*When) CreateGitSyncAndWait

func (w *When) CreateGitSyncAndWait() *When

func (*When) DeleteGitSyncAndWait

func (w *When) DeleteGitSyncAndWait() *When

func (*When) Expect

func (w *When) Expect() *Expect

func (*When) Given

func (w *When) Given() *Given

func (*When) PushToGitRepo

func (w *When) PushToGitRepo(directory string, fileNames []string) *When

make git push to Git server pod