Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChainedPlanner ¶
type ChainedPlanner struct {
Planners []orchestrator.Planner
}
ChainedPlanner implements the orchestrator.Planner interface by chaining multiple planners together.
func NewChain ¶
func NewChain(planners ...orchestrator.Planner) *ChainedPlanner
NewChain creates a new ChainedPlanner with the provided planners.
func (*ChainedPlanner) Add ¶
func (c *ChainedPlanner) Add(planners ...orchestrator.Planner)
Add adds the specified planners to the ChainedPlanner.
type ComputeForwarder ¶
type ComputeForwarder struct {
// contains filtered or unexported fields
}
func NewComputeForwarder ¶
func NewComputeForwarder(params ComputeForwarderParams) *ComputeForwarder
type ComputeForwarderParams ¶
type EventEmitter ¶
type EventEmitter struct {
// contains filtered or unexported fields
}
EventEmitter is a planner implementation that emits events based on the job state.
func NewEventEmitter ¶
func NewEventEmitter(params EventEmitterParams) *EventEmitter
NewEventEmitter creates a new instance of EventEmitter.
type EventEmitterParams ¶
type EventEmitterParams struct {
ID string
EventEmitter orchestrator.EventEmitter
}
EventEmitterParams holds the parameters for creating a new EventEmitter.
type LoggingPlanner ¶
type LoggingPlanner struct {
}
func NewLoggingPlanner ¶
func NewLoggingPlanner() *LoggingPlanner
type StateUpdater ¶
type StateUpdater struct {
// contains filtered or unexported fields
}
StateUpdater is responsible for updating the state of executions and jobs in the plan. It makes sense to have this as the first planner in the chain, so that the desired state is updated before any other planner try to execute the plan, such as forwarding an execution to a compute node.
func NewStateUpdater ¶
func NewStateUpdater(store jobstore.Store) *StateUpdater
NewStateUpdater creates a new instance of StateUpdater with the specified jobstore.Store.
Source Files