Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type State ¶
type State interface {
Process(processor *TestProcessor) error
}
type StateInitial ¶
type StateInitial struct{}
func (*StateInitial) Process ¶
func (s *StateInitial) Process(processor *TestProcessor) error
type StateInitializingTestCount ¶
type StateInitializingTestCount struct{}
func (*StateInitializingTestCount) CreatePod ¶
func (s *StateInitializingTestCount) CreatePod(processor *TestProcessor) error
func (*StateInitializingTestCount) DeletePod ¶
func (s *StateInitializingTestCount) DeletePod(processor *TestProcessor) error
func (*StateInitializingTestCount) Process ¶
func (s *StateInitializingTestCount) Process(processor *TestProcessor) error
type StateRunning ¶
type StateRunning struct{}
func (*StateRunning) Process ¶
func (s *StateRunning) Process(processor *TestProcessor) error
type TestProcessor ¶
type TestProcessor struct { ApiExtCli *apiextclient.Clientset KubeCli *kubernetes.Clientset TestsCli *versioned.Clientset TestName string TestNamespace string TestSpec *v1alpha1.TestSpec // contains filtered or unexported fields }
TestProcessor : a state machine which takes a test as input, and fully processes it.
func New ¶
func New( apiExtCli *apiextclient.Clientset, kubeCli *kubernetes.Clientset, testsCli *versioned.Clientset, test *v1alpha1.Test, ) *TestProcessor
func (*TestProcessor) AtomicOwn ¶
func (processor *TestProcessor) AtomicOwn() bool
func (*TestProcessor) Cancel ¶
func (processor *TestProcessor) Cancel()
func (*TestProcessor) CheckOwnerAlive ¶
func (processor *TestProcessor) CheckOwnerAlive() (bool, error)
func (*TestProcessor) CheckTestOwnedByUs ¶
func (processor *TestProcessor) CheckTestOwnedByUs() bool
func (*TestProcessor) Process ¶
func (processor *TestProcessor) Process() error
Click to show internal directories.
Click to hide internal directories.