strategies

type Action struct {
	// Unique name for the action
	Name string
	// Function that performs the action
	Do func(*Context, *apiserver.APIServer) error
}

type Context struct {
	*sm.Context
	// ActionSequence stores the sequence of actions performed in the current iteration
	ActionSequence *types.List[*Action]
	// contains filtered or unexported fields
}

type Driver struct {
	*types.BaseService
	// contains filtered or unexported fields
}

type Strategy interface {
	types.Service
	// ActionsCh should return a channel that is used to
	// communicate the actions that needs to be performed
	ActionsCh() *types.Channel[*Action]
	// Step is called for each event, actions to be performed can be decided within the step call
	Step(*types.Event, *Context)
	// EndCurIteration is called at the end of every iteration
	EndCurIteration(*Context)
	// NextIteration is called at the beginning of every iteration
	NextIteration(*Context)
	// Finalize is called after executing all the iteration.
	// This function can be used to record/log telemetry or other stats
	Finalize(*Context)
}

type StrategyConfig struct {
	// Iterations the number of iterations to be run
	Iterations int `json:"iterations"`
	// IterationTimeout timeout for each iteration
	IterationTimeout time.Duration `json:"iteration_timeout"`
	// SetupFunc invoked at the start of every iteration
	SetupFunc func(*Context)
	// StepFunc invoked for every event in all iterations
	StepFunc func(*types.Event, *Context)
	// FinalizeFunc is invoked after all the iterations are completed
	FinalizeFunc func(*Context)
}

type StrategyWithProperty struct {
	Strategy
	Property *sm.StateMachine
	// contains filtered or unexported fields
}