manager

Documentation

Index

• type JobFunnel
  • func NewJobFunnel(scheduler *s.Scheduler, cm *cm.ChaosManager) JobFunnel
• type JobFunnelImpl
  • func (jf *JobFunnelImpl) BeginTest(testID m.TestID, testType string) error
  • func (jf *JobFunnelImpl) RunChaosSimulation(testID m.TestID, chaosInstances []m.ChaosInstance, testDuration uint64) map[m.ChaosID]m.ChaosResult
  • func (jf *JobFunnelImpl) StopTest(testID m.TestID) error
• type ScheduleManager
  • func NewScheduleManager(jf JobFunnel) ScheduleManager
• type ScheduleManagerImpl
  • func (sm *ScheduleManagerImpl) Add(schedule *m.TestSchedule, store bool) error
  • func (sm *ScheduleManagerImpl) Remove(id m.TestScheduleID) error
  • func (sm *ScheduleManagerImpl) ValidateSpec(spec string) error
• type TestingJobFunnel
  • func (jf *TestingJobFunnel) BeginTest(testID m.TestID, testType string) error
  • func (jf *TestingJobFunnel) StopTest(testID m.TestID) error
• type TestingScheduleManager
  • func (sm *TestingScheduleManager) Add(schedule *m.TestSchedule, store bool) error
  • func (sm *TestingScheduleManager) Remove(id m.TestScheduleID) error
  • func (sm *TestingScheduleManager) ValidateSpec(spec string) error

Types

type JobFunnel

type JobFunnel interface {
	BeginTest(testID m.TestID, testType string) error
	StopTest(testID m.TestID) error
	// contains filtered or unexported methods
}

JobFunnel is used to interface with the Scheduler while keeping track of ongoing Tests

func NewJobFunnel

func NewJobFunnel(scheduler *s.Scheduler, cm *cm.ChaosManager) JobFunnel

NewJobFunnel creates a new JobFunnel

type JobFunnelImpl

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

func (*JobFunnelImpl) BeginTest

func (jf *JobFunnelImpl) BeginTest(testID m.TestID, testType string) error

BeginTest creates a TestInstance for the Test with the specified TestID if another instance of the same Test is not already ongoing

func (*JobFunnelImpl) RunChaosSimulation

func (jf *JobFunnelImpl) RunChaosSimulation(testID m.TestID, chaosInstances []m.ChaosInstance, testDuration uint64) map[m.ChaosID]m.ChaosResult

func (*JobFunnelImpl) StopTest

func (jf *JobFunnelImpl) StopTest(testID m.TestID) error

StopTest stops the running TestInstance for the Test corresponding to the given TestID, if it exists

type ScheduleManager

type ScheduleManager interface {
	Add(schedule *m.TestSchedule, store bool) error
	Remove(id m.TestScheduleID) error
	ValidateSpec(spec string) error
}

func NewScheduleManager

func NewScheduleManager(jf JobFunnel) ScheduleManager

type ScheduleManagerImpl

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

func (*ScheduleManagerImpl) Add

func (sm *ScheduleManagerImpl) Add(schedule *m.TestSchedule, store bool) error

func (*ScheduleManagerImpl) Remove

func (sm *ScheduleManagerImpl) Remove(id m.TestScheduleID) error

func (*ScheduleManagerImpl) ValidateSpec

func (sm *ScheduleManagerImpl) ValidateSpec(spec string) error

type TestingJobFunnel

type TestingJobFunnel struct {
	Starts []m.TestID
	Stops  []m.TestID
}

func (*TestingJobFunnel) BeginTest

func (jf *TestingJobFunnel) BeginTest(
	testID m.TestID,
	testType string,
) error

func (*TestingJobFunnel) StopTest

func (jf *TestingJobFunnel) StopTest(
	testID m.TestID,
) error

type TestingScheduleManager

type TestingScheduleManager struct {
	Added   []m.TestScheduleID
	Removed []m.TestScheduleID
}

func (*TestingScheduleManager) Add

func (sm *TestingScheduleManager) Add(
	schedule *m.TestSchedule,
	store bool,
) error

func (*TestingScheduleManager) Remove

func (sm *TestingScheduleManager) Remove(
	id m.TestScheduleID,
) error

func (*TestingScheduleManager) ValidateSpec

func (sm *TestingScheduleManager) ValidateSpec(
	spec string,
) error