Documentation
¶
Index ¶
- type Task
- type TaskManager
- func (t *TaskManager) NewHorizontalScalingTask(modelTask *model.Task, oldReplicas int32, logger event.Logger) Task
- func (t *TaskManager) NewRestartTask(modelTask *model.Task, logger event.Logger) Task
- func (t *TaskManager) NewRollingUpgradeTask(modelTask *model.Task, logger event.Logger) Task
- func (t *TaskManager) NewStartTask(modelTask *model.Task, logger event.Logger) Task
- func (t *TaskManager) NewStopTask(modelTask *model.Task, logger event.Logger) Task
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Task ¶
type Task interface {
RunSuccess()
RunError(err error)
BeforeRun()
AfterRun()
Stop()
RollBack()
Run() error
TaskID() string
Logger() event.Logger
}
Task 任务接口
type TaskManager ¶
type TaskManager struct {
// contains filtered or unexported fields
}
func NewTaskManager ¶
func NewTaskManager(appm appm.Manager, statusManager *status.AppRuntimeSyncClient) *TaskManager
func (*TaskManager) NewHorizontalScalingTask ¶
func (t *TaskManager) NewHorizontalScalingTask(modelTask *model.Task, oldReplicas int32, logger event.Logger) Task
NewHorizontalScalingTask 应用水平伸缩
func (*TaskManager) NewRestartTask ¶
NewRestartTask 重启应用任务
func (*TaskManager) NewRollingUpgradeTask ¶
TODO: NewRollingUpgradeTask 滚动升级
func (*TaskManager) NewStartTask ¶
NewStartTask 启动应用任务
func (*TaskManager) NewStopTask ¶
NewStopTask 停止应用任务
Source Files
Click to show internal directories.
Click to hide internal directories.