tasks

package
v0.0.0-...-94e4715 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 20, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyAddons 

func ApplyAddons(cluster *models.SCluster, conf *api.ClusterAddonsManifestConfig) error

func SetObjectTaskFailed 

func SetObjectTaskFailed(ctx context.Context, task taskman.ITask, obj IStatusStandaloneModel, status, reason string)

Types

type ClusterApplyAddonsTask 

type ClusterApplyAddonsTask struct {
	taskman.STask
}

func (*ClusterApplyAddonsTask) OnApplyAddons 

func (t *ClusterApplyAddonsTask) OnApplyAddons(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterApplyAddonsTask) OnApplyAddonsFailed 

func (t *ClusterApplyAddonsTask) OnApplyAddonsFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterApplyAddonsTask) OnError 

func (t *ClusterApplyAddonsTask) OnError(ctx context.Context, obj *models.SCluster, err jsonutils.JSONObject)

func (*ClusterApplyAddonsTask) OnInit 

func (t *ClusterApplyAddonsTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type ClusterCreateMachinesTask 

type ClusterCreateMachinesTask struct {
	taskman.STask
}

func (*ClusterCreateMachinesTask) OnInit 

func (t *ClusterCreateMachinesTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateMachinesTask) OnMachinesCreated 

func (t *ClusterCreateMachinesTask) OnMachinesCreated(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterCreateMachinesTask) OnMachinesCreatedFailed 

func (t *ClusterCreateMachinesTask) OnMachinesCreatedFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateMachinesTask) OnMachinesDeployed 

func (t *ClusterCreateMachinesTask) OnMachinesDeployed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterCreateMachinesTask) OnMachinesDeployedFailed 

func (t *ClusterCreateMachinesTask) OnMachinesDeployedFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type ClusterCreateTask 

type ClusterCreateTask struct {
	taskman.STask
}

func (*ClusterCreateTask) CreateMachines 

func (t *ClusterCreateTask) CreateMachines(ctx context.Context, cluster *models.SCluster)

func (*ClusterCreateTask) OnApplyAddonsComplete 

func (t *ClusterCreateTask) OnApplyAddonsComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnApplyAddonsCompleteFailed 

func (t *ClusterCreateTask) OnApplyAddonsCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnInit 

func (t *ClusterCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnMachinesCreated 

func (t *ClusterCreateTask) OnMachinesCreated(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnMachinesCreatedFailed 

func (t *ClusterCreateTask) OnMachinesCreatedFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnSyncComplete 

func (t *ClusterCreateTask) OnSyncComplete(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnSyncCompleteFailed 

func (t *ClusterCreateTask) OnSyncCompleteFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnSyncStatusComplete 

func (t *ClusterCreateTask) OnSyncStatusComplete(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterCreateTask) OnSyncStatusCompleteFailed 

func (t *ClusterCreateTask) OnSyncStatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterCreateTask) SetFailed 

func (t *ClusterCreateTask) SetFailed(ctx context.Context, obj db.IStandaloneModel, reason jsonutils.JSONObject)

type ClusterDeleteMachinesTask 

type ClusterDeleteMachinesTask struct {
	taskman.STask
}

func (*ClusterDeleteMachinesTask) IsFromClusterDeleteTask 

func (t *ClusterDeleteMachinesTask) IsFromClusterDeleteTask(cluster *models.SCluster) bool

func (*ClusterDeleteMachinesTask) OnClusterNodeRemoved 

func (t *ClusterDeleteMachinesTask) OnClusterNodeRemoved(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteMachinesTask) OnClusterNodeRemovedFailed 

func (t *ClusterDeleteMachinesTask) OnClusterNodeRemovedFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteMachinesTask) OnDeleteMachines 

func (t *ClusterDeleteMachinesTask) OnDeleteMachines(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteMachinesTask) OnDeleteMachinesFailed 

func (t *ClusterDeleteMachinesTask) OnDeleteMachinesFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteMachinesTask) OnError 

func (t *ClusterDeleteMachinesTask) OnError(ctx context.Context, cluster *models.SCluster, err string)

func (*ClusterDeleteMachinesTask) OnInit 

func (t *ClusterDeleteMachinesTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterDeleteMachinesTask) OnSyncStatus 

func (t *ClusterDeleteMachinesTask) OnSyncStatus(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteMachinesTask) OnSyncStatusFailed 

func (t *ClusterDeleteMachinesTask) OnSyncStatusFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

type ClusterDeleteTask 

type ClusterDeleteTask struct {
	taskman.STask
}

