scheduler

Documentation

Index

• Constants
• type Scheduler
  • func NewScheduler(metrics v1.Metrics, executor client.Executor, ...) *Scheduler
  • func (s *Scheduler) PrepareTestRequests(work []testsv3.Test, request testkube.ExecutionRequest) []...
  • func (s *Scheduler) PrepareTestSuiteRequests(work []testsuitesv3.TestSuite, request testkube.TestSuiteExecutionRequest) []...

Constants

const (
	// DefaultConcurrencyLevel is a default concurrency level for worker pool
	DefaultConcurrencyLevel = 10
)

Types

type Scheduler

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

func NewScheduler

func NewScheduler(
	metrics v1.Metrics,
	executor client.Executor,
	containerExecutor client.Executor,
	executionResults result.Repository,
	testExecutionResults testresult.Repository,
	executorsClient executorsv1.Interface,
	testsClient testsv3.Interface,
	testSuitesClient testsuitesv3.Interface,
	testSourcesClient testsourcesv1.Interface,
	secretClient secret.Interface,
	events *event.Emitter,
	logger *zap.SugaredLogger,
	configMap config.Repository,
	configMapClient configmap.Interface,
	testSuiteExecutionsClient testsuiteexecutionsclientv1.Interface,
	eventsBus bus.Bus,
	dashboardURI string,
	featureFlags featureflags.FeatureFlags,
	logsStream logsclient.Stream,
) *Scheduler

func (*Scheduler) PrepareTestRequests

func (s *Scheduler) PrepareTestRequests(work []testsv3.Test, request testkube.ExecutionRequest) []workerpool.Request[
	testkube.Test, testkube.ExecutionRequest, testkube.Execution]

func (*Scheduler) PrepareTestSuiteRequests

func (s *Scheduler) PrepareTestSuiteRequests(work []testsuitesv3.TestSuite, request testkube.TestSuiteExecutionRequest) []workerpool.Request[
	testkube.TestSuite,
	testkube.TestSuiteExecutionRequest,
	testkube.TestSuiteExecution,
]