processors

Documentation

Index

• Constants
• func NewClusters() clusters
• type StepProcessor
  • func NewStepProcessor(config v1alpha1.ConfigurationSpec, clusters clusters, ...) StepProcessor
• type TestProcessor
  • func NewTestProcessor(config v1alpha1.ConfigurationSpec, clusters clusters, clock clock.PassiveClock, ...) TestProcessor
• type TestsProcessor
  • func NewTestsProcessor(config v1alpha1.ConfigurationSpec, clusters clusters, clock clock.PassiveClock, ...) TestsProcessor

Constants

const DefaultClient = ""

Functions

func NewClusters

func NewClusters() clusters

Types

type StepProcessor

type StepProcessor interface {
	Run(ctx context.Context)
}

func NewStepProcessor

func NewStepProcessor(
	config v1alpha1.ConfigurationSpec,
	clusters clusters,
	namespacer namespacer.Namespacer,
	clock clock.PassiveClock,
	test discovery.Test,
	step v1alpha1.TestSpecStep,
	stepReport *report.TestSpecStepReport,
	cleaner *cleaner,
	bindings binding.Bindings,
) StepProcessor

type TestProcessor

type TestProcessor interface {
	Run(context.Context, namespacer.Namespacer)
	CreateStepProcessor(namespacer.Namespacer, binding.Bindings, *cleaner, v1alpha1.TestSpecStep) StepProcessor
}

func NewTestProcessor

func NewTestProcessor(
	config v1alpha1.ConfigurationSpec,
	clusters clusters,
	clock clock.PassiveClock,
	summary *summary.Summary,
	testReport *report.TestReport,
	test discovery.Test,
	shouldFailFast *atomic.Bool,
	bindings binding.Bindings,
) TestProcessor

type TestsProcessor

type TestsProcessor interface {
	Run(context.Context)
	CreateTestProcessor(discovery.Test, binding.Bindings) TestProcessor
}

func NewTestsProcessor

func NewTestsProcessor(
	config v1alpha1.ConfigurationSpec,
	clusters clusters,
	clock clock.PassiveClock,
	summary *summary.Summary,
	testsReport *report.TestsReport,
	bindings binding.Bindings,
	tests ...discovery.Test,
) TestsProcessor