func (*ClusterDeleteTask) OnInit 

func (t *ClusterDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterDeleteTask) OnMachinesDeleted 

func (t *ClusterDeleteTask) OnMachinesDeleted(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteTask) OnMachinesDeletedFailed 

func (t *ClusterDeleteTask) OnMachinesDeletedFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeleteTask) SetFailed 

func (t *ClusterDeleteTask) SetFailed(ctx context.Context, obj db.IStandaloneModel, reason jsonutils.JSONObject)

type ClusterDeployMachinesTask 

type ClusterDeployMachinesTask struct {
	taskman.STask
}

ClusterDeployMachinesTask run ansible deploy machines as kubernetes nodes

func (*ClusterDeployMachinesTask) OnDeployMachines 

func (t *ClusterDeployMachinesTask) OnDeployMachines(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) OnDeployMachinesFailed 

func (t *ClusterDeployMachinesTask) OnDeployMachinesFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) OnInit 

func (t *ClusterDeployMachinesTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) OnSyncComplete 

func (t *ClusterDeployMachinesTask) OnSyncComplete(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) OnSyncCompleteFailed 

func (t *ClusterDeployMachinesTask) OnSyncCompleteFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) OnSyncStatusComplete 

func (t *ClusterDeployMachinesTask) OnSyncStatusComplete(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) OnSyncStatusCompleteFailed 

func (t *ClusterDeployMachinesTask) OnSyncStatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterDeployMachinesTask) SetFailed 

func (t *ClusterDeployMachinesTask) SetFailed(ctx context.Context, obj db.IStandaloneModel, reason jsonutils.JSONObject)

type ClusterResourceBaseTask 

type ClusterResourceBaseTask struct {
	taskman.STask
}

type ClusterResourceCreateTask 

type ClusterResourceCreateTask struct {
	ClusterResourceBaseTask
}

func (*ClusterResourceCreateTask) OnCreateComplete 

func (t *ClusterResourceCreateTask) OnCreateComplete(ctx context.Context, obj models.IClusterModel, data jsonutils.JSONObject)

func (*ClusterResourceCreateTask) OnCreateCompleteFailed 

func (t *ClusterResourceCreateTask) OnCreateCompleteFailed(ctx context.Context, obj models.IClusterModel, reason jsonutils.JSONObject)

func (*ClusterResourceCreateTask) OnInit 

func (t *ClusterResourceCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterResourceCreateTask) OnResourceSyncComplete 

func (t *ClusterResourceCreateTask) OnResourceSyncComplete(ctx context.Context, obj models.IClusterModel, data jsonutils.JSONObject)

func (*ClusterResourceCreateTask) OnResourceSyncCompleteFailed 

func (t *ClusterResourceCreateTask) OnResourceSyncCompleteFailed(ctx context.Context, obj models.IClusterModel, err jsonutils.JSONObject)

type ClusterResourceDeleteTask 

type ClusterResourceDeleteTask struct {
	ClusterResourceBaseTask
}

func (*ClusterResourceDeleteTask) OnDeleteComplete 

func (t *ClusterResourceDeleteTask) OnDeleteComplete(ctx context.Context, obj models.IClusterModel, data jsonutils.JSONObject)

func (*ClusterResourceDeleteTask) OnDeleteCompleteFailed 

func (t *ClusterResourceDeleteTask) OnDeleteCompleteFailed(ctx context.Context, obj models.IClusterModel, reason jsonutils.JSONObject)

func (*ClusterResourceDeleteTask) OnInit 

