scheduler

Documentation

Index

• Constants
• type PodNameGenerator
  • func (P *PodNameGenerator) GetName(suite v1alpha1.ClusterTestSuite, def v1alpha1.TestDefinition) (string, error)
• type Service
  • func NewService(statusProvider StatusProvider, reader client.Reader, writer client.Writer, ...) *Service
  • func (s *Service) TrySchedule(suite v1alpha1.ClusterTestSuite) (*v1.Pod, *v1alpha1.TestSuiteStatus, error)
• type StatusProvider

Constants

const (
	TestingPodPrefix = "oct-tp"
)

Types

type PodNameGenerator

type PodNameGenerator struct{}

func (*PodNameGenerator) GetName

func (P *PodNameGenerator) GetName(suite v1alpha1.ClusterTestSuite, def v1alpha1.TestDefinition) (string, error)

type Service

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

func NewService

func NewService(statusProvider StatusProvider, reader client.Reader, writer client.Writer, scheme *runtime.Scheme, logger logr.Logger) *Service

func (*Service) TrySchedule

func (s *Service) TrySchedule(suite v1alpha1.ClusterTestSuite) (*v1.Pod, *v1alpha1.TestSuiteStatus, error)

type StatusProvider

type StatusProvider interface {
	MarkAsScheduled(status v1alpha1.TestSuiteStatus, testName, testNs, podName string) (v1alpha1.TestSuiteStatus, error)
	GetExecutionsInProgress(suite v1alpha1.ClusterTestSuite) []v1alpha1.TestExecution
}