processors

Documentation

Index

• type OperationInfo
• type StepInfo
• type StepProcessor
  • func NewStepProcessor(step v1alpha1.TestStep, basePath string, report *report.StepReport, ...) StepProcessor
• type TestInfo
• type TestProcessor
  • func NewTestProcessor(test discovery.Test, size int, clock clock.PassiveClock, ...) TestProcessor
• type TestsProcessor
  • func NewTestsProcessor(config model.Configuration, clock clock.PassiveClock, report *report.Report) TestsProcessor

Types

type OperationInfo

type OperationInfo struct {
	Id         int
	ResourceId int
}

type StepInfo

type StepInfo struct {
	Id int
}

type StepProcessor

type StepProcessor interface {
	Run(context.Context, namespacer.Namespacer, engine.Context)
}

func NewStepProcessor

func NewStepProcessor(
	step v1alpha1.TestStep,
	basePath string,
	report *report.StepReport,
	delayBeforeCleanup *time.Duration,
	terminationGracePeriod *metav1.Duration,
	timeouts v1alpha1.DefaultTimeouts,
	deletionPropagationPolicy metav1.DeletionPropagation,
	templating bool,
	skipDelete bool,
	catch ...v1alpha1.CatchFinally,
) StepProcessor

type TestInfo

type TestInfo struct {
	Id         int
	ScenarioId int
	Metadata   metav1.ObjectMeta
}

type TestProcessor

type TestProcessor interface {
	Run(context.Context, namespacer.Namespacer, engine.Context)
}

func NewTestProcessor

func NewTestProcessor(
	test discovery.Test,
	size int,
	clock clock.PassiveClock,
	report *report.TestReport,
	nsTemplate *v1alpha1.Any,
	delayBeforeCleanup *time.Duration,
	terminationGracePeriod *metav1.Duration,
	timeouts v1alpha1.DefaultTimeouts,
	deletionPropagationPolicy metav1.DeletionPropagation,
	templating bool,
	skipDelete bool,
	catch ...v1alpha1.CatchFinally,
) TestProcessor

type TestsProcessor

type TestsProcessor interface {
	Run(context.Context, engine.Context, ...discovery.Test)
}

func NewTestsProcessor

func NewTestsProcessor(config model.Configuration, clock clock.PassiveClock, report *report.Report) TestsProcessor