func (t *ClusterResourceDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type ClusterResourceSyncTask 

type ClusterResourceSyncTask struct {
	ClusterResourceBaseTask
}

func (*ClusterResourceSyncTask) OnInit 

func (t *ClusterResourceSyncTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterResourceSyncTask) OnSyncComplete 

func (t *ClusterResourceSyncTask) OnSyncComplete(ctx context.Context, obj models.IClusterModel, data jsonutils.JSONObject)

func (*ClusterResourceSyncTask) OnSyncCompleteFailed 

func (t *ClusterResourceSyncTask) OnSyncCompleteFailed(ctx context.Context, obj models.IClusterModel, reason jsonutils.JSONObject)

type ClusterResourceUpdateTask 

type ClusterResourceUpdateTask struct {
	ClusterResourceBaseTask
}

func (*ClusterResourceUpdateTask) OnInit 

func (t *ClusterResourceUpdateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterResourceUpdateTask) OnUpdateComplete 

func (t *ClusterResourceUpdateTask) OnUpdateComplete(ctx context.Context, obj models.IClusterModel, data jsonutils.JSONObject)

func (*ClusterResourceUpdateTask) OnUpdateCompleteFailed 

func (t *ClusterResourceUpdateTask) OnUpdateCompleteFailed(ctx context.Context, obj models.IClusterModel, reason jsonutils.JSONObject)

type ClusterSyncTask 

type ClusterSyncTask struct {
	taskman.STask
}

func (*ClusterSyncTask) OnInit 

func (t *ClusterSyncTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterSyncTask) OnSyncComplete 

func (t *ClusterSyncTask) OnSyncComplete(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterSyncTask) OnSyncCompleteFailed 

func (t *ClusterSyncTask) OnSyncCompleteFailed(ctx context.Context, cluster *models.SCluster, reason jsonutils.JSONObject)

type ClusterSyncstatusTask 

type ClusterSyncstatusTask struct {
	taskman.STask
}

func (*ClusterSyncstatusTask) OnInit 

func (t *ClusterSyncstatusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ClusterSyncstatusTask) OnSyncStatus 

func (t *ClusterSyncstatusTask) OnSyncStatus(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterSyncstatusTask) OnSyncStatusFailed 

func (t *ClusterSyncstatusTask) OnSyncStatusFailed(ctx context.Context, cluster *models.SCluster, data jsonutils.JSONObject)

func (*ClusterSyncstatusTask) SetFailed 

func (t *ClusterSyncstatusTask) SetFailed(ctx context.Context, obj db.IStandaloneModel, reason jsonutils.JSONObject)

type ComponentDeleteTask 

type ComponentDeleteTask struct {
	taskman.STask
}

func (*ComponentDeleteTask) OnInit 

func (t *ComponentDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ComponentDeleteTask) OnUndeployComplete 

func (t *ComponentDeleteTask) OnUndeployComplete(ctx context.Context, obj *models.SComponent, data jsonutils.JSONObject)

func (*ComponentDeleteTask) OnUndeployCompleteFailed 

func (t *ComponentDeleteTask) OnUndeployCompleteFailed(ctx context.Context, obj *models.SComponent, reason jsonutils.JSONObject)

type ComponentDeployTask 

type ComponentDeployTask struct {
	taskman.STask
}

func (*ComponentDeployTask) OnDeployComplete 

func (t *ComponentDeployTask) OnDeployComplete(ctx context.Context, obj *models.SComponent, data jsonutils.JSONObject)

func (*ComponentDeployTask) OnDeployCompleteFailed 

func (t *ComponentDeployTask) OnDeployCompleteFailed(ctx context.Context, obj *models.SComponent, reason jsonutils.JSONObject)

func (*ComponentDeployTask) OnInit 

func (t *ComponentDeployTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type ComponentUndeployTask 

type ComponentUndeployTask struct {
	taskman.STask
}

func (*ComponentUndeployTask) OnInit 

func (t *ComponentUndeployTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type ComponentUpdateTask 

type ComponentUpdateTask struct {
	taskman.STask
}

func (*ComponentUpdateTask) OnInit 

func (t *ComponentUpdateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ComponentUpdateTask) OnUpdateComplete 

func (t *ComponentUpdateTask) OnUpdateComplete(ctx context.Context, obj *models.SComponent, data jsonutils.JSONObject)

func (*ComponentUpdateTask) OnUpdateCompleteFailed 

func (t *ComponentUpdateTask) OnUpdateCompleteFailed(ctx context.Context, obj *models.SComponent, reason jsonutils.JSONObject)

type FedResourceAttachClusterTask 

type FedResourceAttachClusterTask struct {
	FedResourceBaseTask
}

func (*FedResourceAttachClusterTask) OnAttachComplete 

func (t *FedResourceAttachClusterTask) OnAttachComplete(ctx context.Context, obj models.IFedModel, data jsonutils.JSONObject)

func (*FedResourceAttachClusterTask) OnAttachCompleteFailed 

func (t *FedResourceAttachClusterTask) OnAttachCompleteFailed(ctx context.Context, obj models.IFedModel, reason jsonutils.JSONObject)

func (*FedResourceAttachClusterTask) OnInit 

func (t *FedResourceAttachClusterTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type FedResourceBaseTask 

type FedResourceBaseTask struct {
	taskman.STask
}

type FedResourceSyncTask 

type FedResourceSyncTask struct {
	FedResourceBaseTask
}

func (*FedResourceSyncTask) OnInit 

func (t *FedResourceSyncTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*FedResourceSyncTask) OnSyncComplete 

func (t *FedResourceSyncTask) OnSyncComplete(ctx context.Context, obj models.IFedModel, data jsonutils.JSONObject)

func (*FedResourceSyncTask) OnSyncCompleteFailed 

func (t *FedResourceSyncTask) OnSyncCompleteFailed(ctx context.Context, obj models.IFedModel, reason jsonutils.JSONObject)

type FedResourceUpdateTask 

type FedResourceUpdateTask struct {
	FedResourceBaseTask
}

func (*FedResourceUpdateTask) OnInit 

func (t *FedResourceUpdateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*FedResourceUpdateTask) OnUpdateComplete 

func (t *FedResourceUpdateTask) OnUpdateComplete(ctx context.Context, obj models.IFedModel, data jsonutils.JSONObject)

func (*FedResourceUpdateTask) OnUpdateCompleteFailed 

func (t *FedResourceUpdateTask) OnUpdateCompleteFailed(ctx context.Context, obj models.IFedModel, reason jsonutils.JSONObject)

type IStatusStandaloneModel 

type IStatusStandaloneModel interface {
	db.IStandaloneModel

	SetStatus(ctx context.Context, userCred mcclient.TokenCredential, status string, reason string) error
}

type MachineBatchCreateTask 

type MachineBatchCreateTask struct {
	taskman.STask
}

func (*MachineBatchCreateTask) OnInit 

func (t *MachineBatchCreateTask) OnInit(ctx context.Context, objs []db.IStandaloneModel, body jsonutils.JSONObject)

func (*MachineBatchCreateTask) OnMachinesCreated 

func (t *MachineBatchCreateTask) OnMachinesCreated(ctx context.Context, objs []db.IStandaloneModel, data *jsonutils.JSONDict)

func (*MachineBatchCreateTask) OnMachinesCreatedFailed 

func (t *MachineBatchCreateTask) OnMachinesCreatedFailed(ctx context.Context, objs []db.IStandaloneModel, data *jsonutils.JSONDict)

type MachineBatchDeleteTask 

type MachineBatchDeleteTask struct {
	taskman.STask
}

func (*MachineBatchDeleteTask) OnDeleteMachines 

func (self *MachineBatchDeleteTask) OnDeleteMachines(ctx context.Context, objs []db.IStandaloneModel, data *jsonutils.JSONDict)

func (*MachineBatchDeleteTask) OnDeleteMachinesFailed 

func (self *MachineBatchDeleteTask) OnDeleteMachinesFailed(ctx context.Context, objs []db.IStandaloneModel, data *jsonutils.JSONDict)

func (*MachineBatchDeleteTask) OnInit 

func (self *MachineBatchDeleteTask) OnInit(ctx context.Context, objs []db.IStandaloneModel, body jsonutils.JSONObject)

type MachineCreateTask 

type MachineCreateTask struct {
	taskman.STask
}

func (*MachineCreateTask) OnError 

func (t *MachineCreateTask) OnError(ctx context.Context, machine *models.SMachine, err error)

func (*MachineCreateTask) OnInit 

func (t *MachineCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*MachineCreateTask) OnMachinePrepared 

func (t *MachineCreateTask) OnMachinePrepared(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*MachineCreateTask) OnMachinePreparedFailed 

func (t *MachineCreateTask) OnMachinePreparedFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type MachinePrepareTask 

type MachinePrepareTask struct {
	taskman.STask
}

func (*MachinePrepareTask) OnError 

func (t *MachinePrepareTask) OnError(ctx context.Context, machine *models.SMachine, err error)

func (*MachinePrepareTask) OnInit 

func (t *MachinePrepareTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*MachinePrepareTask) OnPrepared 

func (t *MachinePrepareTask) OnPrepared(ctx context.Context, machine db.IStandaloneModel, data jsonutils.JSONObject)

func (*MachinePrepareTask) OnPreparedFailed 

func (t *MachinePrepareTask) OnPreparedFailed(ctx context.Context, machine *models.SMachine, data jsonutils.JSONObject)

type MachineTerminateTask 

type MachineTerminateTask struct {
	taskman.STask
}

func (*MachineTerminateTask) OnError 

func (t *MachineTerminateTask) OnError(ctx context.Context, machine *models.SMachine, err error)

func (*MachineTerminateTask) OnInit 

func (t *MachineTerminateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type NamespaceCreateTask 

type NamespaceCreateTask struct {
	ClusterResourceCreateTask
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.