testprocessor

Documentation

Index

• func HashTest(test *v1alpha1.Test) []byte
• type State
• type StateInitial
  • func (s *StateInitial) Process(processor *TestProcessor) error
• type StateInitializingTestCount
  • func (s *StateInitializingTestCount) CreatePod(processor *TestProcessor) error
  • func (s *StateInitializingTestCount) DeletePod(processor *TestProcessor) error
  • func (s *StateInitializingTestCount) Process(processor *TestProcessor) error
• type StateRunning
  • func (s *StateRunning) Process(processor *TestProcessor) error
• type TestProcessor
  • func New(apiExtCli *apiextclient.Clientset, kubeCli *kubernetes.Clientset, ...) *TestProcessor
  • func (processor *TestProcessor) AtomicOwn() bool
  • func (processor *TestProcessor) Cancel()
  • func (processor *TestProcessor) CheckOwnerAlive() (bool, error)
  • func (processor *TestProcessor) CheckTestOwnedByUs() bool
  • func (processor *TestProcessor) Process() error

Functions

func HashTest

func HashTest(test *v1alpha1.Test) []byte

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