tasks

package
v0.0.0-...-6410feb Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2024 License: Apache-2.0 Imports: 53 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	STORAGEIDS = "storage_ids"
)
View Source 
var (
	SkuSyncWorkerManager *appsrv.SWorkerManager
)

Functions ¶

func ClearTaskPendingRegionUsage ¶ 

func ClearTaskPendingRegionUsage(ctx context.Context, task taskman.ITask) error

func ClearTaskPendingUsage ¶ 

func ClearTaskPendingUsage(ctx context.Context, task taskman.ITask) error

func InitCloudproviderSyncWorkers ¶ 

func InitCloudproviderSyncWorkers(count int)

func StartScheduleObjects ¶ 

func StartScheduleObjects(
	ctx context.Context,
	task IScheduleTask,
	objs []db.IStandaloneModel,
)

Types ¶

type AccessGroupCreateTask ¶ 

type AccessGroupCreateTask struct {
	taskman.STask
}

func (*AccessGroupCreateTask) OnInit ¶ 

func (self *AccessGroupCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type AccessGroupDeleteTask ¶ 

type AccessGroupDeleteTask struct {
	taskman.STask
}

func (*AccessGroupDeleteTask) OnInit ¶ 

func (self *AccessGroupDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type AccessGroupRuleCreateTask ¶ 

type AccessGroupRuleCreateTask struct {
	taskman.STask
}

func (*AccessGroupRuleCreateTask) OnInit ¶ 

func (self *AccessGroupRuleCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type AccessGroupRuleDeleteTask ¶ 

type AccessGroupRuleDeleteTask struct {
	taskman.STask
}

func (*AccessGroupRuleDeleteTask) OnInit ¶ 

func (self *AccessGroupRuleDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type AccessGroupSyncstatusTask ¶ 

type AccessGroupSyncstatusTask struct {
	taskman.STask
}

func (*AccessGroupSyncstatusTask) OnInit ¶ 

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

type AppRemoteUpdateTask ¶ 

type AppRemoteUpdateTask struct {
	taskman.STask
}

func (*AppRemoteUpdateTask) OnInit ¶ 

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

func (*AppRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *AppRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, app *models.SApp, data jsonutils.JSONObject)

func (*AppRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *AppRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, app *models.SApp, data jsonutils.JSONObject)

func (*AppRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *AppRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, app *models.SApp, data jsonutils.JSONObject)

type AppSyncstatusTask ¶ 

type AppSyncstatusTask struct {
	taskman.STask
}

func (*AppSyncstatusTask) OnInit ¶ 

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

type BackupStorageSyncstatusTask ¶ 

type BackupStorageSyncstatusTask struct {
	taskman.STask
}

func (*BackupStorageSyncstatusTask) OnBackupStorageSyncStatus ¶ 

func (self *BackupStorageSyncstatusTask) OnBackupStorageSyncStatus(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*BackupStorageSyncstatusTask) OnBackupStorageSyncStatusFailed ¶ 

func (self *BackupStorageSyncstatusTask) OnBackupStorageSyncStatusFailed(ctx context.Context, backup *models.SBackupStorage, data jsonutils.JSONObject)

func (*BackupStorageSyncstatusTask) OnInit ¶ 

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

type BaremetalCdromTask ¶ 

type BaremetalCdromTask struct {
	SBaremetalBaseTask
}

func (*BaremetalCdromTask) OnFailure ¶ 

func (self *BaremetalCdromTask) OnFailure(ctx context.Context, baremetal *models.SHost, reason jsonutils.JSONObject)

func (*BaremetalCdromTask) OnInit ¶ 

func (self *BaremetalCdromTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalCdromTask) OnSyncConfigComplete ¶ 

func (self *BaremetalCdromTask) OnSyncConfigComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalCdromTask) OnSyncConfigCompleteFailed ¶ 

func (self *BaremetalCdromTask) OnSyncConfigCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BaremetalConvertHypervisorTask ¶ 

type BaremetalConvertHypervisorTask struct {
	taskman.STask
}

func (*BaremetalConvertHypervisorTask) OnFailedSyncstatusComplete ¶ 

func (self *BaremetalConvertHypervisorTask) OnFailedSyncstatusComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalConvertHypervisorTask) OnGuestDeleteComplete ¶ 

func (self *BaremetalConvertHypervisorTask) OnGuestDeleteComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalConvertHypervisorTask) OnGuestDeployComplete ¶ 

func (self *BaremetalConvertHypervisorTask) OnGuestDeployComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalConvertHypervisorTask) OnGuestDeployCompleteFailed ¶ 

func (self *BaremetalConvertHypervisorTask) OnGuestDeployCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalConvertHypervisorTask) OnInit ¶ 

func (self *BaremetalConvertHypervisorTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BaremetalCreateTask ¶ 

type BaremetalCreateTask struct {
	SBaremetalBaseTask
}

func (*BaremetalCreateTask) OnInit ¶ 

func (self *BaremetalCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalCreateTask) OnIpmiProbeComplete ¶ 

func (self *BaremetalCreateTask) OnIpmiProbeComplete(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalCreateTask) OnIpmiProbeCompleteFailed ¶ 

func (self *BaremetalCreateTask) OnIpmiProbeCompleteFailed(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalCreateTask) OnPrepareComplete ¶ 

func (self *BaremetalCreateTask) OnPrepareComplete(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalCreateTask) OnPrepareCompleteFailed ¶ 

func (self *BaremetalCreateTask) OnPrepareCompleteFailed(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BaremetalDeleteTask ¶ 

type BaremetalDeleteTask struct {
	SBaremetalBaseTask
}

func (*BaremetalDeleteTask) OnDeleteBaremetalComplete ¶ 

func (self *BaremetalDeleteTask) OnDeleteBaremetalComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalDeleteTask) OnDeleteBaremetalCompleteFailed ¶ 

func (self *BaremetalDeleteTask) OnDeleteBaremetalCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalDeleteTask) OnFailure ¶ 

func (self *BaremetalDeleteTask) OnFailure(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalDeleteTask) OnInit ¶ 

func (self *BaremetalDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BaremetalIpmiProbeTask ¶ 

type BaremetalIpmiProbeTask struct {
	SBaremetalBaseTask
}

func (*BaremetalIpmiProbeTask) OnFailure ¶ 

func (self *BaremetalIpmiProbeTask) OnFailure(ctx context.Context, baremetal *models.SHost, reason jsonutils.JSONObject)

func (*BaremetalIpmiProbeTask) OnInit ¶ 

func (self *BaremetalIpmiProbeTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalIpmiProbeTask) OnSyncConfigComplete ¶ 

func (self *BaremetalIpmiProbeTask) OnSyncConfigComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalIpmiProbeTask) OnSyncConfigCompleteFailed ¶ 

func (self *BaremetalIpmiProbeTask) OnSyncConfigCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BaremetalMaintenanceTask ¶ 

type BaremetalMaintenanceTask struct {
	SBaremetalBaseTask
}

func (*BaremetalMaintenanceTask) OnEnterMaintenantModeSucc ¶ 

func (self *BaremetalMaintenanceTask) OnEnterMaintenantModeSucc(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalMaintenanceTask) OnEnterMaintenantModeSuccFailed ¶ 

func (self *BaremetalMaintenanceTask) OnEnterMaintenantModeSuccFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalMaintenanceTask) OnInit ¶ 

func (self *BaremetalMaintenanceTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BaremetalPrepareTask ¶ 

type BaremetalPrepareTask struct {
	SBaremetalBaseTask
}

func (*BaremetalPrepareTask) OnFailure ¶ 

func (self *BaremetalPrepareTask) OnFailure(ctx context.Context, baremetal *models.SHost, reason jsonutils.JSONObject)

func (*BaremetalPrepareTask) OnInit ¶ 

func (self *BaremetalPrepareTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalPrepareTask) OnSyncConfigComplete ¶ 

func (self *BaremetalPrepareTask) OnSyncConfigComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalPrepareTask) OnSyncConfigCompleteFailed ¶ 

func (self *BaremetalPrepareTask) OnSyncConfigCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BaremetalServerResetTask ¶ 

type BaremetalServerResetTask struct {
	SGuestBaseTask
}

func (*BaremetalServerResetTask) OnInit ¶ 

func (self *BaremetalServerResetTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BaremetalServerStartTask ¶ 

type BaremetalServerStartTask struct {
	SGuestBaseTask
}

func (*BaremetalServerStartTask) OnInit ¶ 

func (self *BaremetalServerStartTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalServerStartTask) OnStartComplete ¶ 

func (self *BaremetalServerStartTask) OnStartComplete(ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject)

func (*BaremetalServerStartTask) OnStartCompleteFailed ¶ 

func (self *BaremetalServerStartTask) OnStartCompleteFailed(ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject)

type BaremetalServerStopTask ¶ 

type BaremetalServerStopTask struct {
	SGuestBaseTask
}

func (*BaremetalServerStopTask) OnGuestStopTaskComplete ¶ 

func (self *BaremetalServerStopTask) OnGuestStopTaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*BaremetalServerStopTask) OnGuestStopTaskCompleteFailed ¶ 

func (self *BaremetalServerStopTask) OnGuestStopTaskCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*BaremetalServerStopTask) OnInit ¶ 

func (self *BaremetalServerStopTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalServerStopTask) OnStopGuestFail ¶ 

func (self *BaremetalServerStopTask) OnStopGuestFail(ctx context.Context, guest *models.SGuest, reason string)

type BaremetalServerSyncStatusTask ¶ 

type BaremetalServerSyncStatusTask struct {
	SGuestBaseTask
}

func (*BaremetalServerSyncStatusTask) OnGetStatusFail ¶ 

func (self *BaremetalServerSyncStatusTask) OnGetStatusFail(ctx context.Context, guest *models.SGuest)

func (*BaremetalServerSyncStatusTask) OnGuestStatusTaskComplete ¶ 

func (self *BaremetalServerSyncStatusTask) OnGuestStatusTaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*BaremetalServerSyncStatusTask) OnGuestStatusTaskCompleteFailed ¶ 

func (self *BaremetalServerSyncStatusTask) OnGuestStatusTaskCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*BaremetalServerSyncStatusTask) OnInit ¶ 

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

type BaremetalSyncAllGuestsStatusTask ¶ 

type BaremetalSyncAllGuestsStatusTask struct {
	SBaremetalBaseTask
}

func (*BaremetalSyncAllGuestsStatusTask) OnGuestSyncStatusComplete ¶ 

func (self *BaremetalSyncAllGuestsStatusTask) OnGuestSyncStatusComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalSyncAllGuestsStatusTask) OnGuestSyncStatusCompleteFailed ¶ 

func (self *BaremetalSyncAllGuestsStatusTask) OnGuestSyncStatusCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalSyncAllGuestsStatusTask) OnInit ¶ 

func (self *BaremetalSyncAllGuestsStatusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BaremetalSyncConfigTask ¶ 

type BaremetalSyncConfigTask struct {
	SBaremetalBaseTask
}

func (*BaremetalSyncConfigTask) DoSyncConfig ¶ 

func (self *BaremetalSyncConfigTask) DoSyncConfig(ctx context.Context, baremetal *models.SHost)

func (*BaremetalSyncConfigTask) OnInit ¶ 

func (self *BaremetalSyncConfigTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalSyncConfigTask) OnSyncConfigComplete ¶ 

func (self *BaremetalSyncConfigTask) OnSyncConfigComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalSyncConfigTask) OnSyncstatusComplete ¶ 

func (self *BaremetalSyncConfigTask) OnSyncstatusComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BaremetalSyncStatusTask ¶ 

type BaremetalSyncStatusTask struct {
	SBaremetalBaseTask
}

func (*BaremetalSyncStatusTask) DoSyncStatus ¶ 

func (self *BaremetalSyncStatusTask) DoSyncStatus(ctx context.Context, baremetal *models.SHost)

func (*BaremetalSyncStatusTask) OnInit ¶ 

func (self *BaremetalSyncStatusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalSyncStatusTask) OnSyncstatusComplete ¶ 

func (self *BaremetalSyncStatusTask) OnSyncstatusComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalSyncStatusTask) OnSyncstatusCompleteFailed ¶ 

func (self *BaremetalSyncStatusTask) OnSyncstatusCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BaremetalUnconvertHypervisorTask ¶ 

type BaremetalUnconvertHypervisorTask struct {
	SBaremetalBaseTask
}

func (*BaremetalUnconvertHypervisorTask) OnFailSyncstatusComplete ¶ 

func (self *BaremetalUnconvertHypervisorTask) OnFailSyncstatusComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalUnconvertHypervisorTask) OnGuestDeleteComplete ¶ 

func (self *BaremetalUnconvertHypervisorTask) OnGuestDeleteComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalUnconvertHypervisorTask) OnGuestDeleteCompleteFailed ¶ 

func (self *BaremetalUnconvertHypervisorTask) OnGuestDeleteCompleteFailed(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

func (*BaremetalUnconvertHypervisorTask) OnInit ¶ 

func (self *BaremetalUnconvertHypervisorTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalUnconvertHypervisorTask) OnPrepareComplete ¶ 

func (self *BaremetalUnconvertHypervisorTask) OnPrepareComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BaremetalUnmaintenanceTask ¶ 

type BaremetalUnmaintenanceTask struct {
	SBaremetalBaseTask
}

func (*BaremetalUnmaintenanceTask) OnInit ¶ 

func (self *BaremetalUnmaintenanceTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*BaremetalUnmaintenanceTask) OnUnmaintenantComplete ¶ 

func (self *BaremetalUnmaintenanceTask) OnUnmaintenantComplete(ctx context.Context, baremetal *models.SHost, body jsonutils.JSONObject)

type BatchSnapshotsDeleteTask ¶ 

type BatchSnapshotsDeleteTask struct {
	taskman.STask
}

func (*BatchSnapshotsDeleteTask) OnInit ¶ 

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

func (*BatchSnapshotsDeleteTask) OnStorageDeleteSnapshot ¶ 

func (self *BatchSnapshotsDeleteTask) OnStorageDeleteSnapshot(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*BatchSnapshotsDeleteTask) StartStorageDeleteSnapshot ¶ 

func (self *BatchSnapshotsDeleteTask) StartStorageDeleteSnapshot(ctx context.Context, snapshot *models.SSnapshot)

type BucketCreateTask ¶ 

type BucketCreateTask struct {
	taskman.STask
}

func (*BucketCreateTask) OnInit ¶ 

func (task *BucketCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BucketDeleteTask ¶ 

type BucketDeleteTask struct {
	taskman.STask
}

func (*BucketDeleteTask) OnInit ¶ 

func (task *BucketDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type BucketSyncstatusTask ¶ 

type BucketSyncstatusTask struct {
	taskman.STask
}

func (*BucketSyncstatusTask) OnBucketSyncStatusComplete ¶ 

func (self *BucketSyncstatusTask) OnBucketSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*BucketSyncstatusTask) OnBucketSyncStatusCompleteFailed ¶ 

func (self *BucketSyncstatusTask) OnBucketSyncStatusCompleteFailed(ctx context.Context, bucket *models.SBucket, data jsonutils.JSONObject)

func (*BucketSyncstatusTask) OnInit ¶ 

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

type CDNDomainCreateTask ¶ 

type CDNDomainCreateTask struct {
	taskman.STask
}

func (*CDNDomainCreateTask) OnInit ¶ 

func (self *CDNDomainCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*CDNDomainCreateTask) OnSyncstatusComplete ¶ 

func (self *CDNDomainCreateTask) OnSyncstatusComplete(ctx context.Context, domain *models.SCDNDomain, data jsonutils.JSONObject)

func (*CDNDomainCreateTask) OnSyncstatusCompleteFailed ¶ 

func (self *CDNDomainCreateTask) OnSyncstatusCompleteFailed(ctx context.Context, domain *models.SCDNDomain, data jsonutils.JSONObject)

type CDNDomainDeleteTask ¶ 

type CDNDomainDeleteTask struct {
	taskman.STask
}

func (*CDNDomainDeleteTask) OnInit ¶ 

func (self *CDNDomainDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CDNDomainRemoteUpdateTask ¶ 

type CDNDomainRemoteUpdateTask struct {
	taskman.STask
}

func (*CDNDomainRemoteUpdateTask) OnInit ¶ 

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

func (*CDNDomainRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *CDNDomainRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, cdn *models.SCDNDomain, data jsonutils.JSONObject)

func (*CDNDomainRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *CDNDomainRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, cdn *models.SCDNDomain, data jsonutils.JSONObject)

func (*CDNDomainRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *CDNDomainRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, cdn *models.SCDNDomain, data jsonutils.JSONObject)

type CDNDomainSyncstatusTask ¶ 

type CDNDomainSyncstatusTask struct {
	taskman.STask
}

func (*CDNDomainSyncstatusTask) OnInit ¶ 

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

type CloudAccountDeleteTask ¶ 

type CloudAccountDeleteTask struct {
	taskman.STask
}

func (*CloudAccountDeleteTask) OnInit ¶ 

func (self *CloudAccountDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CloudAccountSyncInfoTask ¶ 

type CloudAccountSyncInfoTask struct {
	taskman.STask
}

func (*CloudAccountSyncInfoTask) OnCloudaccountSyncComplete ¶ 

func (self *CloudAccountSyncInfoTask) OnCloudaccountSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*CloudAccountSyncInfoTask) OnCloudaccountSyncCompleteFailed ¶ 

func (self *CloudAccountSyncInfoTask) OnCloudaccountSyncCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*CloudAccountSyncInfoTask) OnCloudaccountSyncReady ¶ 

func (self *CloudAccountSyncInfoTask) OnCloudaccountSyncReady(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*CloudAccountSyncInfoTask) OnCloudaccountSyncReadyFailed ¶ 

func (self *CloudAccountSyncInfoTask) OnCloudaccountSyncReadyFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*CloudAccountSyncInfoTask) OnInit ¶ 

func (self *CloudAccountSyncInfoTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CloudAccountSyncSkusTask ¶ 

type CloudAccountSyncSkusTask struct {
	taskman.STask
}

func (*CloudAccountSyncSkusTask) OnInit ¶ 

func (self *CloudAccountSyncSkusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CloudProviderDeleteTask ¶ 

type CloudProviderDeleteTask struct {
	taskman.STask
}

func (*CloudProviderDeleteTask) OnInit ¶ 

func (self *CloudProviderDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CloudProviderSyncInfoTask ¶ 

type CloudProviderSyncInfoTask struct {
	taskman.STask
}

func (*CloudProviderSyncInfoTask) GetSyncRange ¶ 

func (self *CloudProviderSyncInfoTask) GetSyncRange(ctx context.Context) models.SSyncRange

func (*CloudProviderSyncInfoTask) OnInit ¶ 

func (self *CloudProviderSyncInfoTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*CloudProviderSyncInfoTask) OnSyncCloudProviderInfoComplete ¶ 

func (self *CloudProviderSyncInfoTask) OnSyncCloudProviderInfoComplete(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*CloudProviderSyncInfoTask) OnSyncCloudProviderInfoCompleteFailed ¶ 

func (self *CloudProviderSyncInfoTask) OnSyncCloudProviderInfoCompleteFailed(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*CloudProviderSyncInfoTask) OnSyncCloudProviderPreInfoComplete ¶ 

func (self *CloudProviderSyncInfoTask) OnSyncCloudProviderPreInfoComplete(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*CloudProviderSyncInfoTask) OnSyncCloudProviderPreInfoCompleteFailed ¶ 

func (self *CloudProviderSyncInfoTask) OnSyncCloudProviderPreInfoCompleteFailed(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CloudRegionSyncSkusTask ¶ 

type CloudRegionSyncSkusTask struct {
	taskman.STask
}

func (*CloudRegionSyncSkusTask) OnInit ¶ 

func (self *CloudRegionSyncSkusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type CloudpodsGuestCreateDiskTask ¶ 

type CloudpodsGuestCreateDiskTask struct {
	NutanixGuestCreateDiskTask
}

type CloudregionSyncImagesTask ¶ 

type CloudregionSyncImagesTask struct {
	taskman.STask
}

func (*CloudregionSyncImagesTask) OnInit ¶ 

func (self *CloudregionSyncImagesTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type ContainerBaseTask ¶ 

type ContainerBaseTask struct {
	taskman.STask
}

func (*ContainerBaseTask) GetContainer ¶ 

func (t *ContainerBaseTask) GetContainer() *models.SContainer

func (*ContainerBaseTask) GetPod ¶ 

func (t *ContainerBaseTask) GetPod() *models.SGuest

func (*ContainerBaseTask) GetPodDriver ¶ 

func (t *ContainerBaseTask) GetPodDriver() models.IPodDriver

type ContainerCreateTask ¶ 

type ContainerCreateTask struct {
	ContainerBaseTask
}

func (*ContainerCreateTask) OnCreated ¶ 

func (t *ContainerCreateTask) OnCreated(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerCreateTask) OnCreatedFailed ¶ 

func (t *ContainerCreateTask) OnCreatedFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

func (*ContainerCreateTask) OnImagePulled ¶ 

func (t *ContainerCreateTask) OnImagePulled(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerCreateTask) OnImagePulledFailed ¶ 

func (t *ContainerCreateTask) OnImagePulledFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

func (*ContainerCreateTask) OnInit ¶ 

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

func (*ContainerCreateTask) OnStarted ¶ 

func (t *ContainerCreateTask) OnStarted(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerCreateTask) OnStartedFailed ¶ 

func (t *ContainerCreateTask) OnStartedFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

type ContainerDeleteTask ¶ 

type ContainerDeleteTask struct {
	ContainerBaseTask
}

func (*ContainerDeleteTask) OnDeleteFailed ¶ 

func (t *ContainerDeleteTask) OnDeleteFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

func (*ContainerDeleteTask) OnDeleted ¶ 

func (t *ContainerDeleteTask) OnDeleted(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerDeleteTask) OnInit ¶ 

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

type ContainerPullImageTask ¶ 

type ContainerPullImageTask struct {
	ContainerBaseTask
}

func (*ContainerPullImageTask) OnInit ¶ 

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

func (*ContainerPullImageTask) OnPulled ¶ 

func (t *ContainerPullImageTask) OnPulled(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerPullImageTask) OnPulledFailed ¶ 

func (t *ContainerPullImageTask) OnPulledFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

type ContainerSaveVolumeMountImageTask ¶ 

type ContainerSaveVolumeMountImageTask struct {
	ContainerBaseTask
}

func (*ContainerSaveVolumeMountImageTask) OnImageSaved ¶ 

func (t *ContainerSaveVolumeMountImageTask) OnImageSaved(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerSaveVolumeMountImageTask) OnImageSavedFailed ¶ 

func (t *ContainerSaveVolumeMountImageTask) OnImageSavedFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

func (*ContainerSaveVolumeMountImageTask) OnInit ¶ 

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

func (*ContainerSaveVolumeMountImageTask) OnSyncStatus ¶ 

func (t *ContainerSaveVolumeMountImageTask) OnSyncStatus(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerSaveVolumeMountImageTask) OnSyncStatusFailed ¶ 

func (t *ContainerSaveVolumeMountImageTask) OnSyncStatusFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

type ContainerStartTask ¶ 

type ContainerStartTask struct {
	ContainerBaseTask
}

func (*ContainerStartTask) OnInit ¶ 

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

func (*ContainerStartTask) OnStarted ¶ 

func (t *ContainerStartTask) OnStarted(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerStartTask) OnStartedFailed ¶ 

func (t *ContainerStartTask) OnStartedFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

func (*ContainerStartTask) OnSyncStatus ¶ 

func (t *ContainerStartTask) OnSyncStatus(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerStartTask) OnSyncStatusFailed ¶ 

func (t *ContainerStartTask) OnSyncStatusFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

type ContainerStopTask ¶ 

type ContainerStopTask struct {
	ContainerBaseTask
}

func (*ContainerStopTask) OnInit ¶ 

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

func (*ContainerStopTask) OnStopped ¶ 

func (t *ContainerStopTask) OnStopped(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerStopTask) OnStoppedFailed ¶ 

func (t *ContainerStopTask) OnStoppedFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

func (*ContainerStopTask) OnSyncStatus ¶ 

func (t *ContainerStopTask) OnSyncStatus(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerStopTask) OnSyncStatusFailed ¶ 

func (t *ContainerStopTask) OnSyncStatusFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

type ContainerSyncStatusTask ¶ 

type ContainerSyncStatusTask struct {
	ContainerBaseTask
}

func (*ContainerSyncStatusTask) OnInit ¶ 

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

func (*ContainerSyncStatusTask) OnSyncStatus ¶ 

func (t *ContainerSyncStatusTask) OnSyncStatus(ctx context.Context, container *models.SContainer, data jsonutils.JSONObject)

func (*ContainerSyncStatusTask) OnSyncStatusFailed ¶ 

func (t *ContainerSyncStatusTask) OnSyncStatusFailed(ctx context.Context, container *models.SContainer, reason jsonutils.JSONObject)

type CreateImportedLibvirtGuestTask ¶ 

type CreateImportedLibvirtGuestTask struct {
	taskman.STask
}

func (*CreateImportedLibvirtGuestTask) OnGuestSync ¶ 

func (self *CreateImportedLibvirtGuestTask) OnGuestSync(
	ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject,
)

func (*CreateImportedLibvirtGuestTask) OnGuestSyncFailed ¶ 

func (self *CreateImportedLibvirtGuestTask) OnGuestSyncFailed(
	ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject,
)

func (*CreateImportedLibvirtGuestTask) OnInit ¶ 

func (self *CreateImportedLibvirtGuestTask) OnInit(
	ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject,
)

func (*CreateImportedLibvirtGuestTask) OnInitFailed ¶ 

func (self *CreateImportedLibvirtGuestTask) OnInitFailed(
	ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject,
)

func (*CreateImportedLibvirtGuestTask) TaskFailed ¶ 

func (self *CreateImportedLibvirtGuestTask) TaskFailed(
	ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject,
)

type DBInstanceAccountCreateTask ¶ 

type DBInstanceAccountCreateTask struct {
	taskman.STask
}

func (*DBInstanceAccountCreateTask) CreateDBInstanceAccount ¶ 

func (self *DBInstanceAccountCreateTask) CreateDBInstanceAccount(ctx context.Context, account *models.SDBInstanceAccount)

func (*DBInstanceAccountCreateTask) OnInit ¶ 

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

type DBInstanceAccountDeleteTask ¶ 

type DBInstanceAccountDeleteTask struct {
	taskman.STask
}

func (*DBInstanceAccountDeleteTask) DeleteDBInstanceAccount ¶ 

func (self *DBInstanceAccountDeleteTask) DeleteDBInstanceAccount(ctx context.Context, account *models.SDBInstanceAccount)

func (*DBInstanceAccountDeleteTask) OnInit ¶ 

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

type DBInstanceAccountGrantPrivilegeTask ¶ 

type DBInstanceAccountGrantPrivilegeTask struct {
	taskman.STask
}

func (*DBInstanceAccountGrantPrivilegeTask) OnInit ¶ 

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

type DBInstanceAccountResetPasswordTask ¶ 

type DBInstanceAccountResetPasswordTask struct {
	taskman.STask
}

func (*DBInstanceAccountResetPasswordTask) OnInit ¶ 

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

type DBInstanceAccountRevokePrivilegeTask ¶ 

type DBInstanceAccountRevokePrivilegeTask struct {
	taskman.STask
}

func (*DBInstanceAccountRevokePrivilegeTask) OnInit ¶ 

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

type DBInstanceAccountSetPrivilegesTask ¶ 

type DBInstanceAccountSetPrivilegesTask struct {
	taskman.STask
}

func (*DBInstanceAccountSetPrivilegesTask) OnInit ¶ 

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

type DBInstanceBackupCreateTask ¶ 

type DBInstanceBackupCreateTask struct {
	taskman.STask
}

func (*DBInstanceBackupCreateTask) CreateDBInstanceBackup ¶ 

func (self *DBInstanceBackupCreateTask) CreateDBInstanceBackup(ctx context.Context, backup *models.SDBInstanceBackup)

func (*DBInstanceBackupCreateTask) OnCreateDBInstanceBackupComplete ¶ 

func (self *DBInstanceBackupCreateTask) OnCreateDBInstanceBackupComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceBackupCreateTask) OnCreateDBInstanceBackupCompleteFailed ¶ 

func (self *DBInstanceBackupCreateTask) OnCreateDBInstanceBackupCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceBackupCreateTask) OnInit ¶ 

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

type DBInstanceBackupDeleteTask ¶ 

type DBInstanceBackupDeleteTask struct {
	taskman.STask
}

func (*DBInstanceBackupDeleteTask) DeleteDBInstanceBackup ¶ 

func (self *DBInstanceBackupDeleteTask) DeleteDBInstanceBackup(ctx context.Context, backup *models.SDBInstanceBackup)

func (*DBInstanceBackupDeleteTask) OnInit ¶ 

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

type DBInstanceBackupSyncstatusTask ¶ 

type DBInstanceBackupSyncstatusTask struct {
	taskman.STask
}

func (*DBInstanceBackupSyncstatusTask) OnDBInstanceBackupSyncStatusComplete ¶ 

func (self *DBInstanceBackupSyncstatusTask) OnDBInstanceBackupSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceBackupSyncstatusTask) OnDBInstanceBackupSyncStatusCompleteFailed ¶ 

func (self *DBInstanceBackupSyncstatusTask) OnDBInstanceBackupSyncStatusCompleteFailed(ctx context.Context, backup *models.SDBInstanceBackup, data jsonutils.JSONObject)

func (*DBInstanceBackupSyncstatusTask) OnInit ¶ 

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

type DBInstanceChangeConfigTask ¶ 

type DBInstanceChangeConfigTask struct {
	taskman.STask
}

func (*DBInstanceChangeConfigTask) OnDBInstanceChangeConfigComplete ¶ 

func (self *DBInstanceChangeConfigTask) OnDBInstanceChangeConfigComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceChangeConfigTask) OnDBInstanceChangeConfigCompleteFailed ¶ 

func (self *DBInstanceChangeConfigTask) OnDBInstanceChangeConfigCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceChangeConfigTask) OnInit ¶ 

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

func (*DBInstanceChangeConfigTask) OnSyncDBInstanceStatusComplete ¶ 

func (self *DBInstanceChangeConfigTask) OnSyncDBInstanceStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceChangeConfigTask) OnSyncDBInstanceStatusCompleteFailed ¶ 

func (self *DBInstanceChangeConfigTask) OnSyncDBInstanceStatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type DBInstanceCreateTask ¶ 

type DBInstanceCreateTask struct {
	taskman.STask
}

func (*DBInstanceCreateTask) CreateDBInstance ¶ 

func (self *DBInstanceCreateTask) CreateDBInstance(ctx context.Context, rds *models.SDBInstance)

func (*DBInstanceCreateTask) OnCreateDBInstanceComplete ¶ 

func (self *DBInstanceCreateTask) OnCreateDBInstanceComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceCreateTask) OnCreateDBInstanceCompleteFailed ¶ 

func (self *DBInstanceCreateTask) OnCreateDBInstanceCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceCreateTask) OnInit ¶ 

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

func (*DBInstanceCreateTask) OnSyncDBInstanceStatusComplete ¶ 

func (self *DBInstanceCreateTask) OnSyncDBInstanceStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceCreateTask) OnSyncDBInstanceStatusCompleteFailed ¶ 

func (self *DBInstanceCreateTask) OnSyncDBInstanceStatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type DBInstanceDatabaseCreateTask ¶ 

type DBInstanceDatabaseCreateTask struct {
	taskman.STask
}

func (*DBInstanceDatabaseCreateTask) CreateDBInstanceDatabase ¶ 

func (self *DBInstanceDatabaseCreateTask) CreateDBInstanceDatabase(ctx context.Context, database *models.SDBInstanceDatabase)

func (*DBInstanceDatabaseCreateTask) OnInit ¶ 

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

type DBInstanceDatabaseDeleteTask ¶ 

type DBInstanceDatabaseDeleteTask struct {
	taskman.STask
}

func (*DBInstanceDatabaseDeleteTask) DeleteDBInstanceDatabase ¶ 

func (self *DBInstanceDatabaseDeleteTask) DeleteDBInstanceDatabase(ctx context.Context, database *models.SDBInstanceDatabase)

func (*DBInstanceDatabaseDeleteTask) OnInit ¶ 

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

type DBInstanceDeleteTask ¶ 

type DBInstanceDeleteTask struct {
	taskman.STask
}

func (*DBInstanceDeleteTask) DeleteBackups ¶ 

func (self *DBInstanceDeleteTask) DeleteBackups(ctx context.Context, instance *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceDeleteTask) DeleteDBInstance ¶ 

func (self *DBInstanceDeleteTask) DeleteDBInstance(ctx context.Context, rds *models.SDBInstance)

func (*DBInstanceDeleteTask) DeleteDBInstanceComplete ¶ 

func (self *DBInstanceDeleteTask) DeleteDBInstanceComplete(ctx context.Context, rds *models.SDBInstance)

func (*DBInstanceDeleteTask) OnInit ¶ 

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

type DBInstancePublicConnectionTask ¶ 

type DBInstancePublicConnectionTask struct {
	taskman.STask
}

func (*DBInstancePublicConnectionTask) DBInstancePublicConnectionOperation ¶ 

func (self *DBInstancePublicConnectionTask) DBInstancePublicConnectionOperation(ctx context.Context, instance *models.SDBInstance)

func (*DBInstancePublicConnectionTask) OnInit ¶ 

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

type DBInstanceRebootTask ¶ 

type DBInstanceRebootTask struct {
	taskman.STask
}

func (*DBInstanceRebootTask) OnInit ¶ 

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

func (*DBInstanceRebootTask) RebootDBInstance ¶ 

func (self *DBInstanceRebootTask) RebootDBInstance(ctx context.Context, dbinstance *models.SDBInstance)

type DBInstanceRecoveryTask ¶ 

type DBInstanceRecoveryTask struct {
	taskman.STask
}

func (*DBInstanceRecoveryTask) OnInit ¶ 

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

type DBInstanceRemoteUpdateTask ¶ 

type DBInstanceRemoteUpdateTask struct {
	taskman.STask
}

func (*DBInstanceRemoteUpdateTask) OnInit ¶ 

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

func (*DBInstanceRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *DBInstanceRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *DBInstanceRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *DBInstanceRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *DBInstanceRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

type DBInstanceRenewTask ¶ 

type DBInstanceRenewTask struct {
	taskman.STask
}

func (*DBInstanceRenewTask) OnInit ¶ 

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

func (*DBInstanceRenewTask) OnSyncstatusComplete ¶ 

func (self *DBInstanceRenewTask) OnSyncstatusComplete(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceRenewTask) OnSyncstatusCompleteFailed ¶ 

func (self *DBInstanceRenewTask) OnSyncstatusCompleteFailed(ctx context.Context, rds *models.SDBInstance, reason jsonutils.JSONObject)

type DBInstanceSetAutoRenewTask ¶ 

type DBInstanceSetAutoRenewTask struct {
	taskman.STask
}

func (*DBInstanceSetAutoRenewTask) OnDBInstanceSyncComplete ¶ 

func (self *DBInstanceSetAutoRenewTask) OnDBInstanceSyncComplete(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceSetAutoRenewTask) OnDBInstanceSyncCompleteFailed ¶ 

func (self *DBInstanceSetAutoRenewTask) OnDBInstanceSyncCompleteFailed(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceSetAutoRenewTask) OnInit ¶ 

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

type DBInstanceSyncSecgroupsTask ¶ 

type DBInstanceSyncSecgroupsTask struct {
	taskman.STask
}

func (*DBInstanceSyncSecgroupsTask) OnInit ¶ 

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

func (*DBInstanceSyncSecgroupsTask) OnSyncComplete ¶ 

func (self *DBInstanceSyncSecgroupsTask) OnSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceSyncSecgroupsTask) OnSyncCompleteFailed ¶ 

func (self *DBInstanceSyncSecgroupsTask) OnSyncCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DBInstanceSyncSecgroupsTask) OnSyncSecurityGroupsComplete ¶ 

func (self *DBInstanceSyncSecgroupsTask) OnSyncSecurityGroupsComplete(ctx context.Context, rds *models.SDBInstance, data jsonutils.JSONObject)

func (*DBInstanceSyncSecgroupsTask) OnSyncSecurityGroupsCompleteFailed ¶ 

func (self *DBInstanceSyncSecgroupsTask) OnSyncSecurityGroupsCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type DBInstanceSyncTask ¶ 

type DBInstanceSyncTask struct {
	taskman.STask
}

func (*DBInstanceSyncTask) OnInit ¶ 

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

func (*DBInstanceSyncTask) SyncDBInstance ¶ 

func (self *DBInstanceSyncTask) SyncDBInstance(ctx context.Context, rds *models.SDBInstance)

type DiskBackupCreateTask ¶ 

type DiskBackupCreateTask struct {
	taskman.STask
}

func (*DiskBackupCreateTask) CreateSnapshot ¶ 

func (self *DiskBackupCreateTask) CreateSnapshot(ctx context.Context, diskBackup *models.SDiskBackup) (*models.SSnapshot, error)

func (*DiskBackupCreateTask) OnCleanupSnapshot ¶ 

func (self *DiskBackupCreateTask) OnCleanupSnapshot(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupCreateTask) OnCleanupSnapshotFailed ¶ 

func (self *DiskBackupCreateTask) OnCleanupSnapshotFailed(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupCreateTask) OnInit ¶ 

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

func (*DiskBackupCreateTask) OnSave ¶ 

func (self *DiskBackupCreateTask) OnSave(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupCreateTask) OnSaveFailed ¶ 

func (self *DiskBackupCreateTask) OnSaveFailed(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupCreateTask) OnSnapshot ¶ 

func (self *DiskBackupCreateTask) OnSnapshot(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupCreateTask) OnSnapshotFailed ¶ 

func (self *DiskBackupCreateTask) OnSnapshotFailed(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

type DiskBackupDeleteTask ¶ 

type DiskBackupDeleteTask struct {
	taskman.STask
}

func (*DiskBackupDeleteTask) OnDelete ¶ 

func (self *DiskBackupDeleteTask) OnDelete(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupDeleteTask) OnDeleteFailed ¶ 

func (self *DiskBackupDeleteTask) OnDeleteFailed(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupDeleteTask) OnInit ¶ 

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

type DiskBackupRecoveryTask ¶ 

type DiskBackupRecoveryTask struct {
	taskman.STask
}

func (*DiskBackupRecoveryTask) OnCreateDisk ¶ 

func (self *DiskBackupRecoveryTask) OnCreateDisk(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupRecoveryTask) OnCreateDiskFailed ¶ 

func (self *DiskBackupRecoveryTask) OnCreateDiskFailed(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupRecoveryTask) OnInit ¶ 

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

type DiskBackupSyncstatusTask ¶ 

type DiskBackupSyncstatusTask struct {
	taskman.STask
}

func (*DiskBackupSyncstatusTask) OnDiskBackupSyncStatus ¶ 

func (self *DiskBackupSyncstatusTask) OnDiskBackupSyncStatus(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DiskBackupSyncstatusTask) OnDiskBackupSyncStatusFailed ¶ 

func (self *DiskBackupSyncstatusTask) OnDiskBackupSyncStatusFailed(ctx context.Context, backup *models.SDiskBackup, data jsonutils.JSONObject)

func (*DiskBackupSyncstatusTask) OnInit ¶ 

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

type DiskBatchCreateTask ¶ 

type DiskBatchCreateTask struct {
	SSchedTask
}

func (*DiskBatchCreateTask) GetCreateInput ¶ 

func (task *DiskBatchCreateTask) GetCreateInput(data jsonutils.JSONObject) (*api.DiskCreateInput, error)

func (*DiskBatchCreateTask) GetDisks ¶ 

func (task *DiskBatchCreateTask) GetDisks(data jsonutils.JSONObject) ([]*api.DiskConfig, error)

func (*DiskBatchCreateTask) GetFirstDisk ¶ 

func (task *DiskBatchCreateTask) GetFirstDisk(data jsonutils.JSONObject) (*api.DiskConfig, error)

func (*DiskBatchCreateTask) GetSchedParams ¶ 

func (task *DiskBatchCreateTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*DiskBatchCreateTask) OnInit ¶ 

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

func (*DiskBatchCreateTask) OnScheduleComplete ¶ 

func (task *DiskBatchCreateTask) OnScheduleComplete(ctx context.Context, items []db.IStandaloneModel, data *jsonutils.JSONDict)

func (*DiskBatchCreateTask) OnScheduleFailCallback ¶ 

func (task *DiskBatchCreateTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*DiskBatchCreateTask) SaveScheduleResult ¶ 

func (task *DiskBatchCreateTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, candidate *schedapi.CandidateResource, index int)

type DiskCleanOverduedSnapshots ¶ 

type DiskCleanOverduedSnapshots struct {
	SDiskBaseTask
}

type DiskCleanUpSnapshotsTask ¶ 

type DiskCleanUpSnapshotsTask struct {
	SDiskBaseTask
}

func (*DiskCleanUpSnapshotsTask) OnCleanUpSnapshots ¶ 

func (self *DiskCleanUpSnapshotsTask) OnCleanUpSnapshots(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskCleanUpSnapshotsTask) OnCleanUpSnapshotsFailed ¶ 

func (self *DiskCleanUpSnapshotsTask) OnCleanUpSnapshotsFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskCleanUpSnapshotsTask) OnInit ¶ 

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

func (*DiskCleanUpSnapshotsTask) StartCleanUpSnapshots ¶ 

func (self *DiskCleanUpSnapshotsTask) StartCleanUpSnapshots(ctx context.Context, disk *models.SDisk)

type DiskCreateBackupTask ¶ 

type DiskCreateBackupTask struct {
	HADiskCreateTask
}

func (*DiskCreateBackupTask) OnBackupStorageCacheImageComplete ¶ 

func (self *DiskCreateBackupTask) OnBackupStorageCacheImageComplete(
	ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject,
)

func (*DiskCreateBackupTask) OnInit ¶ 

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

func (*DiskCreateBackupTask) OnSlaveDiskReady ¶ 

func (self *DiskCreateBackupTask) OnSlaveDiskReady(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

type DiskCreateTask ¶ 

type DiskCreateTask struct {
	SDiskBaseTask
}

func (*DiskCreateTask) OnDiskReady ¶ 

func (self *DiskCreateTask) OnDiskReady(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskCreateTask) OnDiskReadyFailed ¶ 

func (self *DiskCreateTask) OnDiskReadyFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskCreateTask) OnInit ¶ 

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

func (*DiskCreateTask) OnStartAllocateFailed ¶ 

func (self *DiskCreateTask) OnStartAllocateFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskCreateTask) OnStorageCacheImageComplete ¶ 

func (self *DiskCreateTask) OnStorageCacheImageComplete(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

type DiskDeleteSnapshotsTask ¶ 

type DiskDeleteSnapshotsTask struct {
	taskman.STask
}

func (*DiskDeleteSnapshotsTask) OnInit ¶ 

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

func (*DiskDeleteSnapshotsTask) OnSnapshotDelete ¶ 

func (self *DiskDeleteSnapshotsTask) OnSnapshotDelete(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskDeleteSnapshotsTask) OnSnapshotDeleteFailed ¶ 

func (self *DiskDeleteSnapshotsTask) OnSnapshotDeleteFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskDeleteSnapshotsTask) StartDeleteDiskSnapshots ¶ 

func (self *DiskDeleteSnapshotsTask) StartDeleteDiskSnapshots(
	ctx context.Context, disk *models.SDisk, snapshots []models.SSnapshot)

type DiskDeleteTask ¶ 

type DiskDeleteTask struct {
	SDiskBaseTask
}

func (*DiskDeleteTask) OnDeleteSnapshots ¶ 

func (self *DiskDeleteTask) OnDeleteSnapshots(ctx context.Context, disk *models.SDisk)

func (*DiskDeleteTask) OnDiskSnapshotDelete ¶ 

func (self *DiskDeleteTask) OnDiskSnapshotDelete(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskDeleteTask) OnDiskSnapshotDeleteFailed ¶ 

func (self *DiskDeleteTask) OnDiskSnapshotDeleteFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskDeleteTask) OnGuestDiskDeleteComplete ¶ 

func (self *DiskDeleteTask) OnGuestDiskDeleteComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DiskDeleteTask) OnGuestDiskDeleteCompleteFailed ¶ 

func (self *DiskDeleteTask) OnGuestDiskDeleteCompleteFailed(ctx context.Context, disk *models.SDisk, reason jsonutils.JSONObject)

func (*DiskDeleteTask) OnInit ¶ 

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

func (*DiskDeleteTask) OnMasterStorageDeleteDiskComplete ¶ 

func (self *DiskDeleteTask) OnMasterStorageDeleteDiskComplete(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskDeleteTask) OnMasterStorageDeleteDiskCompleteFailed ¶ 

func (self *DiskDeleteTask) OnMasterStorageDeleteDiskCompleteFailed(ctx context.Context, disk *models.SDisk, reason jsonutils.JSONObject)

func (*DiskDeleteTask) StartDeleteDiskSnapshots ¶ 

func (self *DiskDeleteTask) StartDeleteDiskSnapshots(ctx context.Context, disk *models.SDisk)

type DiskMigrateTask ¶ 

type DiskMigrateTask struct {
	SSchedTask
}

func (*DiskMigrateTask) GetSchedParams ¶ 

func (task *DiskMigrateTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*DiskMigrateTask) OnDeallocateSourceDisk ¶ 

func (task *DiskMigrateTask) OnDeallocateSourceDisk(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskMigrateTask) OnDeallocateSourceDiskFailed ¶ 

func (task *DiskMigrateTask) OnDeallocateSourceDiskFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskMigrateTask) OnDiskMigrate ¶ 

func (task *DiskMigrateTask) OnDiskMigrate(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskMigrateTask) OnDiskMigrateFailed ¶ 

func (task *DiskMigrateTask) OnDiskMigrateFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskMigrateTask) OnInit ¶ 

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

func (*DiskMigrateTask) OnScheduleFailCallback ¶ 

func (task *DiskMigrateTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*DiskMigrateTask) OnScheduleFailed ¶ 

func (task *DiskMigrateTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*DiskMigrateTask) OnStorageCacheImage ¶ 

func (task *DiskMigrateTask) OnStorageCacheImage(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskMigrateTask) SaveScheduleResult ¶ 

func (task *DiskMigrateTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, candidate *schedapi.CandidateResource, index int)

func (*DiskMigrateTask) TaskComplete ¶ 

func (task *DiskMigrateTask) TaskComplete(ctx context.Context, disk *models.SDisk)

func (*DiskMigrateTask) TaskFailed ¶ 

func (task *DiskMigrateTask) TaskFailed(ctx context.Context, disk *models.SDisk, reason jsonutils.JSONObject)

type DiskResetTask ¶ 

type DiskResetTask struct {
	SDiskBaseTask
}

func (*DiskResetTask) OnInit ¶ 

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

func (*DiskResetTask) OnRequestResetDisk ¶ 

func (self *DiskResetTask) OnRequestResetDisk(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskResetTask) OnRequestResetDiskFailed ¶ 

func (self *DiskResetTask) OnRequestResetDiskFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskResetTask) OnStartGuest ¶ 

func (self *DiskResetTask) OnStartGuest(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskResetTask) RequestResetDisk ¶ 

func (self *DiskResetTask) RequestResetDisk(ctx context.Context, disk *models.SDisk, host *models.SHost)

func (*DiskResetTask) TaskCompleted ¶ 

func (self *DiskResetTask) TaskCompleted(ctx context.Context, disk *models.SDisk, data *jsonutils.JSONDict)

func (*DiskResetTask) TaskFailed ¶ 

func (self *DiskResetTask) TaskFailed(ctx context.Context, disk *models.SDisk, reason error)

type DiskResizeTask ¶ 

type DiskResizeTask struct {
	SDiskBaseTask
}

func (*DiskResizeTask) OnDiskResizeComplete ¶ 

func (self *DiskResizeTask) OnDiskResizeComplete(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskResizeTask) OnDiskResizeCompleteFailed ¶ 

func (self *DiskResizeTask) OnDiskResizeCompleteFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskResizeTask) OnDiskResized ¶ 

func (self *DiskResizeTask) OnDiskResized(ctx context.Context, disk *models.SDisk)

func (*DiskResizeTask) OnInit ¶ 

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

func (*DiskResizeTask) OnStartResizeDiskFailed ¶ 

func (self *DiskResizeTask) OnStartResizeDiskFailed(ctx context.Context, disk *models.SDisk, reason error)

func (*DiskResizeTask) OnStartResizeDiskSucc ¶ 

func (self *DiskResizeTask) OnStartResizeDiskSucc(ctx context.Context, disk *models.SDisk)

func (*DiskResizeTask) SetDiskReady ¶ 

func (self *DiskResizeTask) SetDiskReady(ctx context.Context, disk *models.SDisk, userCred mcclient.TokenCredential, reason string)

func (*DiskResizeTask) StartResizeDisk ¶ 

func (self *DiskResizeTask) StartResizeDisk(ctx context.Context, host *models.SHost, storage *models.SStorage, disk *models.SDisk)

type DiskSaveTask ¶ 

type DiskSaveTask struct {
	SDiskBaseTask
}

func (*DiskSaveTask) GetMasterHost ¶ 

func (self *DiskSaveTask) GetMasterHost(disk *models.SDisk) *models.SHost

func (*DiskSaveTask) OnDiskBackupComplete ¶ 

func (self *DiskSaveTask) OnDiskBackupComplete(ctx context.Context, disk *models.SDisk, data *jsonutils.JSONDict)

func (*DiskSaveTask) OnDiskBackupCompleteFailed ¶ 

func (self *DiskSaveTask) OnDiskBackupCompleteFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskSaveTask) OnInit ¶ 

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

func (*DiskSaveTask) OnUploadDiskComplete ¶ 

func (self *DiskSaveTask) OnUploadDiskComplete(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskSaveTask) OnUploadDiskCompleteFailed ¶ 

func (self *DiskSaveTask) OnUploadDiskCompleteFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskSaveTask) RefreshImageCache ¶ 

func (self *DiskSaveTask) RefreshImageCache(ctx context.Context, imageId string)

func (*DiskSaveTask) StartBackupDisk ¶ 

func (self *DiskSaveTask) StartBackupDisk(ctx context.Context, disk *models.SDisk, host *models.SHost)

func (*DiskSaveTask) UploadDisk ¶ 

func (self *DiskSaveTask) UploadDisk(ctx context.Context, host *models.SHost, disk *models.SDisk, imageId string, data *jsonutils.JSONDict) error

type DiskSyncstatusTask ¶ 

type DiskSyncstatusTask struct {
	taskman.STask
}

func (*DiskSyncstatusTask) OnDiskSyncStatusComplete ¶ 

func (self *DiskSyncstatusTask) OnDiskSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*DiskSyncstatusTask) OnDiskSyncStatusCompleteFailed ¶ 

func (self *DiskSyncstatusTask) OnDiskSyncStatusCompleteFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*DiskSyncstatusTask) OnInit ¶ 

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

type DnsRecordCreateTask ¶ 

type DnsRecordCreateTask struct {
	taskman.STask
}

func (*DnsRecordCreateTask) OnInit ¶ 

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

type DnsRecordDeleteTask ¶ 

type DnsRecordDeleteTask struct {
	taskman.STask
}

func (*DnsRecordDeleteTask) OnInit ¶ 

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

type DnsRecordSetEnabledTask ¶ 

type DnsRecordSetEnabledTask struct {
	taskman.STask
}

func (*DnsRecordSetEnabledTask) OnInit ¶ 

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

type DnsRecordUpdateTask ¶ 

type DnsRecordUpdateTask struct {
	taskman.STask
}

func (*DnsRecordUpdateTask) OnInit ¶ 

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

type DnsZoneAddVpcsTask ¶ 

type DnsZoneAddVpcsTask struct {
	taskman.STask
}

func (*DnsZoneAddVpcsTask) OnInit ¶ 

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

type DnsZoneCreateTask ¶ 

type DnsZoneCreateTask struct {
	taskman.STask
}

func (*DnsZoneCreateTask) OnInit ¶ 

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

type DnsZoneDeleteTask ¶ 

type DnsZoneDeleteTask struct {
	taskman.STask
}

func (*DnsZoneDeleteTask) OnInit ¶ 

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

type DnsZoneRemoveVpcsTask ¶ 

type DnsZoneRemoveVpcsTask struct {
	taskman.STask
}

func (*DnsZoneRemoveVpcsTask) OnInit ¶ 

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

type DnsZoneSyncstatusTask ¶ 

type DnsZoneSyncstatusTask struct {
	taskman.STask
}

func (*DnsZoneSyncstatusTask) OnInit ¶ 

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

type ESXiGuestCreateDiskTask ¶ 

type ESXiGuestCreateDiskTask struct {
	SGuestCreateDiskBaseTask
}

func (*ESXiGuestCreateDiskTask) OnInit ¶ 

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

type EipAllocateTask ¶ 

type EipAllocateTask struct {
	taskman.STask
}

func (*EipAllocateTask) OnEipAssociateComplete ¶ 

func (self *EipAllocateTask) OnEipAssociateComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*EipAllocateTask) OnEipAssociateCompleteFailed ¶ 

func (self *EipAllocateTask) OnEipAssociateCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*EipAllocateTask) OnInit ¶ 

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

type EipAssociateTask ¶ 

type EipAssociateTask struct {
	taskman.STask
}

func (*EipAssociateTask) GetAssociateInput ¶ 

func (self *EipAssociateTask) GetAssociateInput() (api.ElasticipAssociateInput, error)

func (*EipAssociateTask) GetAssociateObj ¶ 

func (self *EipAssociateTask) GetAssociateObj(ctx context.Context) (db.IStatusStandaloneModel, api.ElasticipAssociateInput, error)

func (*EipAssociateTask) OnAssociateEipComplete ¶ 

func (self *EipAssociateTask) OnAssociateEipComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*EipAssociateTask) OnAssociateEipCompleteFailed ¶ 

func (self *EipAssociateTask) OnAssociateEipCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*EipAssociateTask) OnInit ¶ 

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

type EipChangeBandwidthTask ¶ 

type EipChangeBandwidthTask struct {
	taskman.STask
}

func (*EipChangeBandwidthTask) OnInit ¶ 

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

func (*EipChangeBandwidthTask) TaskFail ¶ 

func (self *EipChangeBandwidthTask) TaskFail(ctx context.Context, eip *models.SElasticip, msg jsonutils.JSONObject)

type EipDeallocateTask ¶ 

type EipDeallocateTask struct {
	taskman.STask
}

func (*EipDeallocateTask) OnInit ¶ 

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

type EipDissociateTask ¶ 

type EipDissociateTask struct {
	taskman.STask
}

func (*EipDissociateTask) OnInit ¶ 

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

func (*EipDissociateTask) TaskFail ¶ 

func (self *EipDissociateTask) TaskFail(ctx context.Context, eip *models.SElasticip, msg jsonutils.JSONObject, model db.IModel)

type EipRemoteUpdateTask ¶ 

type EipRemoteUpdateTask struct {
	taskman.STask
}

func (*EipRemoteUpdateTask) OnInit ¶ 

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

func (*EipRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *EipRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, eip *models.SElasticip, data jsonutils.JSONObject)

func (*EipRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *EipRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, eip *models.SElasticip, data jsonutils.JSONObject)

func (*EipRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *EipRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, eip *models.SElasticip, data jsonutils.JSONObject)

type EipSyncstatusTask ¶ 

type EipSyncstatusTask struct {
	taskman.STask
}

func (*EipSyncstatusTask) OnInit ¶ 

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

type ElasticSearchDeleteTask ¶ 

type ElasticSearchDeleteTask struct {
	taskman.STask
}

func (*ElasticSearchDeleteTask) OnInit ¶ 

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

type ElasticSearchRemoteUpdateTask ¶ 

type ElasticSearchRemoteUpdateTask struct {
	taskman.STask
}

func (*ElasticSearchRemoteUpdateTask) OnInit ¶ 

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

func (*ElasticSearchRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *ElasticSearchRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, elasticcache *models.SElasticSearch, data jsonutils.JSONObject)

func (*ElasticSearchRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *ElasticSearchRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, elasticcache *models.SElasticSearch, data jsonutils.JSONObject)

func (*ElasticSearchRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *ElasticSearchRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, elasticcache *models.SElasticSearch, data jsonutils.JSONObject)

func (*ElasticSearchRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *ElasticSearchRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, elasticcache *models.SElasticSearch, data jsonutils.JSONObject)

type ElasticSearchSyncstatusTask ¶ 

type ElasticSearchSyncstatusTask struct {
	taskman.STask
}

func (*ElasticSearchSyncstatusTask) OnInit ¶ 

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

type ElasticcacheAccountCreateTask ¶ 

type ElasticcacheAccountCreateTask struct {
	taskman.STask
}

func (*ElasticcacheAccountCreateTask) OnElasticcacheAccountCreateComplete ¶ 

func (self *ElasticcacheAccountCreateTask) OnElasticcacheAccountCreateComplete(ctx context.Context, ea *models.SElasticcacheAccount, data jsonutils.JSONObject)

func (*ElasticcacheAccountCreateTask) OnElasticcacheAccountCreateCompleteFailed ¶ 

func (self *ElasticcacheAccountCreateTask) OnElasticcacheAccountCreateCompleteFailed(ctx context.Context, ea *models.SElasticcacheAccount, data jsonutils.JSONObject)

func (*ElasticcacheAccountCreateTask) OnInit ¶ 

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

type ElasticcacheAccountDeleteTask ¶ 

type ElasticcacheAccountDeleteTask struct {
	taskman.STask
}

func (*ElasticcacheAccountDeleteTask) OnInit ¶ 

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

type ElasticcacheAccountResetPasswordTask ¶ 

type ElasticcacheAccountResetPasswordTask struct {
	taskman.STask
}

func (*ElasticcacheAccountResetPasswordTask) OnInit ¶ 

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

type ElasticcacheAclCreateTask ¶ 

type ElasticcacheAclCreateTask struct {
	taskman.STask
}

func (*ElasticcacheAclCreateTask) OnElasticcacheAclCreateComplete ¶ 

func (self *ElasticcacheAclCreateTask) OnElasticcacheAclCreateComplete(ctx context.Context, ea *models.SElasticcacheAcl, data jsonutils.JSONObject)

func (*ElasticcacheAclCreateTask) OnElasticcacheAclCreateCompleteFailed ¶ 

func (self *ElasticcacheAclCreateTask) OnElasticcacheAclCreateCompleteFailed(ctx context.Context, ea *models.SElasticcacheAcl, data jsonutils.JSONObject)

func (*ElasticcacheAclCreateTask) OnInit ¶ 

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

type ElasticcacheAclDeleteTask ¶ 

type ElasticcacheAclDeleteTask struct {
	taskman.STask
}

func (*ElasticcacheAclDeleteTask) OnInit ¶ 

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

type ElasticcacheAclUpdateTask ¶ 

type ElasticcacheAclUpdateTask struct {
	taskman.STask
}

func (*ElasticcacheAclUpdateTask) OnElasticcacheAclUpdateComplete ¶ 

func (self *ElasticcacheAclUpdateTask) OnElasticcacheAclUpdateComplete(ctx context.Context, ea *models.SElasticcacheAcl, data jsonutils.JSONObject)

func (*ElasticcacheAclUpdateTask) OnElasticcacheAclUpdateCompleteFailed ¶ 

func (self *ElasticcacheAclUpdateTask) OnElasticcacheAclUpdateCompleteFailed(ctx context.Context, ea *models.SElasticcacheAcl, data jsonutils.JSONObject)

func (*ElasticcacheAclUpdateTask) OnInit ¶ 

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

type ElasticcacheAllocatePublicConnectionTask ¶ 

type ElasticcacheAllocatePublicConnectionTask struct {
	taskman.STask
}

func (*ElasticcacheAllocatePublicConnectionTask) OnElasticcacheAllocatePublicConnectionComplete ¶ 

func (self *ElasticcacheAllocatePublicConnectionTask) OnElasticcacheAllocatePublicConnectionComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheAllocatePublicConnectionTask) OnElasticcacheAllocatePublicConnectionCompleteFailed ¶ 

func (self *ElasticcacheAllocatePublicConnectionTask) OnElasticcacheAllocatePublicConnectionCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheAllocatePublicConnectionTask) OnInit ¶ 

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

type ElasticcacheBackupCreateTask ¶ 

type ElasticcacheBackupCreateTask struct {
	taskman.STask
}

func (*ElasticcacheBackupCreateTask) OnElasticcacheBackupCreateComplete ¶ 

func (self *ElasticcacheBackupCreateTask) OnElasticcacheBackupCreateComplete(ctx context.Context, eb *models.SElasticcacheBackup, data jsonutils.JSONObject)

func (*ElasticcacheBackupCreateTask) OnElasticcacheBackupCreateCompleteFailed ¶ 

func (self *ElasticcacheBackupCreateTask) OnElasticcacheBackupCreateCompleteFailed(ctx context.Context, eb *models.SElasticcacheBackup, data jsonutils.JSONObject)

func (*ElasticcacheBackupCreateTask) OnInit ¶ 

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

type ElasticcacheBackupRestoreInstanceTask ¶ 

type ElasticcacheBackupRestoreInstanceTask struct {
	taskman.STask
}

func (*ElasticcacheBackupRestoreInstanceTask) OnElasticcacheBackupRestoreInstanceComplete ¶ 

func (self *ElasticcacheBackupRestoreInstanceTask) OnElasticcacheBackupRestoreInstanceComplete(ctx context.Context, eb *models.SElasticcacheBackup, data jsonutils.JSONObject)

func (*ElasticcacheBackupRestoreInstanceTask) OnElasticcacheBackupRestoreInstanceCompleteFailed ¶ 

func (self *ElasticcacheBackupRestoreInstanceTask) OnElasticcacheBackupRestoreInstanceCompleteFailed(ctx context.Context, eb *models.SElasticcacheBackup, reason jsonutils.JSONObject)

func (*ElasticcacheBackupRestoreInstanceTask) OnInit ¶ 

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

type ElasticcacheChangeSpecTask ¶ 

type ElasticcacheChangeSpecTask struct {
	taskman.STask
}

func (*ElasticcacheChangeSpecTask) OnElasticcacheChangeSpecComplete ¶ 

func (self *ElasticcacheChangeSpecTask) OnElasticcacheChangeSpecComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheChangeSpecTask) OnElasticcacheChangeSpecCompleteFailed ¶ 

func (self *ElasticcacheChangeSpecTask) OnElasticcacheChangeSpecCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheChangeSpecTask) OnInit ¶ 

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

type ElasticcacheCreateTask ¶ 

type ElasticcacheCreateTask struct {
	taskman.STask
}

func (*ElasticcacheCreateTask) OnElasticcacheCreateComplete ¶ 

func (self *ElasticcacheCreateTask) OnElasticcacheCreateComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheCreateTask) OnElasticcacheCreateCompleteFailed ¶ 

func (self *ElasticcacheCreateTask) OnElasticcacheCreateCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheCreateTask) OnInit ¶ 

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

func (*ElasticcacheCreateTask) OnSyncSecurityGroupComplete ¶ 

func (self *ElasticcacheCreateTask) OnSyncSecurityGroupComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheCreateTask) OnSyncSecurityGroupCompleteFailed ¶ 

func (self *ElasticcacheCreateTask) OnSyncSecurityGroupCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

type ElasticcacheDeleteTask ¶ 

type ElasticcacheDeleteTask struct {
	taskman.STask
}

func (*ElasticcacheDeleteTask) OnInit ¶ 

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

type ElasticcacheFlushInstanceTask ¶ 

type ElasticcacheFlushInstanceTask struct {
	taskman.STask
}

func (*ElasticcacheFlushInstanceTask) OnElasticcacheFlushInstanceComplete ¶ 

func (self *ElasticcacheFlushInstanceTask) OnElasticcacheFlushInstanceComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheFlushInstanceTask) OnElasticcacheFlushInstanceCompleteFailed ¶ 

func (self *ElasticcacheFlushInstanceTask) OnElasticcacheFlushInstanceCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheFlushInstanceTask) OnInit ¶ 

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

type ElasticcacheParameterUpdateTask ¶ 

type ElasticcacheParameterUpdateTask struct {
	taskman.STask
}

func (*ElasticcacheParameterUpdateTask) OnElasticcacheParameterUpdateComplete ¶ 

func (self *ElasticcacheParameterUpdateTask) OnElasticcacheParameterUpdateComplete(ctx context.Context, ep *models.SElasticcacheParameter, data jsonutils.JSONObject)

func (*ElasticcacheParameterUpdateTask) OnElasticcacheParameterUpdateCompleteFailed ¶ 

func (self *ElasticcacheParameterUpdateTask) OnElasticcacheParameterUpdateCompleteFailed(ctx context.Context, ep *models.SElasticcacheParameter, reason jsonutils.JSONObject)

func (*ElasticcacheParameterUpdateTask) OnInit ¶ 

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

type ElasticcacheReleasePublicConnectionTask ¶ 

type ElasticcacheReleasePublicConnectionTask struct {
	taskman.STask
}

func (*ElasticcacheReleasePublicConnectionTask) OnElasticcacheReleasePublicConnectionComplete ¶ 

func (self *ElasticcacheReleasePublicConnectionTask) OnElasticcacheReleasePublicConnectionComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheReleasePublicConnectionTask) OnElasticcacheReleasePublicConnectionCompleteFailed ¶ 

func (self *ElasticcacheReleasePublicConnectionTask) OnElasticcacheReleasePublicConnectionCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheReleasePublicConnectionTask) OnInit ¶ 

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

type ElasticcacheRemoteUpdateTask ¶ 

type ElasticcacheRemoteUpdateTask struct {
	taskman.STask
}

func (*ElasticcacheRemoteUpdateTask) OnInit ¶ 

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

func (*ElasticcacheRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *ElasticcacheRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *ElasticcacheRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *ElasticcacheRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *ElasticcacheRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

type ElasticcacheRenewTask ¶ 

type ElasticcacheRenewTask struct {
	taskman.STask
}

func (*ElasticcacheRenewTask) OnElasticcacheSyncstatusComplete ¶ 

func (self *ElasticcacheRenewTask) OnElasticcacheSyncstatusComplete(ctx context.Context, ec *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheRenewTask) OnElasticcacheSyncstatusCompleteFailed ¶ 

func (self *ElasticcacheRenewTask) OnElasticcacheSyncstatusCompleteFailed(ctx context.Context, ec *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheRenewTask) OnInit ¶ 

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

type ElasticcacheRestartTask ¶ 

type ElasticcacheRestartTask struct {
	taskman.STask
}

func (*ElasticcacheRestartTask) OnInit ¶ 

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

type ElasticcacheSetAutoRenewTask ¶ 

type ElasticcacheSetAutoRenewTask struct {
	taskman.STask
}

func (*ElasticcacheSetAutoRenewTask) OnElasticcacheSyncstatusComplete ¶ 

func (self *ElasticcacheSetAutoRenewTask) OnElasticcacheSyncstatusComplete(ctx context.Context, ec *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheSetAutoRenewTask) OnElasticcacheSyncstatusCompleteFailed ¶ 

func (self *ElasticcacheSetAutoRenewTask) OnElasticcacheSyncstatusCompleteFailed(ctx context.Context, ec *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheSetAutoRenewTask) OnInit ¶ 

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

type ElasticcacheSetMaintainTimeTask ¶ 

type ElasticcacheSetMaintainTimeTask struct {
	taskman.STask
}

func (*ElasticcacheSetMaintainTimeTask) OnElasticcacheSetMaintainTimeComplete ¶ 

func (self *ElasticcacheSetMaintainTimeTask) OnElasticcacheSetMaintainTimeComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheSetMaintainTimeTask) OnElasticcacheSetMaintainTimeCompleteFailed ¶ 

func (self *ElasticcacheSetMaintainTimeTask) OnElasticcacheSetMaintainTimeCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheSetMaintainTimeTask) OnInit ¶ 

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

type ElasticcacheSyncTask ¶ 

type ElasticcacheSyncTask struct {
	taskman.STask
}

func (*ElasticcacheSyncTask) OnInit ¶ 

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

type ElasticcacheSyncsecgroupsTask ¶ 

type ElasticcacheSyncsecgroupsTask struct {
	taskman.STask
}

func (*ElasticcacheSyncsecgroupsTask) OnElasticcacheSyncSecgroupsComplete ¶ 

func (self *ElasticcacheSyncsecgroupsTask) OnElasticcacheSyncSecgroupsComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

https://cloud.tencent.com/document/api/239/41256

func (*ElasticcacheSyncsecgroupsTask) OnElasticcacheSyncSecgroupsCompleteFailed ¶ 

func (self *ElasticcacheSyncsecgroupsTask) OnElasticcacheSyncSecgroupsCompleteFailed(ctx context.Context, cache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheSyncsecgroupsTask) OnInit ¶ 

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

type ElasticcacheSyncstatusTask ¶ 

type ElasticcacheSyncstatusTask struct {
	taskman.STask
}

func (*ElasticcacheSyncstatusTask) OnElasticcacheSyncStatusComplete ¶ 

func (self *ElasticcacheSyncstatusTask) OnElasticcacheSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ElasticcacheSyncstatusTask) OnElasticcacheSyncStatusCompleteFailed ¶ 

func (self *ElasticcacheSyncstatusTask) OnElasticcacheSyncStatusCompleteFailed(ctx context.Context, cache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheSyncstatusTask) OnInit ¶ 

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

type ElasticcacheUpdateAuthModeTask ¶ 

type ElasticcacheUpdateAuthModeTask struct {
	taskman.STask
}

func (*ElasticcacheUpdateAuthModeTask) OnElasticcacheUpdateAuthModeComplete ¶ 

func (self *ElasticcacheUpdateAuthModeTask) OnElasticcacheUpdateAuthModeComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheUpdateAuthModeTask) OnElasticcacheUpdateAuthModeCompleteFailed ¶ 

func (self *ElasticcacheUpdateAuthModeTask) OnElasticcacheUpdateAuthModeCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheUpdateAuthModeTask) OnInit ¶ 

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

type ElasticcacheUpdateBackupPolicyTask ¶ 

type ElasticcacheUpdateBackupPolicyTask struct {
	taskman.STask
}

func (*ElasticcacheUpdateBackupPolicyTask) OnElasticcacheUpdateBackupPolicyComplete ¶ 

func (self *ElasticcacheUpdateBackupPolicyTask) OnElasticcacheUpdateBackupPolicyComplete(ctx context.Context, elasticcache *models.SElasticcache, data jsonutils.JSONObject)

func (*ElasticcacheUpdateBackupPolicyTask) OnElasticcacheUpdateBackupPolicyCompleteFailed ¶ 

func (self *ElasticcacheUpdateBackupPolicyTask) OnElasticcacheUpdateBackupPolicyCompleteFailed(ctx context.Context, elasticcache *models.SElasticcache, reason jsonutils.JSONObject)

func (*ElasticcacheUpdateBackupPolicyTask) OnInit ¶ 

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

type ExternalProjectCreateTask ¶ 

type ExternalProjectCreateTask struct {
	taskman.STask
}

func (*ExternalProjectCreateTask) OnInit ¶ 

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

type FileSystemCreateTask ¶ 

type FileSystemCreateTask struct {
	taskman.STask
}

func (*FileSystemCreateTask) OnInit ¶ 

func (self *FileSystemCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*FileSystemCreateTask) OnSyncstatusComplete ¶ 

func (self *FileSystemCreateTask) OnSyncstatusComplete(ctx context.Context, fs *models.SFileSystem, data jsonutils.JSONObject)

func (*FileSystemCreateTask) OnSyncstatusCompleteFailed ¶ 

func (self *FileSystemCreateTask) OnSyncstatusCompleteFailed(ctx context.Context, fs *models.SFileSystem, data jsonutils.JSONObject)

type FileSystemDeleteTask ¶ 

type FileSystemDeleteTask struct {
	taskman.STask
}

func (*FileSystemDeleteTask) OnInit ¶ 

func (self *FileSystemDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type FileSystemRemoteUpdateTask ¶ 

type FileSystemRemoteUpdateTask struct {
	taskman.STask
}

func (*FileSystemRemoteUpdateTask) OnInit ¶ 

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

func (*FileSystemRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *FileSystemRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, fs *models.SFileSystem, data jsonutils.JSONObject)

func (*FileSystemRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *FileSystemRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, fs *models.SFileSystem, data jsonutils.JSONObject)

func (*FileSystemRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *FileSystemRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, fs *models.SFileSystem, data jsonutils.JSONObject)

func (*FileSystemRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *FileSystemRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, fs *models.SFileSystem, data jsonutils.JSONObject)

type FileSystemSyncstatusTask ¶ 

type FileSystemSyncstatusTask struct {
	taskman.STask
}

func (*FileSystemSyncstatusTask) OnInit ¶ 

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

type GlobalVpcCreateTask ¶ 

type GlobalVpcCreateTask struct {
	taskman.STask
}

func (*GlobalVpcCreateTask) OnInit ¶ 

func (self *GlobalVpcCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*GlobalVpcCreateTask) OnSyncstatusComplete ¶ 

func (self *GlobalVpcCreateTask) OnSyncstatusComplete(ctx context.Context, gvpc *models.SGlobalVpc, data jsonutils.JSONObject)

func (*GlobalVpcCreateTask) OnSyncstatusCompleteFailed ¶ 

func (self *GlobalVpcCreateTask) OnSyncstatusCompleteFailed(ctx context.Context, gvpc *models.SGlobalVpc, data jsonutils.JSONObject)

type GlobalVpcDeleteTask ¶ 

type GlobalVpcDeleteTask struct {
	taskman.STask
}

func (*GlobalVpcDeleteTask) OnInit ¶ 

func (self *GlobalVpcDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type GlobalVpcSyncstatusTask ¶ 

type GlobalVpcSyncstatusTask struct {
	taskman.STask
}

func (*GlobalVpcSyncstatusTask) OnInit ¶ 

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

type GuestAttachDiskTask ¶ 

type GuestAttachDiskTask struct {
	SGuestBaseTask
}

func (*GuestAttachDiskTask) OnInit ¶ 

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

func (*GuestAttachDiskTask) OnSyncConfigComplete ¶ 

func (self *GuestAttachDiskTask) OnSyncConfigComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestAttachDiskTask) OnSyncConfigCompleteFailed ¶ 

func (self *GuestAttachDiskTask) OnSyncConfigCompleteFailed(ctx context.Context, obj db.IStandaloneModel, reason jsonutils.JSONObject)

func (*GuestAttachDiskTask) OnTaskFail ¶ 

func (self *GuestAttachDiskTask) OnTaskFail(ctx context.Context, guest *models.SGuest, disk *models.SDisk, err jsonutils.JSONObject)

type GuestBatchCreateTask ¶ 

type GuestBatchCreateTask struct {
	SSchedTask
}

func (*GuestBatchCreateTask) GetCreateInput ¶ 

func (task *GuestBatchCreateTask) GetCreateInput(data jsonutils.JSONObject) (*api.ServerCreateInput, error)

func (*GuestBatchCreateTask) GetDisks ¶ 

func (task *GuestBatchCreateTask) GetDisks() ([]*api.DiskConfig, error)

func (*GuestBatchCreateTask) GetFirstDisk ¶ 

func (task *GuestBatchCreateTask) GetFirstDisk() (*api.DiskConfig, error)

func (*GuestBatchCreateTask) GetSchedParams ¶ 

func (task *GuestBatchCreateTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*GuestBatchCreateTask) OnInit ¶ 

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

func (*GuestBatchCreateTask) OnScheduleComplete ¶ 

func (task *GuestBatchCreateTask) OnScheduleComplete(ctx context.Context, items []db.IStandaloneModel, data *jsonutils.JSONDict)

func (*GuestBatchCreateTask) OnScheduleFailCallback ¶ 

func (task *GuestBatchCreateTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*GuestBatchCreateTask) SaveScheduleResult ¶ 

func (task *GuestBatchCreateTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, candidate *schedapi.CandidateResource, index int)

func (*GuestBatchCreateTask) SaveScheduleResultWithBackup ¶ 

func (task *GuestBatchCreateTask) SaveScheduleResultWithBackup(ctx context.Context, obj IScheduleModel, master, slave *schedapi.CandidateResource, index int)

type GuestBlockIoThrottleTask ¶ 

type GuestBlockIoThrottleTask struct {
	SGuestBaseTask
}

func (*GuestBlockIoThrottleTask) OnGuestSync ¶ 

func (self *GuestBlockIoThrottleTask) OnGuestSync(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestBlockIoThrottleTask) OnGuestSyncFailed ¶ 

func (self *GuestBlockIoThrottleTask) OnGuestSyncFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestBlockIoThrottleTask) OnInit ¶ 

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

func (*GuestBlockIoThrottleTask) OnIoThrottle ¶ 

func (self *GuestBlockIoThrottleTask) OnIoThrottle(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestBlockIoThrottleTask) OnIoThrottleFailed ¶ 

func (self *GuestBlockIoThrottleTask) OnIoThrottleFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestCPUSetTask ¶ 

type GuestCPUSetTask struct {
	SGuestBaseTask
}

func (*GuestCPUSetTask) OnInit ¶ 

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

func (*GuestCPUSetTask) OnSyncComplete ¶ 

func (self *GuestCPUSetTask) OnSyncComplete(ctx context.Context, obj *models.SGuest, data jsonutils.JSONObject)

func (*GuestCPUSetTask) OnSyncCompleteFailed ¶ 

func (self *GuestCPUSetTask) OnSyncCompleteFailed(ctx context.Context, obj *models.SGuest, data jsonutils.JSONObject)

type GuestChangeConfigTask ¶ 

type GuestChangeConfigTask struct {
	SSchedTask
}

func (*GuestChangeConfigTask) DoCreateDisksTask ¶ 

func (task *GuestChangeConfigTask) DoCreateDisksTask(ctx context.Context, guest *models.SGuest)

func (*GuestChangeConfigTask) GetSchedParams ¶ 

func (task *GuestChangeConfigTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*GuestChangeConfigTask) OnCreateDisksComplete ¶ 

func (task *GuestChangeConfigTask) OnCreateDisksComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnCreateDisksCompleteFailed ¶ 

func (task *GuestChangeConfigTask) OnCreateDisksCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnDisksResizeComplete ¶ 

func (task *GuestChangeConfigTask) OnDisksResizeComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestChangeCpuMemSpecComplete ¶ 

func (task *GuestChangeConfigTask) OnGuestChangeCpuMemSpecComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestChangeCpuMemSpecCompleteFailed ¶ 

func (task *GuestChangeConfigTask) OnGuestChangeCpuMemSpecCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestChangeCpuMemSpecFinish ¶ 

func (task *GuestChangeConfigTask) OnGuestChangeCpuMemSpecFinish(ctx context.Context, guest *models.SGuest)

func (*GuestChangeConfigTask) OnGuestResetNicTraffics ¶ 

func (task *GuestChangeConfigTask) OnGuestResetNicTraffics(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestResetNicTrafficsFailed ¶ 

func (task *GuestChangeConfigTask) OnGuestResetNicTrafficsFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestSetNicTraffics ¶ 

func (task *GuestChangeConfigTask) OnGuestSetNicTraffics(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestSetNicTrafficsFailed ¶ 

func (task *GuestChangeConfigTask) OnGuestSetNicTrafficsFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestStartComplete ¶ 

func (task *GuestChangeConfigTask) OnGuestStartComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnGuestStartCompleteFailed ¶ 

func (task *GuestChangeConfigTask) OnGuestStartCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnInit ¶ 

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

func (*GuestChangeConfigTask) OnScheduleFailCallback ¶ 

func (task *GuestChangeConfigTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*GuestChangeConfigTask) OnScheduleFailed ¶ 

func (task *GuestChangeConfigTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnStartSchedule ¶ 

func (task *GuestChangeConfigTask) OnStartSchedule(obj IScheduleModel)

func (*GuestChangeConfigTask) OnSyncConfigComplete ¶ 

func (task *GuestChangeConfigTask) OnSyncConfigComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) OnSyncStatusComplete ¶ 

func (task *GuestChangeConfigTask) OnSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestChangeConfigTask) SaveScheduleResult ¶ 

func (task *GuestChangeConfigTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, target *schedapi.CandidateResource, index int)

func (*GuestChangeConfigTask) SetStageComplete ¶ 

func (task *GuestChangeConfigTask) SetStageComplete(ctx context.Context, data *jsonutils.JSONDict)

func (*GuestChangeConfigTask) SetStageFailed ¶ 

func (task *GuestChangeConfigTask) SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*GuestChangeConfigTask) StartResizeDisks ¶ 

func (task *GuestChangeConfigTask) StartResizeDisks(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestChangeDiskStorageTask ¶ 

type GuestChangeDiskStorageTask struct {
	SGuestBaseTask
}

func (*GuestChangeDiskStorageTask) ChangeDiskStorage ¶ 

func (t *GuestChangeDiskStorageTask) ChangeDiskStorage(ctx context.Context, guest *models.SGuest)

func (*GuestChangeDiskStorageTask) GetInputParams ¶ 

func (t *GuestChangeDiskStorageTask) GetInputParams() (*api.ServerChangeDiskStorageInternalInput, error)

func (*GuestChangeDiskStorageTask) GetSourceDisk ¶ 

func (t *GuestChangeDiskStorageTask) GetSourceDisk() (*models.SDisk, error)

func (*GuestChangeDiskStorageTask) GetTargetDisk ¶ 

func (t *GuestChangeDiskStorageTask) GetTargetDisk() (*models.SDisk, error)

func (*GuestChangeDiskStorageTask) OnDiskChangeStorageComplete ¶ 

func (t *GuestChangeDiskStorageTask) OnDiskChangeStorageComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnDiskChangeStorageCompleteFailed ¶ 

func (t *GuestChangeDiskStorageTask) OnDiskChangeStorageCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnDiskLiveChangeStorageReady ¶ 

func (t *GuestChangeDiskStorageTask) OnDiskLiveChangeStorageReady(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*GuestChangeDiskStorageTask) OnDiskLiveChangeStorageReadyFailed ¶ 

func (t *GuestChangeDiskStorageTask) OnDiskLiveChangeStorageReadyFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*GuestChangeDiskStorageTask) OnGuestSyncStatus ¶ 

func (t *GuestChangeDiskStorageTask) OnGuestSyncStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnGuestSyncStatusFailed ¶ 

func (t *GuestChangeDiskStorageTask) OnGuestSyncStatusFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnInit ¶ 

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

func (*GuestChangeDiskStorageTask) OnSourceDiskDetachComplete ¶ 

func (t *GuestChangeDiskStorageTask) OnSourceDiskDetachComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnSourceDiskDetachCompleteFailed ¶ 

func (t *GuestChangeDiskStorageTask) OnSourceDiskDetachCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnTargetDiskAttachComplete ¶ 

func (t *GuestChangeDiskStorageTask) OnTargetDiskAttachComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) OnTargetDiskAttachCompleteFailed ¶ 

func (t *GuestChangeDiskStorageTask) OnTargetDiskAttachCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) TaskComplete ¶ 

func (t *GuestChangeDiskStorageTask) TaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDiskStorageTask) TaskFailed ¶ 

func (t *GuestChangeDiskStorageTask) TaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestChangeDisksStorageTask ¶ 

type GuestChangeDisksStorageTask struct {
	SGuestBaseTask
}

func (*GuestChangeDisksStorageTask) ChangeDiskStorage ¶ 

func (t *GuestChangeDisksStorageTask) ChangeDiskStorage(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDisksStorageTask) ChangeDiskStorageFailed ¶ 

func (t *GuestChangeDisksStorageTask) ChangeDiskStorageFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDisksStorageTask) CreateTargetDisk ¶ 

func (t *GuestChangeDisksStorageTask) CreateTargetDisk(ctx context.Context, guest *models.SGuest, input *api.ServerChangeStorageInternalInput)

func (*GuestChangeDisksStorageTask) GetInputParams ¶ 

func (t *GuestChangeDisksStorageTask) GetInputParams() (*api.ServerChangeStorageInternalInput, error)

func (*GuestChangeDisksStorageTask) OnDiskChangeStorageComplete ¶ 

func (t *GuestChangeDisksStorageTask) OnDiskChangeStorageComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDisksStorageTask) OnGuestSyncStatus ¶ 

func (t *GuestChangeDisksStorageTask) OnGuestSyncStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDisksStorageTask) OnGuestSyncStatusFailed ¶ 

func (t *GuestChangeDisksStorageTask) OnGuestSyncStatusFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDisksStorageTask) OnInit ¶ 

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

func (*GuestChangeDisksStorageTask) TaskComplete ¶ 

func (t *GuestChangeDisksStorageTask) TaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestChangeDisksStorageTask) TaskFailed ¶ 

func (t *GuestChangeDisksStorageTask) TaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestCloneTask ¶ 

type GuestCloneTask struct {
	GuestBatchCreateTask
}

func (*GuestCloneTask) OnInit ¶ 

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

func (*GuestCloneTask) OnScheduleComplete ¶ 

func (self *GuestCloneTask) OnScheduleComplete(ctx context.Context, guest *models.SGuest, data *jsonutils.JSONDict)

type GuestConvertCloudpodsToKvmTask ¶ 

type GuestConvertCloudpodsToKvmTask struct {
	SSchedTask
}

func (*GuestConvertCloudpodsToKvmTask) GetAccessInfo ¶ 

func (task *GuestConvertCloudpodsToKvmTask) GetAccessInfo(guest *models.SGuest) (*jsonutils.JSONDict, error)

func (*GuestConvertCloudpodsToKvmTask) GetSchedParams ¶ 

func (task *GuestConvertCloudpodsToKvmTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*GuestConvertCloudpodsToKvmTask) OnHostCreateGuest ¶ 

func (task *GuestConvertCloudpodsToKvmTask) OnHostCreateGuest(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*GuestConvertCloudpodsToKvmTask) OnHostCreateGuestFailed ¶ 

func (task *GuestConvertCloudpodsToKvmTask) OnHostCreateGuestFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*GuestConvertCloudpodsToKvmTask) OnInit ¶ 

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

func (*GuestConvertCloudpodsToKvmTask) OnScheduleFailed ¶ 

func (task *GuestConvertCloudpodsToKvmTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*GuestConvertCloudpodsToKvmTask) RequestHostCreateGuestFromCloudpods ¶ 

func (task *GuestConvertCloudpodsToKvmTask) RequestHostCreateGuestFromCloudpods(
	ctx context.Context, guest *models.SGuest, accessInfo *jsonutils.JSONDict,
) error

func (*GuestConvertCloudpodsToKvmTask) SaveScheduleResult ¶ 

func (task *GuestConvertCloudpodsToKvmTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, target *schedapi.CandidateResource, index int)

func (*GuestConvertCloudpodsToKvmTask) TaskComplete ¶ 

func (task *GuestConvertCloudpodsToKvmTask) TaskComplete(ctx context.Context, guest, targetGuest *models.SGuest)

type GuestConvertEsxiToKvmTask ¶ 

type GuestConvertEsxiToKvmTask struct {
	SSchedTask
}

func (*GuestConvertEsxiToKvmTask) GenerateEsxiAcceessInfo ¶ 

func (task *GuestConvertEsxiToKvmTask) GenerateEsxiAcceessInfo(guest *models.SGuest) (*jsonutils.JSONDict, error)

func (*GuestConvertEsxiToKvmTask) GetSchedParams ¶ 

func (task *GuestConvertEsxiToKvmTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*GuestConvertEsxiToKvmTask) OnGuestConvertDoDeployGuest ¶ 

func (task *GuestConvertEsxiToKvmTask) OnGuestConvertDoDeployGuest(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestConvertEsxiToKvmTask) OnGuestConvertDoDeployGuestFailed ¶ 

func (task *GuestConvertEsxiToKvmTask) OnGuestConvertDoDeployGuestFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestConvertEsxiToKvmTask) OnHostCreateGuest ¶ 

func (task *GuestConvertEsxiToKvmTask) OnHostCreateGuest(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*GuestConvertEsxiToKvmTask) OnHostCreateGuestFailed ¶ 

func (task *GuestConvertEsxiToKvmTask) OnHostCreateGuestFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*GuestConvertEsxiToKvmTask) OnInit ¶ 

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

func (*GuestConvertEsxiToKvmTask) OnScheduleFailed ¶ 

func (task *GuestConvertEsxiToKvmTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*GuestConvertEsxiToKvmTask) OnStartSchedule ¶ 

func (task *GuestConvertEsxiToKvmTask) OnStartSchedule(obj IScheduleModel)

func (*GuestConvertEsxiToKvmTask) RequestHostCreateGuestFromEsxi ¶ 

func (task *GuestConvertEsxiToKvmTask) RequestHostCreateGuestFromEsxi(
	ctx context.Context, guest *models.SGuest, esxiAccessInfo *jsonutils.JSONDict,
) error

func (*GuestConvertEsxiToKvmTask) SaveScheduleResult ¶ 

func (task *GuestConvertEsxiToKvmTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, target *schedapi.CandidateResource, index int)

update database for convert esxi to kvm in the part of guest, guestdisks, guestnetworks

func (*GuestConvertEsxiToKvmTask) TaskComplete ¶ 

func (task *GuestConvertEsxiToKvmTask) TaskComplete(ctx context.Context, guest, targetGuest *models.SGuest)

type GuestCreateBackupDisksTask ¶ 

type GuestCreateBackupDisksTask struct {
	SGuestBaseTask
}

func (*GuestCreateBackupDisksTask) CreateBackups ¶ 

func (self *GuestCreateBackupDisksTask) CreateBackups(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupDisksTask) OnInit ¶ 

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

type GuestCreateBackupTask ¶ 

type GuestCreateBackupTask struct {
	SSchedTask
}

func (*GuestCreateBackupTask) GetSchedParams ¶ 

func (task *GuestCreateBackupTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*GuestCreateBackupTask) OnCreateBackup ¶ 

func (task *GuestCreateBackupTask) OnCreateBackup(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnCreateBackupDisks ¶ 

func (task *GuestCreateBackupTask) OnCreateBackupDisks(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnCreateBackupDisksFailed ¶ 

func (task *GuestCreateBackupTask) OnCreateBackupDisksFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnCreateBackupFailed ¶ 

func (task *GuestCreateBackupTask) OnCreateBackupFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnGuestStart ¶ 

func (task *GuestCreateBackupTask) OnGuestStart(ctx context.Context, guest *models.SGuest, guestStatus string)

func (*GuestCreateBackupTask) OnGuestStartCompleted ¶ 

func (task *GuestCreateBackupTask) OnGuestStartCompleted(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnGuestStartCompletedFailed ¶ 

func (task *GuestCreateBackupTask) OnGuestStartCompletedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnInit ¶ 

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

func (*GuestCreateBackupTask) OnInsertIso ¶ 

func (task *GuestCreateBackupTask) OnInsertIso(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnInsertIsoFailed ¶ 

func (task *GuestCreateBackupTask) OnInsertIsoFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnScheduleFailCallback ¶ 

func (task *GuestCreateBackupTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*GuestCreateBackupTask) OnScheduleFailed ¶ 

func (task *GuestCreateBackupTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnStartSchedule ¶ 

func (task *GuestCreateBackupTask) OnStartSchedule(obj IScheduleModel)

func (*GuestCreateBackupTask) OnSyncToBackup ¶ 

func (task *GuestCreateBackupTask) OnSyncToBackup(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) OnSyncToBackupFailed ¶ 

func (task *GuestCreateBackupTask) OnSyncToBackupFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateBackupTask) RequestStartGuest ¶ 

func (task *GuestCreateBackupTask) RequestStartGuest(ctx context.Context, guest *models.SGuest)

func (*GuestCreateBackupTask) SaveScheduleResult ¶ 

func (task *GuestCreateBackupTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, candidate *schedapi.CandidateResource, index int)

func (*GuestCreateBackupTask) StartCreateBackupDisks ¶ 

func (task *GuestCreateBackupTask) StartCreateBackupDisks(ctx context.Context, guest *models.SGuest, host *models.SHost, candidateDisks []*schedapi.CandidateDisk)

func (*GuestCreateBackupTask) StartInsertIso ¶ 

func (task *GuestCreateBackupTask) StartInsertIso(ctx context.Context, guest *models.SGuest, imageId string)

func (*GuestCreateBackupTask) TaskCompleted ¶ 

func (task *GuestCreateBackupTask) TaskCompleted(ctx context.Context, guest *models.SGuest, reason string)

func (*GuestCreateBackupTask) TaskFailed ¶ 

func (task *GuestCreateBackupTask) TaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestCreateDiskTask ¶ 

type GuestCreateDiskTask struct {
	SGuestBaseTask
}

func (*GuestCreateDiskTask) OnDiskPrepared ¶ 

func (self *GuestCreateDiskTask) OnDiskPrepared(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateDiskTask) OnDiskPreparedFailed ¶ 

func (self *GuestCreateDiskTask) OnDiskPreparedFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateDiskTask) OnInit ¶ 

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

type GuestCreateTask ¶ 

type GuestCreateTask struct {
	SGuestBaseTask
}

func (*GuestCreateTask) OnAutoStartGuest ¶ 

func (self *GuestCreateTask) OnAutoStartGuest(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnCdromPrepared ¶ 

func (self *GuestCreateTask) OnCdromPrepared(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateTask) OnCdromPreparedFailed ¶ 

func (self *GuestCreateTask) OnCdromPreparedFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnDeployEipComplete ¶ 

func (self *GuestCreateTask) OnDeployEipComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnDeployEipCompleteFailed ¶ 

func (self *GuestCreateTask) OnDeployEipCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnDeployGuestDescComplete ¶ 

func (self *GuestCreateTask) OnDeployGuestDescComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnDeployGuestDescCompleteFailed ¶ 

func (self *GuestCreateTask) OnDeployGuestDescCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnDiskPrepared ¶ 

func (self *GuestCreateTask) OnDiskPrepared(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateTask) OnDiskPreparedFailed ¶ 

func (self *GuestCreateTask) OnDiskPreparedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateTask) OnGuestNetworkReady ¶ 

func (self *GuestCreateTask) OnGuestNetworkReady(ctx context.Context, guest *models.SGuest)

func (*GuestCreateTask) OnInit ¶ 

func (self *GuestCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*GuestCreateTask) OnSecurityGroupPrepared ¶ 

func (self *GuestCreateTask) OnSecurityGroupPrepared(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateTask) OnSecurityGroupPreparedFailed ¶ 

func (self *GuestCreateTask) OnSecurityGroupPreparedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestCreateTask) OnSyncStatusComplete ¶ 

func (self *GuestCreateTask) OnSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) OnWaitGuestNetworksReady ¶ 

func (self *GuestCreateTask) OnWaitGuestNetworksReady(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestCreateTask) StartDeployGuest ¶ 

func (self *GuestCreateTask) StartDeployGuest(ctx context.Context, guest *models.SGuest)

func (*GuestCreateTask) TaskComplete ¶ 

func (self *GuestCreateTask) TaskComplete(ctx context.Context, guest *models.SGuest)

type GuestDeleteBackupTask ¶ 

type GuestDeleteBackupTask struct {
	SGuestBaseTask
}

func (*GuestDeleteBackupTask) OnCancelBlockReplication ¶ 

func (self *GuestDeleteBackupTask) OnCancelBlockReplication(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnCancelBlockReplicationFailed ¶ 

func (self *GuestDeleteBackupTask) OnCancelBlockReplicationFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnCreateNewBackup ¶ 

func (self *GuestDeleteBackupTask) OnCreateNewBackup(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnCreateNewBackupFailed ¶ 

func (self *GuestDeleteBackupTask) OnCreateNewBackupFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnDeleteBackupComplete ¶ 

func (self *GuestDeleteBackupTask) OnDeleteBackupComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnDeleteOnHost ¶ 

func (self *GuestDeleteBackupTask) OnDeleteOnHost(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnDeleteOnHostFailed ¶ 

func (self *GuestDeleteBackupTask) OnDeleteOnHostFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnFail ¶ 

func (self *GuestDeleteBackupTask) OnFail(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestDeleteBackupTask) OnInit ¶ 

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

func (*GuestDeleteBackupTask) StartDeleteBackupOnHost ¶ 

func (self *GuestDeleteBackupTask) StartDeleteBackupOnHost(ctx context.Context, guest *models.SGuest)

func (*GuestDeleteBackupTask) TaskComplete ¶ 

func (self *GuestDeleteBackupTask) TaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestDeleteOnHostTask ¶ 

type GuestDeleteOnHostTask struct {
	SGuestBaseTask
}

func (*GuestDeleteOnHostTask) OnFail ¶ 

func (self *GuestDeleteOnHostTask) OnFail(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestDeleteOnHostTask) OnInit ¶ 

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

func (*GuestDeleteOnHostTask) OnStopGuest ¶ 

func (self *GuestDeleteOnHostTask) OnStopGuest(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteOnHostTask) OnSync ¶ 

func (self *GuestDeleteOnHostTask) OnSync(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteOnHostTask) OnUnDeployGuest ¶ 

func (self *GuestDeleteOnHostTask) OnUnDeployGuest(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteOnHostTask) OnUnDeployGuestFailed ¶ 

func (self *GuestDeleteOnHostTask) OnUnDeployGuestFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestDeleteSnapshotsTask ¶ 

type GuestDeleteSnapshotsTask struct {
	taskman.STask
}

func (*GuestDeleteSnapshotsTask) OnInit ¶ 

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

func (*GuestDeleteSnapshotsTask) OnInstanceSnapshotDelete ¶ 

func (self *GuestDeleteSnapshotsTask) OnInstanceSnapshotDelete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteSnapshotsTask) OnInstanceSnapshotDeleteFailed ¶ 

func (self *GuestDeleteSnapshotsTask) OnInstanceSnapshotDeleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteSnapshotsTask) OnSnapshotDelete ¶ 

func (self *GuestDeleteSnapshotsTask) OnSnapshotDelete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteSnapshotsTask) OnSnapshotDeleteFailed ¶ 

func (self *GuestDeleteSnapshotsTask) OnSnapshotDeleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteSnapshotsTask) StartDeleteDiskSnapshots ¶ 

func (self *GuestDeleteSnapshotsTask) StartDeleteDiskSnapshots(
	ctx context.Context, guest *models.SGuest, snapshots []models.SSnapshot)

func (*GuestDeleteSnapshotsTask) StartDeleteInstanceSnapshots ¶ 

func (self *GuestDeleteSnapshotsTask) StartDeleteInstanceSnapshots(
	ctx context.Context, guest *models.SGuest, instanceSnapshots []models.SInstanceSnapshot)

type GuestDeleteTask ¶ 

type GuestDeleteTask struct {
	SGuestBaseTask
}

func (*GuestDeleteTask) DeleteGuest ¶ 

func (self *GuestDeleteTask) DeleteGuest(ctx context.Context, guest *models.SGuest)

func (*GuestDeleteTask) DoDeleteGuest ¶ 

func (self *GuestDeleteTask) DoDeleteGuest(ctx context.Context, guest *models.SGuest)

func (*GuestDeleteTask) NotifyServerDeleted ¶ 

func (self *GuestDeleteTask) NotifyServerDeleted(ctx context.Context, guest *models.SGuest)

func (*GuestDeleteTask) OnDiskDetachComplete ¶ 

func (self *GuestDeleteTask) OnDiskDetachComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

remove detachable disks

func (*GuestDeleteTask) OnDiskDetachCompleteFailed ¶ 

func (self *GuestDeleteTask) OnDiskDetachCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestDeleteTask) OnEipDissociateComplete ¶ 

func (self *GuestDeleteTask) OnEipDissociateComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnEipDissociateCompleteFailed ¶ 

func (self *GuestDeleteTask) OnEipDissociateCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestDeleteTask) OnFailed ¶ 

func (self *GuestDeleteTask) OnFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestDeleteComplete ¶ 

func (self *GuestDeleteTask) OnGuestDeleteComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestDeleteCompleteFailed ¶ 

func (self *GuestDeleteTask) OnGuestDeleteCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestDeleteFailed ¶ 

func (self *GuestDeleteTask) OnGuestDeleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestDetachDisksComplete ¶ 

func (self *GuestDeleteTask) OnGuestDetachDisksComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestDetachDisksCompleteFailed ¶ 

func (self *GuestDeleteTask) OnGuestDetachDisksCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestStopComplete ¶ 

func (self *GuestDeleteTask) OnGuestStopComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnGuestStopCompleteFailed ¶ 

func (self *GuestDeleteTask) OnGuestStopCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*GuestDeleteTask) OnInit ¶ 

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

func (*GuestDeleteTask) OnMasterHostStopGuestComplete ¶ 

func (self *GuestDeleteTask) OnMasterHostStopGuestComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnMasterHostStopGuestCompleteFailed ¶ 

func (self *GuestDeleteTask) OnMasterHostStopGuestCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnPendingDeleteComplete ¶ 

func (self *GuestDeleteTask) OnPendingDeleteComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnPendingDeleteCompleteFailed ¶ 

func (self *GuestDeleteTask) OnPendingDeleteCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnStartEipDissociate ¶ 

func (self *GuestDeleteTask) OnStartEipDissociate(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnStartEipDissociateFailed ¶ 

func (self *GuestDeleteTask) OnStartEipDissociateFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnSyncConfigComplete ¶ 

func (self *GuestDeleteTask) OnSyncConfigComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeleteTask) OnSyncConfigCompleteFailed ¶ 

func (self *GuestDeleteTask) OnSyncConfigCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestDeleteTask) StartDeleteGuest ¶ 

func (self *GuestDeleteTask) StartDeleteGuest(ctx context.Context, guest *models.SGuest)

func (*GuestDeleteTask) StartDeleteGuestSnapshots ¶ 

func (self *GuestDeleteTask) StartDeleteGuestSnapshots(ctx context.Context, guest *models.SGuest)

func (*GuestDeleteTask) StartPendingDeleteGuest ¶ 

func (self *GuestDeleteTask) StartPendingDeleteGuest(ctx context.Context, guest *models.SGuest)

type GuestDeployBackupTask ¶ 

type GuestDeployBackupTask struct {
	HAGuestDeployTask
}

func (*GuestDeployBackupTask) OnDeployGuestComplete ¶ 

func (self *GuestDeployBackupTask) OnDeployGuestComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeployBackupTask) OnDeployGuestCompleteFailed ¶ 

func (self *GuestDeployBackupTask) OnDeployGuestCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeployBackupTask) OnInit ¶ 

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

type GuestDeployTask ¶ 

type GuestDeployTask struct {
	SGuestBaseTask
}

func (*GuestDeployTask) DeployOnHost ¶ 

func (self *GuestDeployTask) DeployOnHost(ctx context.Context, guest *models.SGuest, host *models.SHost)

func (*GuestDeployTask) OnDeployGuestComplete ¶ 

func (self *GuestDeployTask) OnDeployGuestComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeployTask) OnDeployGuestCompleteFailed ¶ 

func (self *GuestDeployTask) OnDeployGuestCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeployTask) OnDeployGuestFail ¶ 

func (self *GuestDeployTask) OnDeployGuestFail(ctx context.Context, guest *models.SGuest, err error)

func (*GuestDeployTask) OnDeployGuestSyncstatusComplete ¶ 

func (self *GuestDeployTask) OnDeployGuestSyncstatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeployTask) OnDeployGuestSyncstatusCompleteFailed ¶ 

func (self *GuestDeployTask) OnDeployGuestSyncstatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeployTask) OnDeployStartGuestComplete ¶ 

func (self *GuestDeployTask) OnDeployStartGuestComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeployTask) OnDeployStartGuestCompleteFailed ¶ 

func (self *GuestDeployTask) OnDeployStartGuestCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDeployTask) OnDeployWaitServerStop ¶ 

func (self *GuestDeployTask) OnDeployWaitServerStop(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDeployTask) OnGuestNetworkReady ¶ 

func (self *GuestDeployTask) OnGuestNetworkReady(ctx context.Context, guest *models.SGuest)

func (*GuestDeployTask) OnInit ¶ 

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

type GuestDetachAllDisksTask ¶ 

type GuestDetachAllDisksTask struct {
	SGuestBaseTask
}

func (*GuestDetachAllDisksTask) OnDiskDeleteComplete ¶ 

func (self *GuestDetachAllDisksTask) OnDiskDeleteComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDetachAllDisksTask) OnInit ¶ 

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

type GuestDetachDiskTask ¶ 

type GuestDetachDiskTask struct {
	SGuestBaseTask
}

func (*GuestDetachDiskTask) OnDetachDiskComplete ¶ 

func (self *GuestDetachDiskTask) OnDetachDiskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnDetachDiskCompleteFailed ¶ 

func (self *GuestDetachDiskTask) OnDetachDiskCompleteFailed(ctx context.Context, obj db.IStandaloneModel, reason jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnDiskDeleteComplete ¶ 

func (self *GuestDetachDiskTask) OnDiskDeleteComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnGetGuestStatus ¶ 

func (self *GuestDetachDiskTask) OnGetGuestStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnGetGuestStatusFailed ¶ 

func (self *GuestDetachDiskTask) OnGetGuestStatusFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnInit ¶ 

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

func (*GuestDetachDiskTask) OnSyncstatusComplete ¶ 

func (self *GuestDetachDiskTask) OnSyncstatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnSyncstatusCompleteFailed ¶ 

func (self *GuestDetachDiskTask) OnSyncstatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestDetachDiskTask) OnTaskFail ¶ 

func (self *GuestDetachDiskTask) OnTaskFail(ctx context.Context, guest *models.SGuest, disk *models.SDisk, err jsonutils.JSONObject)

type GuestDetachScalingGroupTask ¶ 

type GuestDetachScalingGroupTask struct {
	taskman.STask
}

func (*GuestDetachScalingGroupTask) OnDeleteGuestComplete ¶ 

func (self *GuestDetachScalingGroupTask) OnDeleteGuestComplete(ctx context.Context, sg *models.SScalingGroup, data jsonutils.JSONObject)

func (*GuestDetachScalingGroupTask) OnDeleteGuestCompleteFailed ¶ 

func (self *GuestDetachScalingGroupTask) OnDeleteGuestCompleteFailed(ctx context.Context, sg *models.SScalingGroup, data jsonutils.JSONObject)

func (*GuestDetachScalingGroupTask) OnDetachLoadbalancerComplete ¶ 

func (self *GuestDetachScalingGroupTask) OnDetachLoadbalancerComplete(ctx context.Context, sg *models.SScalingGroup, data jsonutils.JSONObject)

func (*GuestDetachScalingGroupTask) OnDetachLoadbalancerCompleteFailed ¶ 

func (self *GuestDetachScalingGroupTask) OnDetachLoadbalancerCompleteFailed(ctx context.Context, sg *models.SScalingGroup,
	data jsonutils.JSONObject)

func (*GuestDetachScalingGroupTask) OnInit ¶ 

func (self *GuestDetachScalingGroupTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type GuestDiskSnapshotTask ¶ 

type GuestDiskSnapshotTask struct {
	SGuestBaseTask
}

func (*GuestDiskSnapshotTask) DoDiskSnapshot ¶ 

func (self *GuestDiskSnapshotTask) DoDiskSnapshot(ctx context.Context, guest *models.SGuest)

func (*GuestDiskSnapshotTask) OnDiskSnapshotComplete ¶ 

func (self *GuestDiskSnapshotTask) OnDiskSnapshotComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDiskSnapshotTask) OnDiskSnapshotCompleteFailed ¶ 

func (self *GuestDiskSnapshotTask) OnDiskSnapshotCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*GuestDiskSnapshotTask) OnInit ¶ 

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

func (*GuestDiskSnapshotTask) TaskComplete ¶ 

func (self *GuestDiskSnapshotTask) TaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestDiskSnapshotTask) TaskFailed ¶ 

func (self *GuestDiskSnapshotTask) TaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestEjectISOTask ¶ 

type GuestEjectISOTask struct {
	SGuestBaseTask
}

func (*GuestEjectISOTask) OnConfigSyncComplete ¶ 

func (self *GuestEjectISOTask) OnConfigSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestEjectISOTask) OnInit ¶ 

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

type GuestEjectVFDTask ¶ 

type GuestEjectVFDTask struct {
	SGuestBaseTask
}

func (*GuestEjectVFDTask) OnConfigSyncComplete ¶ 

func (self *GuestEjectVFDTask) OnConfigSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestEjectVFDTask) OnInit ¶ 

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

type GuestHardResetTask ¶ 

type GuestHardResetTask struct {
	SGuestBaseTask
}

func (*GuestHardResetTask) OnInit ¶ 

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

func (*GuestHardResetTask) OnServerStartComplete ¶ 

func (self *GuestHardResetTask) OnServerStartComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestHardResetTask) OnServerStopComplete ¶ 

func (self *GuestHardResetTask) OnServerStopComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestHardResetTask) StartServer ¶ 

func (self *GuestHardResetTask) StartServer(ctx context.Context, guest *models.SGuest)

func (*GuestHardResetTask) StopServer ¶ 

func (self *GuestHardResetTask) StopServer(ctx context.Context, guest *models.SGuest)

type GuestInsertIsoTask ¶ 

type GuestInsertIsoTask struct {
	SGuestBaseTask
}

func (*GuestInsertIsoTask) OnConfigSyncComplete ¶ 

func (self *GuestInsertIsoTask) OnConfigSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestInsertIsoTask) OnInit ¶ 

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

func (*GuestInsertIsoTask) OnIsoPrepareComplete ¶ 

func (self *GuestInsertIsoTask) OnIsoPrepareComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestInsertIsoTask) OnIsoPrepareCompleteFailed ¶ 

func (self *GuestInsertIsoTask) OnIsoPrepareCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type GuestInsertVfdTask ¶ 

type GuestInsertVfdTask struct {
	SGuestBaseTask
}

func (*GuestInsertVfdTask) OnConfigSyncComplete ¶ 

func (self *GuestInsertVfdTask) OnConfigSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestInsertVfdTask) OnInit ¶ 

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

func (*GuestInsertVfdTask) OnVfdPrepareComplete ¶ 

func (self *GuestInsertVfdTask) OnVfdPrepareComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestInsertVfdTask) OnVfdPrepareCompleteFailed ¶ 

func (self *GuestInsertVfdTask) OnVfdPrepareCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type GuestIsolatedDeviceSyncTask ¶ 

type GuestIsolatedDeviceSyncTask struct {
	SGuestBaseTask
}

func (*GuestIsolatedDeviceSyncTask) OnInit ¶ 

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

func (*GuestIsolatedDeviceSyncTask) OnStartComplete ¶ 

func (self *GuestIsolatedDeviceSyncTask) OnStartComplete(ctx context.Context, obj *models.SGuest, data jsonutils.JSONObject)

func (*GuestIsolatedDeviceSyncTask) OnStartCompleteFailed ¶ 

func (self *GuestIsolatedDeviceSyncTask) OnStartCompleteFailed(ctx context.Context, obj *models.SGuest, data jsonutils.JSONObject)

func (*GuestIsolatedDeviceSyncTask) OnSyncConfigComplete ¶ 

func (self *GuestIsolatedDeviceSyncTask) OnSyncConfigComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestIsolatedDeviceSyncTask) OnSyncConfigCompleteFailed ¶ 

func (self *GuestIsolatedDeviceSyncTask) OnSyncConfigCompleteFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestLiveMigrateTask ¶ 

type GuestLiveMigrateTask struct {
	GuestMigrateTask
}

func (*GuestLiveMigrateTask) OnGuestSyncStatus ¶ 

func (task *GuestLiveMigrateTask) OnGuestSyncStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

Server live migrate complete

func (*GuestLiveMigrateTask) OnGuestUndeployed ¶ 

func (task *GuestLiveMigrateTask) OnGuestUndeployed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnGuestUndeployedFailed ¶ 

func (task *GuestLiveMigrateTask) OnGuestUndeployedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnLiveMigrateComplete ¶ 

func (task *GuestLiveMigrateTask) OnLiveMigrateComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnLiveMigrateCompleteFailed ¶ 

func (task *GuestLiveMigrateTask) OnLiveMigrateCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnResumeDestGuestComplete ¶ 

func (task *GuestLiveMigrateTask) OnResumeDestGuestComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnResumeDestGuestCompleteFailed ¶ 

func (task *GuestLiveMigrateTask) OnResumeDestGuestCompleteFailed(ctx context.Context,
	guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnResumeSourceGuestComplete ¶ 

func (task *GuestLiveMigrateTask) OnResumeSourceGuestComplete(ctx context.Context,
	guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnResumeSourceGuestCompleteFailed ¶ 

func (task *GuestLiveMigrateTask) OnResumeSourceGuestCompleteFailed(ctx context.Context,
	guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnStartDestComplete ¶ 

func (task *GuestLiveMigrateTask) OnStartDestComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnStartDestCompleteFailed ¶ 

func (task *GuestLiveMigrateTask) OnStartDestCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestLiveMigrateTask) OnUndeploySrcGuestComplete ¶ 

func (task *GuestLiveMigrateTask) OnUndeploySrcGuestComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestMigrateTask ¶ 

type GuestMigrateTask struct {
	SSchedTask
}

func (*GuestMigrateTask) GetSchedParams ¶ 

func (task *GuestMigrateTask) GetSchedParams() (*schedapi.ScheduleInput, error)

func (*GuestMigrateTask) OnCachedCdromComplete ¶ 

func (task *GuestMigrateTask) OnCachedCdromComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnCachedCdromCompleteFailed ¶ 

func (task *GuestMigrateTask) OnCachedCdromCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnCachedImageComplete ¶ 

func (task *GuestMigrateTask) OnCachedImageComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

For local storage get disk info

func (*GuestMigrateTask) OnCachedImageCompleteFailed ¶ 

func (task *GuestMigrateTask) OnCachedImageCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnGuestStartSucc ¶ 

func (task *GuestMigrateTask) OnGuestStartSucc(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnGuestStartSuccFailed ¶ 

func (task *GuestMigrateTask) OnGuestStartSuccFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnInit ¶ 

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

func (*GuestMigrateTask) OnMigrateConfAndDiskComplete ¶ 

func (task *GuestMigrateTask) OnMigrateConfAndDiskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnMigrateConfAndDiskCompleteFailed ¶ 

func (task *GuestMigrateTask) OnMigrateConfAndDiskCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnNormalMigrateComplete ¶ 

func (task *GuestMigrateTask) OnNormalMigrateComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnScheduleFailCallback ¶ 

func (task *GuestMigrateTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*GuestMigrateTask) OnScheduleFailed ¶ 

func (task *GuestMigrateTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*GuestMigrateTask) OnSrcPrepareComplete ¶ 

func (task *GuestMigrateTask) OnSrcPrepareComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnSrcPrepareCompleteFailed ¶ 

func (task *GuestMigrateTask) OnSrcPrepareCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnStartCacheImages ¶ 

func (task *GuestMigrateTask) OnStartCacheImages(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnStartCacheImagesFailed ¶ 

func (task *GuestMigrateTask) OnStartCacheImagesFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnStartSchedule ¶ 

func (task *GuestMigrateTask) OnStartSchedule(obj IScheduleModel)

func (*GuestMigrateTask) OnUndeployOldHostSucc ¶ 

func (task *GuestMigrateTask) OnUndeployOldHostSucc(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

Server migrate complete

func (*GuestMigrateTask) OnUndeployOldHostSuccFailed ¶ 

func (task *GuestMigrateTask) OnUndeployOldHostSuccFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnUndeployTargetGuestSucc ¶ 

func (task *GuestMigrateTask) OnUndeployTargetGuestSucc(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) OnUndeployTargetGuestSuccFailed ¶ 

func (task *GuestMigrateTask) OnUndeployTargetGuestSuccFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestMigrateTask) SaveScheduleResult ¶ 

func (task *GuestMigrateTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, target *schedapi.CandidateResource, index int)

func (*GuestMigrateTask) TaskComplete ¶ 

func (task *GuestMigrateTask) TaskComplete(ctx context.Context, guest *models.SGuest)

func (*GuestMigrateTask) TaskFailed ¶ 

func (task *GuestMigrateTask) TaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestOsInfo ¶ 

type GuestOsInfo struct {
	Id            string `json:"id"`
	KernelRelease string `json:"kernel-release"`
	KernelVersion string `json:"kernel-version"`
	Machine       string `json:"machine"`
	Name          string `json:"name"`
	PrettyName    string `json:"pretty-name"`
	Version       string `json:"version"`
	VersionId     string `json:"version-id"`
}

type GuestPublicipToEipTask ¶ 

type GuestPublicipToEipTask struct {
	taskman.STask
}

func (*GuestPublicipToEipTask) OnEipConvertComplete ¶ 

func (self *GuestPublicipToEipTask) OnEipConvertComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestPublicipToEipTask) OnEipConvertCompleteFailed ¶ 

func (self *GuestPublicipToEipTask) OnEipConvertCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestPublicipToEipTask) OnGuestStartSucc ¶ 

func (self *GuestPublicipToEipTask) OnGuestStartSucc(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestPublicipToEipTask) OnGuestStartSuccFailed ¶ 

func (self *GuestPublicipToEipTask) OnGuestStartSuccFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestPublicipToEipTask) OnGuestSyncstatusComplete ¶ 

func (self *GuestPublicipToEipTask) OnGuestSyncstatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestPublicipToEipTask) OnGuestSyncstatusCompleteFailed ¶ 

func (self *GuestPublicipToEipTask) OnGuestSyncstatusCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestPublicipToEipTask) OnInit ¶ 

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

type GuestQgaRestartNetworkTask ¶ 

type GuestQgaRestartNetworkTask struct {
	SGuestBaseTask
}

func (*GuestQgaRestartNetworkTask) OnInit ¶ 

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

func (*GuestQgaRestartNetworkTask) OnRestartNetwork ¶ 

func (self *GuestQgaRestartNetworkTask) OnRestartNetwork(ctx context.Context, guest *models.SGuest)

func (*GuestQgaRestartNetworkTask) OnSetNetwork ¶ 

func (self *GuestQgaRestartNetworkTask) OnSetNetwork(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestQgaRestartNetworkTask) OnSetNetworkFailed ¶ 

func (self *GuestQgaRestartNetworkTask) OnSetNetworkFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestQgaSetPasswordTask ¶ 

type GuestQgaSetPasswordTask struct {
	SGuestQgaBaseTask
}

func (*GuestQgaSetPasswordTask) OnInit ¶ 

func (self *GuestQgaSetPasswordTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*GuestQgaSetPasswordTask) OnQgaGuestPing ¶ 

func (self *GuestQgaSetPasswordTask) OnQgaGuestPing(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestQgaSetPasswordTask) OnQgaGuestPingFailed ¶ 

func (self *GuestQgaSetPasswordTask) OnQgaGuestPingFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestQgaSetPasswordTask) OnQgaSetUserPassword ¶ 

func (self *GuestQgaSetPasswordTask) OnQgaSetUserPassword(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestQgaSetPasswordTask) OnQgaSetUserPasswordFailed ¶ 

func (self *GuestQgaSetPasswordTask) OnQgaSetUserPasswordFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestQgaSyncOsInfoTask ¶ 

type GuestQgaSyncOsInfoTask struct {
	SGuestBaseTask
}

func (*GuestQgaSyncOsInfoTask) OnInit ¶ 

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

func (*GuestQgaSyncOsInfoTask) OnUpdateOsInfoComplete ¶ 

func (self *GuestQgaSyncOsInfoTask) OnUpdateOsInfoComplete(ctx context.Context, guest *models.SGuest, osInput api.ServerSetOSInfoInput)

type GuestReSyncToBackup ¶ 

type GuestReSyncToBackup struct {
	GuestStartAndSyncToBackupTask
}

func (*GuestReSyncToBackup) OnInit ¶ 

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

func (*GuestReSyncToBackup) StartSyncToBackup ¶ 

func (task *GuestReSyncToBackup) StartSyncToBackup(ctx context.Context, guest *models.SGuest)

type GuestRebuildRootTask ¶ 

type GuestRebuildRootTask struct {
	SGuestBaseTask
}

func (*GuestRebuildRootTask) OnGuestStartComplete ¶ 

func (self *GuestRebuildRootTask) OnGuestStartComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnInit ¶ 

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

func (*GuestRebuildRootTask) OnRebuildAllDisksComplete ¶ 

func (self *GuestRebuildRootTask) OnRebuildAllDisksComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnRebuildRootDiskComplete ¶ 

func (self *GuestRebuildRootTask) OnRebuildRootDiskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnRebuildRootDiskCompleteFailed ¶ 

func (self *GuestRebuildRootTask) OnRebuildRootDiskCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnRebuildingDataDisksComplete ¶ 

func (self *GuestRebuildRootTask) OnRebuildingDataDisksComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnRebuildingDataDisksCompleteFailed ¶ 

func (self *GuestRebuildRootTask) OnRebuildingDataDisksCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnStopServerComplete ¶ 

func (self *GuestRebuildRootTask) OnStopServerComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) OnSyncStatusComplete ¶ 

func (self *GuestRebuildRootTask) OnSyncStatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRebuildRootTask) StartRebuildRootDisk ¶ 

func (self *GuestRebuildRootTask) StartRebuildRootDisk(ctx context.Context, guest *models.SGuest)

type GuestRemoteUpdateTask ¶ 

type GuestRemoteUpdateTask struct {
	SGuestBaseTask
}

func (*GuestRemoteUpdateTask) OnInit ¶ 

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

func (*GuestRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *GuestRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *GuestRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *GuestRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *GuestRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestRenewTask ¶ 

type GuestRenewTask struct {
	SGuestBaseTask
}

func (*GuestRenewTask) OnInit ¶ 

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

type GuestResetNicTrafficsTask ¶ 

type GuestResetNicTrafficsTask struct {
	SGuestBaseTask
}

func (*GuestResetNicTrafficsTask) OnInit ¶ 

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

func (*GuestResetNicTrafficsTask) OnResetNicTrafficLimit ¶ 

func (self *GuestResetNicTrafficsTask) OnResetNicTrafficLimit(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestResizeDiskTask ¶ 

type GuestResizeDiskTask struct {
	SGuestBaseTask
}

func (*GuestResizeDiskTask) OnDiskResizeComplete ¶ 

func (task *GuestResizeDiskTask) OnDiskResizeComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestResizeDiskTask) OnDiskResizeCompleteFailed ¶ 

func (task *GuestResizeDiskTask) OnDiskResizeCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestResizeDiskTask) OnInit ¶ 

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

func (*GuestResizeDiskTask) OnTaskFailed ¶ 

func (task *GuestResizeDiskTask) OnTaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestResizeDiskTask) TaskComplete ¶ 

func (task *GuestResizeDiskTask) TaskComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestResizeDiskTask) TaskCompleteFailed ¶ 

func (task *GuestResizeDiskTask) TaskCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type GuestRestartNetworkTask ¶ 

type GuestRestartNetworkTask struct {
	SGuestBaseTask
}

func (*GuestRestartNetworkTask) OnCloseIpMacSrcCheckComplete ¶ 

func (self *GuestRestartNetworkTask) OnCloseIpMacSrcCheckComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestRestartNetworkTask) OnCloseIpMacSrcCheckCompleteFailed ¶ 

func (self *GuestRestartNetworkTask) OnCloseIpMacSrcCheckCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestRestartNetworkTask) OnInit ¶ 

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

func (*GuestRestartNetworkTask) OnResumeIpMacSrcCheckComplete ¶ 

func (self *GuestRestartNetworkTask) OnResumeIpMacSrcCheckComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestRestartNetworkTask) OnResumeIpMacSrcCheckCompleteFailed ¶ 

func (self *GuestRestartNetworkTask) OnResumeIpMacSrcCheckCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type GuestRestartTask ¶ 

type GuestRestartTask struct {
	GuestHardResetTask
}

func (*GuestRestartTask) StopServer ¶ 

func (self *GuestRestartTask) StopServer(ctx context.Context, guest *models.SGuest)

type GuestResumeTask ¶ 

type GuestResumeTask struct {
	SGuestBaseTask
}

func (*GuestResumeTask) OnInit ¶ 

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

func (*GuestResumeTask) OnResumeComplete ¶ 

func (self *GuestResumeTask) OnResumeComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestResumeTask) OnResumeCompleteFailed ¶ 

func (self *GuestResumeTask) OnResumeCompleteFailed(ctx context.Context, obj db.IStandaloneModel,
	err jsonutils.JSONObject)

func (*GuestResumeTask) OnResumeGuestFail ¶ 

func (self *GuestResumeTask) OnResumeGuestFail(guest *models.SGuest, reason string)

type GuestSaveGuestImageTask ¶ 

type GuestSaveGuestImageTask struct {
	SGuestBaseTask
}

func (*GuestSaveGuestImageTask) OnInit ¶ 

func (self *GuestSaveGuestImageTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*GuestSaveGuestImageTask) OnSaveRootImageComplete ¶ 

func (self *GuestSaveGuestImageTask) OnSaveRootImageComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveGuestImageTask) OnSaveRootImageCompleteFailed ¶ 

func (self *GuestSaveGuestImageTask) OnSaveRootImageCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveGuestImageTask) OnStartServerComplete ¶ 

func (self *GuestSaveGuestImageTask) OnStartServerComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveGuestImageTask) OnStartServerCompleteFailed ¶ 

func (self *GuestSaveGuestImageTask) OnStartServerCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestSaveImageTask ¶ 

type GuestSaveImageTask struct {
	SGuestBaseTask
}

func (*GuestSaveImageTask) OnInit ¶ 

func (self *GuestSaveImageTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*GuestSaveImageTask) OnSaveRootImageComplete ¶ 

func (self *GuestSaveImageTask) OnSaveRootImageComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveImageTask) OnSaveRootImageCompleteFailed ¶ 

func (self *GuestSaveImageTask) OnSaveRootImageCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveImageTask) OnStartServerComplete ¶ 

func (self *GuestSaveImageTask) OnStartServerComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveImageTask) OnStartServerCompleteFailed ¶ 

func (self *GuestSaveImageTask) OnStartServerCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveImageTask) OnStopServerComplete ¶ 

func (self *GuestSaveImageTask) OnStopServerComplete(ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject)

func (*GuestSaveImageTask) OnStopServerCompleteFailed ¶ 

func (self *GuestSaveImageTask) OnStopServerCompleteFailed(ctx context.Context, guest *models.SGuest, body jsonutils.JSONObject)

func (*GuestSaveImageTask) OnSyncstatusComplete ¶ 

func (self *GuestSaveImageTask) OnSyncstatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSaveImageTask) OnSyncstatusCompleteFailed ¶ 

func (self *GuestSaveImageTask) OnSyncstatusCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestSaveTemplateTask ¶ 

type GuestSaveTemplateTask struct {
	taskman.STask
}

func (*GuestSaveTemplateTask) OnInit ¶ 

func (self *GuestSaveTemplateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type GuestSchedStartTask ¶ 

type GuestSchedStartTask struct {
	SGuestBaseTask
}

func (*GuestSchedStartTask) OnGuestMigrate ¶ 

func (self *GuestSchedStartTask) OnGuestMigrate(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSchedStartTask) OnGuestMigrateFailed ¶ 

func (self *GuestSchedStartTask) OnGuestMigrateFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSchedStartTask) OnGuestStarted ¶ 

func (self *GuestSchedStartTask) OnGuestStarted(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSchedStartTask) OnGuestStartedFailed ¶ 

func (self *GuestSchedStartTask) OnGuestStartedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSchedStartTask) OnInit ¶ 

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

func (*GuestSchedStartTask) ScheduleFailed ¶ 

func (self *GuestSchedStartTask) ScheduleFailed(ctx context.Context, guest *models.SGuest, resetCpuNumaPin bool)

func (*GuestSchedStartTask) ScheduleSucc ¶ 

func (self *GuestSchedStartTask) ScheduleSucc(ctx context.Context, guest *models.SGuest)

func (*GuestSchedStartTask) StartScheduler ¶ 

func (self *GuestSchedStartTask) StartScheduler(ctx context.Context, guest *models.SGuest)

func (*GuestSchedStartTask) TaskFailed ¶ 

func (self *GuestSchedStartTask) TaskFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestSetAutoRenewTask ¶ 

type GuestSetAutoRenewTask struct {
	SGuestBaseTask
}

func (*GuestSetAutoRenewTask) OnGuestSyncstatusComplete ¶ 

func (self *GuestSetAutoRenewTask) OnGuestSyncstatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSetAutoRenewTask) OnGuestSyncstatusCompleteFailed ¶ 

func (self *GuestSetAutoRenewTask) OnGuestSyncstatusCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSetAutoRenewTask) OnInit ¶ 

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

func (*GuestSetAutoRenewTask) OnSetAutoRenewComplete ¶ 

func (self *GuestSetAutoRenewTask) OnSetAutoRenewComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSetAutoRenewTask) OnSetAutoRenewCompleteFailed ¶ 

func (self *GuestSetAutoRenewTask) OnSetAutoRenewCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestSetNicTrafficsTask ¶ 

type GuestSetNicTrafficsTask struct {
	SGuestBaseTask
}

func (*GuestSetNicTrafficsTask) OnInit ¶ 

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

func (*GuestSetNicTrafficsTask) OnSetNicTrafficLimit ¶ 

func (self *GuestSetNicTrafficsTask) OnSetNicTrafficLimit(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestSoftResetTask ¶ 

type GuestSoftResetTask struct {
	SGuestBaseTask
}

func (*GuestSoftResetTask) OnInit ¶ 

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

type GuestStartAndSyncToBackupTask ¶ 

type GuestStartAndSyncToBackupTask struct {
	SGuestBaseTask
}

func (*GuestStartAndSyncToBackupTask) OnCheckTemplete ¶ 

func (task *GuestStartAndSyncToBackupTask) OnCheckTemplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStartAndSyncToBackupTask) OnInit ¶ 

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

func (*GuestStartAndSyncToBackupTask) OnRequestSyncToBackup ¶ 

func (task *GuestStartAndSyncToBackupTask) OnRequestSyncToBackup(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStartAndSyncToBackupTask) OnRequestSyncToBackupFailed ¶ 

func (task *GuestStartAndSyncToBackupTask) OnRequestSyncToBackupFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStartAndSyncToBackupTask) OnStartBackupGuest ¶ 

func (task *GuestStartAndSyncToBackupTask) OnStartBackupGuest(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStartAndSyncToBackupTask) OnStartBackupGuestFailed ¶ 

func (task *GuestStartAndSyncToBackupTask) OnStartBackupGuestFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type GuestStartTask ¶ 

type GuestStartTask struct {
	SGuestBaseTask
}

func (*GuestStartTask) AttachReleasedDevices ¶ 

func (self *GuestStartTask) AttachReleasedDevices(ctx context.Context, guest *models.SGuest)

func (*GuestStartTask) OnInit ¶ 

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

func (*GuestStartTask) OnReleasedDevicesAttached ¶ 

func (self *GuestStartTask) OnReleasedDevicesAttached(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStartTask) OnReleasedDevicesFailed ¶ 

func (self *GuestStartTask) OnReleasedDevicesFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStartTask) OnStartComplete ¶ 

func (task *GuestStartTask) OnStartComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestStartTask) OnStartCompleteFailed ¶ 

func (self *GuestStartTask) OnStartCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestStartTask) RequestStart ¶ 

func (self *GuestStartTask) RequestStart(ctx context.Context, guest *models.SGuest)

type GuestStopAndFreezeTask ¶ 

type GuestStopAndFreezeTask struct {
	SGuestBaseTask
}

func (*GuestStopAndFreezeTask) OnInit ¶ 

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

func (*GuestStopAndFreezeTask) OnStopGuest ¶ 

func (self *GuestStopAndFreezeTask) OnStopGuest(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStopAndFreezeTask) OnStopGuestFailed ¶ 

func (self *GuestStopAndFreezeTask) OnStopGuestFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestStopAndFreezeTask) OnSyncStatus ¶ 

func (self *GuestStopAndFreezeTask) OnSyncStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStopAndFreezeTask) OnSyncStatusFailed ¶ 

func (self *GuestStopAndFreezeTask) OnSyncStatusFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

type GuestStopTask ¶ 

type GuestStopTask struct {
	SGuestBaseTask
}

func (*GuestStopTask) OnDevicesReleaseFailed ¶ 

func (self *GuestStopTask) OnDevicesReleaseFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestStopTask) OnDevicesReleased ¶ 

func (self *GuestStopTask) OnDevicesReleased(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStopTask) OnGuestStopTaskComplete ¶ 

func (self *GuestStopTask) OnGuestStopTaskComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestStopTask) OnGuestStopTaskCompleteFailed ¶ 

func (self *GuestStopTask) OnGuestStopTaskCompleteFailed(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestStopTask) OnInit ¶ 

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

type GuestSuspendTask ¶ 

type GuestSuspendTask struct {
	SGuestBaseTask
}

func (*GuestSuspendTask) OnInit ¶ 

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

func (*GuestSuspendTask) OnSuspendComplete ¶ 

func (self *GuestSuspendTask) OnSuspendComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestSuspendTask) OnSuspendCompleteFailed ¶ 

func (self *GuestSuspendTask) OnSuspendCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestSuspendTask) OnSuspendGuestFail ¶ 

func (self *GuestSuspendTask) OnSuspendGuestFail(guest *models.SGuest, reason string)

type GuestSwitchToBackupTask ¶ 

type GuestSwitchToBackupTask struct {
	SGuestBaseTask
}

func (*GuestSwitchToBackupTask) OnBackupGuestStoped ¶ 

func (task *GuestSwitchToBackupTask) OnBackupGuestStoped(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSwitchToBackupTask) OnComplete ¶ 

func (task *GuestSwitchToBackupTask) OnComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSwitchToBackupTask) OnEnsureMasterGuestStoped ¶ 

func (task *GuestSwitchToBackupTask) OnEnsureMasterGuestStoped(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSwitchToBackupTask) OnFail ¶ 

func (task *GuestSwitchToBackupTask) OnFail(ctx context.Context, guest *models.SGuest, reason jsonutils.JSONObject)

func (*GuestSwitchToBackupTask) OnGuestStartCompleted ¶ 

func (task *GuestSwitchToBackupTask) OnGuestStartCompleted(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSwitchToBackupTask) OnGuestStartCompletedFailed ¶ 

func (task *GuestSwitchToBackupTask) OnGuestStartCompletedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSwitchToBackupTask) OnInit ¶ 

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

0. ensure master guest stopped 1. stop backup guest 2. switch guest master host to backup host 3. start guest with new master

type GuestSyncConfTask ¶ 

type GuestSyncConfTask struct {
	SGuestBaseTask
}

func (*GuestSyncConfTask) OnDiskSyncComplete ¶ 

func (self *GuestSyncConfTask) OnDiskSyncComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSyncConfTask) OnDiskSyncCompleteFailed ¶ 

func (self *GuestSyncConfTask) OnDiskSyncCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestSyncConfTask) OnInit ¶ 

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

func (*GuestSyncConfTask) OnSyncComplete ¶ 

func (self *GuestSyncConfTask) OnSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestSyncConfTask) OnSyncCompleteFailed ¶ 

func (self *GuestSyncConfTask) OnSyncCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestSyncConfTask) OnSyncStatusComplete ¶ 

func (self *GuestSyncConfTask) OnSyncStatusComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSyncConfTask) OnSyncStatusCompleteFailed ¶ 

func (self *GuestSyncConfTask) OnSyncStatusCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestSyncConfTask) StartRestartNetworkTask ¶ 

func (self *GuestSyncConfTask) StartRestartNetworkTask(ctx context.Context, guest *models.SGuest)

type GuestSyncstatusTask ¶ 

type GuestSyncstatusTask struct {
	SGuestBaseTask
}

func (*GuestSyncstatusTask) OnGetStatusComplete ¶ 

func (self *GuestSyncstatusTask) OnGetStatusComplete(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*GuestSyncstatusTask) OnGetStatusCompleteFailed ¶ 

func (self *GuestSyncstatusTask) OnGetStatusCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*GuestSyncstatusTask) OnInit ¶ 

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

type GuestUndeployTask ¶ 

type GuestUndeployTask struct {
	SGuestBaseTask
}

func (*GuestUndeployTask) OnGuestUndeployComplete ¶ 

func (self *GuestUndeployTask) OnGuestUndeployComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*GuestUndeployTask) OnInit ¶ 

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

func (*GuestUndeployTask) OnMasterHostUndeployGuestComplete ¶ 

func (self *GuestUndeployTask) OnMasterHostUndeployGuestComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*GuestUndeployTask) OnStartDeleteGuestFail ¶ 

func (self *GuestUndeployTask) OnStartDeleteGuestFail(ctx context.Context, err error)

type HADiskCreateTask ¶ 

type HADiskCreateTask struct {
	DiskCreateTask
}

func (*HADiskCreateTask) OnBackupAllocateFailed ¶ 

func (self *HADiskCreateTask) OnBackupAllocateFailed(ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject)

func (*HADiskCreateTask) OnBackupStorageCacheImageComplete ¶ 

func (self *HADiskCreateTask) OnBackupStorageCacheImageComplete(
	ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject,
)

func (*HADiskCreateTask) OnDiskReady ¶ 

func (self *HADiskCreateTask) OnDiskReady(
	ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject,
)

func (*HADiskCreateTask) OnSlaveDiskReady ¶ 

func (self *HADiskCreateTask) OnSlaveDiskReady(
	ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject,
)

func (*HADiskCreateTask) OnStorageCacheImageComplete ¶ 

func (self *HADiskCreateTask) OnStorageCacheImageComplete(
	ctx context.Context, disk *models.SDisk, data jsonutils.JSONObject,
)

type HAGuestDeployTask ¶ 

type HAGuestDeployTask struct {
	GuestDeployTask
}

func (*HAGuestDeployTask) DeployBackup ¶ 

func (self *HAGuestDeployTask) DeployBackup(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*HAGuestDeployTask) OnDeploySlaveGuestComplete ¶ 

func (self *HAGuestDeployTask) OnDeploySlaveGuestComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestDeployTask) OnDeploySlaveGuestCompleteFailed ¶ 

func (self *HAGuestDeployTask) OnDeploySlaveGuestCompleteFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestDeployTask) OnDeployWaitServerStop ¶ 

func (self *HAGuestDeployTask) OnDeployWaitServerStop(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

type HAGuestStartTask ¶ 

type HAGuestStartTask struct {
	GuestStartTask
}

func (*HAGuestStartTask) OnBackupGuestStopComplete ¶ 

func (self *HAGuestStartTask) OnBackupGuestStopComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestStartTask) OnBackupGuestStopCompleteFailed ¶ 

func (self *HAGuestStartTask) OnBackupGuestStopCompleteFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestStartTask) OnInit ¶ 

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

func (*HAGuestStartTask) OnStartBackupGuestComplete ¶ 

func (self *HAGuestStartTask) OnStartBackupGuestComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestStartTask) OnStartBackupGuestCompleteFailed ¶ 

func (self *HAGuestStartTask) OnStartBackupGuestCompleteFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestStartTask) OnStartComplete ¶ 

func (self *HAGuestStartTask) OnStartComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*HAGuestStartTask) RequestStartBacking ¶ 

func (self *HAGuestStartTask) RequestStartBacking(ctx context.Context, guest *models.SGuest)

func (*HAGuestStartTask) RequestStopBackupGuest ¶ 

func (self *HAGuestStartTask) RequestStopBackupGuest(ctx context.Context, guest *models.SGuest)

type HAGuestStopTask ¶ 

type HAGuestStopTask struct {
	GuestStopTask
}

func (*HAGuestStopTask) OnGuestStopTaskComplete ¶ 

func (self *HAGuestStopTask) OnGuestStopTaskComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestStopTask) OnSlaveGuestStopTaskComplete ¶ 

func (self *HAGuestStopTask) OnSlaveGuestStopTaskComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HAGuestStopTask) OnSlaveGuestStopTaskCompleteFailed ¶ 

func (self *HAGuestStopTask) OnSlaveGuestStopTaskCompleteFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

type HaGuestInsertIsoTask ¶ 

type HaGuestInsertIsoTask struct {
	GuestInsertIsoTask
}

func (*HaGuestInsertIsoTask) OnBackupIsoPrepareComplete ¶ 

func (self *HaGuestInsertIsoTask) OnBackupIsoPrepareComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HaGuestInsertIsoTask) OnBackupIsoPrepareCompleteFailed ¶ 

func (self *HaGuestInsertIsoTask) OnBackupIsoPrepareCompleteFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HaGuestInsertIsoTask) OnInit ¶ 

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

type HaGuestInsertVfdTask ¶ 

type HaGuestInsertVfdTask struct {
	GuestInsertVfdTask
}

func (*HaGuestInsertVfdTask) OnBackupVfdPrepareComplete ¶ 

func (self *HaGuestInsertVfdTask) OnBackupVfdPrepareComplete(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HaGuestInsertVfdTask) OnBackupVfdPrepareCompleteFailed ¶ 

func (self *HaGuestInsertVfdTask) OnBackupVfdPrepareCompleteFailed(
	ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject,
)

func (*HaGuestInsertVfdTask) OnInit ¶ 

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

type HostGuestsMigrateTask ¶ 

type HostGuestsMigrateTask struct {
	taskman.STask
}

func (*HostGuestsMigrateTask) OnInit ¶ 

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

func (*HostGuestsMigrateTask) OnMigrateComplete ¶ 

func (self *HostGuestsMigrateTask) OnMigrateComplete(ctx context.Context, objs []db.IStandaloneModel, data jsonutils.JSONObject)

func (*HostGuestsMigrateTask) OnMigrateCompleteFailed ¶ 

func (self *HostGuestsMigrateTask) OnMigrateCompleteFailed(ctx context.Context, objs []db.IStandaloneModel, data jsonutils.JSONObject)

type HostImportLibvirtServersTask ¶ 

type HostImportLibvirtServersTask struct {
	taskman.STask
}

func (*HostImportLibvirtServersTask) CreateImportedLibvirtGuestOnHost ¶ 

func (self *HostImportLibvirtServersTask) CreateImportedLibvirtGuestOnHost(
	ctx context.Context, host *models.SHost, guest *models.SGuest, guestDesc *compute.SImportGuestDesc,
) error

Create sub task to create guest on host, and feedback disk real access path

func (*HostImportLibvirtServersTask) FillLibvirtGuestDesc ¶ 

func (self *HostImportLibvirtServersTask) FillLibvirtGuestDesc(
	ctx context.Context, host *models.SHost, guestDesc *compute.SImportGuestDesc,
) error

func (*HostImportLibvirtServersTask) OnInit ¶ 

func (self *HostImportLibvirtServersTask) OnInit(
	ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject,
)

func (*HostImportLibvirtServersTask) OnRequestHostPrepareImport ¶ 

func (self *HostImportLibvirtServersTask) OnRequestHostPrepareImport(
	ctx context.Context, host *models.SHost, body jsonutils.JSONObject,
)

func (*HostImportLibvirtServersTask) RequestHostPrepareImport ¶ 

func (self *HostImportLibvirtServersTask) RequestHostPrepareImport(
	ctx context.Context, host *models.SHost,
)

func (*HostImportLibvirtServersTask) StartImportServers ¶ 

func (self *HostImportLibvirtServersTask) StartImportServers(
	ctx context.Context, host *models.SHost, guestsDesc []compute.SImportGuestDesc,
)

func (*HostImportLibvirtServersTask) TaskFailed ¶ 

func (self *HostImportLibvirtServersTask) TaskFailed(
	ctx context.Context, host *models.SHost, reason jsonutils.JSONObject,
)

type HostMaintainTask ¶ 

type HostMaintainTask struct {
	taskman.STask
}

func (*HostMaintainTask) OnGuestsMigrate ¶ 

func (self *HostMaintainTask) OnGuestsMigrate(ctx context.Context, host *models.SHost, data jsonutils.JSONObject)

func (*HostMaintainTask) OnGuestsMigrateFailed ¶ 

func (self *HostMaintainTask) OnGuestsMigrateFailed(ctx context.Context, host *models.SHost, data jsonutils.JSONObject)

func (*HostMaintainTask) OnInit ¶ 

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

func (*HostMaintainTask) TaskFailed ¶ 

func (self *HostMaintainTask) TaskFailed(ctx context.Context, host *models.SHost, reason jsonutils.JSONObject)

type HostStorageAttachTask ¶ 

type HostStorageAttachTask struct {
	taskman.STask
}

func (*HostStorageAttachTask) OnAttachStorageComplete ¶ 

func (self *HostStorageAttachTask) OnAttachStorageComplete(ctx context.Context, host *models.SHost, data jsonutils.JSONObject)

func (*HostStorageAttachTask) OnAttachStorageCompleteFailed ¶ 

func (self *HostStorageAttachTask) OnAttachStorageCompleteFailed(ctx context.Context, host *models.SHost, reason jsonutils.JSONObject)

func (*HostStorageAttachTask) OnInit ¶ 

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

type HostStorageDetachTask ¶ 

type HostStorageDetachTask struct {
	taskman.STask
}

func (*HostStorageDetachTask) OnDetachStorageComplete ¶ 

func (self *HostStorageDetachTask) OnDetachStorageComplete(ctx context.Context, host *models.SHost, data jsonutils.JSONObject)

func (*HostStorageDetachTask) OnDetachStorageCompleteFailed ¶ 

func (self *HostStorageDetachTask) OnDetachStorageCompleteFailed(ctx context.Context, host *models.SHost, reason jsonutils.JSONObject)

func (*HostStorageDetachTask) OnInit ¶ 

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

type HostSyncTask ¶ 

type HostSyncTask struct {
	taskman.STask
}

func (*HostSyncTask) OnInit ¶ 

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

type IScheduleModel ¶ 

type IScheduleModel interface {
	db.IStandaloneModel

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

type IScheduleTask ¶ 

type IScheduleTask interface {
	GetUserCred() mcclient.TokenCredential
	GetSchedParams() (*schedapi.ScheduleInput, error)
	GetPendingUsage(quota quotas.IQuota, index int) error
	SetStage(stageName string, data *jsonutils.JSONDict) error
	SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

	OnStartSchedule(obj IScheduleModel)
	OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)
	// OnScheduleComplete(ctx context.Context, items []db.IStandaloneModel, data *jsonutils.JSONDict)
	SaveScheduleResult(ctx context.Context, obj IScheduleModel, candidate *schedapi.CandidateResource, index int)
	SaveScheduleResultWithBackup(ctx context.Context, obj IScheduleModel, master, slave *schedapi.CandidateResource, index int)
	OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)
}

type InstanceBackupCreateTask ¶ 

type InstanceBackupCreateTask struct {
	taskman.STask
}

func (*InstanceBackupCreateTask) OnInit ¶ 

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

func (*InstanceBackupCreateTask) OnInstanceBackup ¶ 

func (self *InstanceBackupCreateTask) OnInstanceBackup(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupCreateTask) OnInstanceBackupFailed ¶ 

func (self *InstanceBackupCreateTask) OnInstanceBackupFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupCreateTask) OnKvmDisksSnapshot ¶ 

func (self *InstanceBackupCreateTask) OnKvmDisksSnapshot(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupCreateTask) OnKvmDisksSnapshotFailed ¶ 

func (self *InstanceBackupCreateTask) OnKvmDisksSnapshotFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

type InstanceBackupDeleteTask ¶ 

type InstanceBackupDeleteTask struct {
	taskman.STask
}

func (*InstanceBackupDeleteTask) OnInit ¶ 

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

func (*InstanceBackupDeleteTask) OnInstanceBackupDelete ¶ 

func (self *InstanceBackupDeleteTask) OnInstanceBackupDelete(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupDeleteTask) OnInstanceBackupDeleteFailed ¶ 

func (self *InstanceBackupDeleteTask) OnInstanceBackupDeleteFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupDeleteTask) OnKvmDiskBackupDelete ¶ 

func (self *InstanceBackupDeleteTask) OnKvmDiskBackupDelete(
	ctx context.Context, isp *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupDeleteTask) OnKvmDiskBackupDeleteFailed ¶ 

func (self *InstanceBackupDeleteTask) OnKvmDiskBackupDeleteFailed(
	ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

type InstanceBackupPackTask ¶ 

type InstanceBackupPackTask struct {
	taskman.STask
}

func (*InstanceBackupPackTask) OnInit ¶ 

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

func (*InstanceBackupPackTask) OnPackComplete ¶ 

func (self *InstanceBackupPackTask) OnPackComplete(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupPackTask) OnPackCompleteFailed ¶ 

func (self *InstanceBackupPackTask) OnPackCompleteFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

type InstanceBackupRecoveryTask ¶ 

type InstanceBackupRecoveryTask struct {
	taskman.STask
}

func (*InstanceBackupRecoveryTask) OnCreateGuest ¶ 

func (self *InstanceBackupRecoveryTask) OnCreateGuest(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupRecoveryTask) OnCreateGuestFailed ¶ 

func (self *InstanceBackupRecoveryTask) OnCreateGuestFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupRecoveryTask) OnInit ¶ 

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

type InstanceBackupSyncstatusTask ¶ 

type InstanceBackupSyncstatusTask struct {
	taskman.STask
}

func (*InstanceBackupSyncstatusTask) OnInit ¶ 

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

func (*InstanceBackupSyncstatusTask) OnInstnaceBackupSyncstatus ¶ 

func (self *InstanceBackupSyncstatusTask) OnInstnaceBackupSyncstatus(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupSyncstatusTask) OnInstnaceBackupSyncstatusFailed ¶ 

func (self *InstanceBackupSyncstatusTask) OnInstnaceBackupSyncstatusFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupSyncstatusTask) OnKvmBackupSyncstatus ¶ 

func (self *InstanceBackupSyncstatusTask) OnKvmBackupSyncstatus(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupSyncstatusTask) OnKvmBackupSyncstatusFailed ¶ 

func (self *InstanceBackupSyncstatusTask) OnKvmBackupSyncstatusFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

type InstanceBackupUnpackTask ¶ 

type InstanceBackupUnpackTask struct {
	taskman.STask
}

func (*InstanceBackupUnpackTask) OnInit ¶ 

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

func (*InstanceBackupUnpackTask) OnUnpackComplete ¶ 

func (self *InstanceBackupUnpackTask) OnUnpackComplete(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupUnpackTask) OnUnpackCompleteFailed ¶ 

func (self *InstanceBackupUnpackTask) OnUnpackCompleteFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupUnpackTask) OnUnpackMetadata ¶ 

func (self *InstanceBackupUnpackTask) OnUnpackMetadata(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupUnpackTask) OnUnpackMetadataFailed ¶ 

func (self *InstanceBackupUnpackTask) OnUnpackMetadataFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

type InstanceSnapshotAndCloneTask ¶ 

type InstanceSnapshotAndCloneTask struct {
	taskman.STask
}

func (*InstanceSnapshotAndCloneTask) OnCreateInstanceSnapshot ¶ 

func (self *InstanceSnapshotAndCloneTask) OnCreateInstanceSnapshot(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotAndCloneTask) OnCreateInstanceSnapshotFailed ¶ 

func (self *InstanceSnapshotAndCloneTask) OnCreateInstanceSnapshotFailed(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotAndCloneTask) OnInit ¶ 

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

func (*InstanceSnapshotAndCloneTask) SetStageFailed ¶ 

func (self *InstanceSnapshotAndCloneTask) SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

type InstanceSnapshotCreateTask ¶ 

type InstanceSnapshotCreateTask struct {
	taskman.STask
}

func (*InstanceSnapshotCreateTask) OnInit ¶ 

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

func (*InstanceSnapshotCreateTask) OnInstanceSnapshot ¶ 

func (self *InstanceSnapshotCreateTask) OnInstanceSnapshot(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotCreateTask) OnInstanceSnapshotFailed ¶ 

func (self *InstanceSnapshotCreateTask) OnInstanceSnapshotFailed(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotCreateTask) OnKvmDiskSnapshot ¶ 

func (self *InstanceSnapshotCreateTask) OnKvmDiskSnapshot(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotCreateTask) OnKvmDiskSnapshotFailed ¶ 

func (self *InstanceSnapshotCreateTask) OnKvmDiskSnapshotFailed(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotCreateTask) SetStageFailed ¶ 

func (self *InstanceSnapshotCreateTask) SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

type InstanceSnapshotDeleteTask ¶ 

type InstanceSnapshotDeleteTask struct {
	taskman.STask
}

func (*InstanceSnapshotDeleteTask) OnInit ¶ 

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

func (*InstanceSnapshotDeleteTask) OnInstanceSnapshotDelete ¶ 

func (self *InstanceSnapshotDeleteTask) OnInstanceSnapshotDelete(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotDeleteTask) OnInstanceSnapshotDeleteFailed ¶ 

func (self *InstanceSnapshotDeleteTask) OnInstanceSnapshotDeleteFailed(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotDeleteTask) OnKvmSnapshotDelete ¶ 

func (self *InstanceSnapshotDeleteTask) OnKvmSnapshotDelete(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotDeleteTask) OnKvmSnapshotDeleteFailed ¶ 

func (self *InstanceSnapshotDeleteTask) OnKvmSnapshotDeleteFailed(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

type InstanceSnapshotResetTask ¶ 

type InstanceSnapshotResetTask struct {
	taskman.STask
}

func (*InstanceSnapshotResetTask) OnGuestStartComplete ¶ 

func (self *InstanceSnapshotResetTask) OnGuestStartComplete(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotResetTask) OnInit ¶ 

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

func (*InstanceSnapshotResetTask) OnInstanceSnapshotReset ¶ 

func (self *InstanceSnapshotResetTask) OnInstanceSnapshotReset(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotResetTask) OnInstanceSnapshotResetFailed ¶ 

func (self *InstanceSnapshotResetTask) OnInstanceSnapshotResetFailed(ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotResetTask) OnKvmDiskReset ¶ 

func (self *InstanceSnapshotResetTask) OnKvmDiskReset(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

func (*InstanceSnapshotResetTask) OnKvmDiskResetFailed ¶ 

func (self *InstanceSnapshotResetTask) OnKvmDiskResetFailed(
	ctx context.Context, isp *models.SInstanceSnapshot, data jsonutils.JSONObject)

type InterVpcNetworkAddVpcTask ¶ 

type InterVpcNetworkAddVpcTask struct {
	taskman.STask
}

func (*InterVpcNetworkAddVpcTask) OnInit ¶ 

func (self *InterVpcNetworkAddVpcTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*InterVpcNetworkAddVpcTask) OnSyncInterVpcNetworkComplete ¶ 

func (self *InterVpcNetworkAddVpcTask) OnSyncInterVpcNetworkComplete(ctx context.Context, network *models.SInterVpcNetwork, data jsonutils.JSONObject)

func (*InterVpcNetworkAddVpcTask) OnSyncInterVpcNetworkCompleteFailed ¶ 

func (self *InterVpcNetworkAddVpcTask) OnSyncInterVpcNetworkCompleteFailed(ctx context.Context, network *models.SInterVpcNetwork, data jsonutils.JSONObject)

type InterVpcNetworkCreateTask ¶ 

type InterVpcNetworkCreateTask struct {
	taskman.STask
}

func (*InterVpcNetworkCreateTask) OnInit ¶ 

func (self *InterVpcNetworkCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type InterVpcNetworkDeleteTask ¶ 

type InterVpcNetworkDeleteTask struct {
	taskman.STask
}

func (*InterVpcNetworkDeleteTask) OnInit ¶ 

func (self *InterVpcNetworkDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type InterVpcNetworkRemoveVpcTask ¶ 

type InterVpcNetworkRemoveVpcTask struct {
	taskman.STask
}

func (*InterVpcNetworkRemoveVpcTask) OnInit ¶ 

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

func (*InterVpcNetworkRemoveVpcTask) OnSyncInterVpcNetworkComplete ¶ 

func (self *InterVpcNetworkRemoveVpcTask) OnSyncInterVpcNetworkComplete(ctx context.Context, network *models.SInterVpcNetwork, data jsonutils.JSONObject)

func (*InterVpcNetworkRemoveVpcTask) OnSyncInterVpcNetworkCompleteFailed ¶ 

func (self *InterVpcNetworkRemoveVpcTask) OnSyncInterVpcNetworkCompleteFailed(ctx context.Context, network *models.SInterVpcNetwork, data jsonutils.JSONObject)

type InterVpcNetworkSyncstatusTask ¶ 

type InterVpcNetworkSyncstatusTask struct {
	taskman.STask
}

func (*InterVpcNetworkSyncstatusTask) OnInit ¶ 

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

type InterVpcNetworkUpdateRoutesetTask ¶ 

type InterVpcNetworkUpdateRoutesetTask struct {
	taskman.STask
}

func (*InterVpcNetworkUpdateRoutesetTask) OnInit ¶ 

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

func (*InterVpcNetworkUpdateRoutesetTask) OnSyncInterVpcNetworkComplete ¶ 

func (self *InterVpcNetworkUpdateRoutesetTask) OnSyncInterVpcNetworkComplete(ctx context.Context, network *models.SInterVpcNetwork, data jsonutils.JSONObject)

func (*InterVpcNetworkUpdateRoutesetTask) OnSyncInterVpcNetworkCompleteFailed ¶ 

func (self *InterVpcNetworkUpdateRoutesetTask) OnSyncInterVpcNetworkCompleteFailed(ctx context.Context, network *models.SInterVpcNetwork, data jsonutils.JSONObject)

type KVMGuestCreateDiskTask ¶ 

type KVMGuestCreateDiskTask struct {
	SGuestCreateDiskBaseTask
}

func (*KVMGuestCreateDiskTask) OnConfigSyncComplete ¶ 

func (self *KVMGuestCreateDiskTask) OnConfigSyncComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*KVMGuestCreateDiskTask) OnInit ¶ 

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

func (*KVMGuestCreateDiskTask) OnKvmDiskPrepared ¶ 

func (self *KVMGuestCreateDiskTask) OnKvmDiskPrepared(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type KVMGuestRebuildRootTask ¶ 

type KVMGuestRebuildRootTask struct {
	SGuestBaseTask
}

func (*KVMGuestRebuildRootTask) OnGuestDeployComplete ¶ 

func (self *KVMGuestRebuildRootTask) OnGuestDeployComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*KVMGuestRebuildRootTask) OnGuestDeployCompleteFailed ¶ 

func (self *KVMGuestRebuildRootTask) OnGuestDeployCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*KVMGuestRebuildRootTask) OnInit ¶ 

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

func (*KVMGuestRebuildRootTask) OnRebuildRootDiskComplete ¶ 

func (self *KVMGuestRebuildRootTask) OnRebuildRootDiskComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*KVMGuestRebuildRootTask) OnRebuildRootDiskCompleteFailed ¶ 

func (self *KVMGuestRebuildRootTask) OnRebuildRootDiskCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type KafkaDeleteTask ¶ 

type KafkaDeleteTask struct {
	taskman.STask
}

func (*KafkaDeleteTask) OnInit ¶ 

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

type KafkaRemoteUpdateTask ¶ 

type KafkaRemoteUpdateTask struct {
	taskman.STask
}

func (*KafkaRemoteUpdateTask) OnInit ¶ 

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

func (*KafkaRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *KafkaRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, kafka *models.SKafka, data jsonutils.JSONObject)

func (*KafkaRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *KafkaRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, kafka *models.SKafka, data jsonutils.JSONObject)

func (*KafkaRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *KafkaRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, kafka *models.SKafka, data jsonutils.JSONObject)

func (*KafkaRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *KafkaRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, kafka *models.SKafka, data jsonutils.JSONObject)

type KafkaSyncstatusTask ¶ 

type KafkaSyncstatusTask struct {
	taskman.STask
}

func (*KafkaSyncstatusTask) OnInit ¶ 

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

type KubeClusterCreateTask ¶ 

type KubeClusterCreateTask struct {
	taskman.STask
}

func (*KubeClusterCreateTask) OnInit ¶ 

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

func (*KubeClusterCreateTask) OnKubeClusterCreateComplate ¶ 

func (self *KubeClusterCreateTask) OnKubeClusterCreateComplate(ctx context.Context, cluster *models.SKubeCluster, data jsonutils.JSONObject)

func (*KubeClusterCreateTask) OnKubeClusterCreateComplateFailed ¶ 

func (self *KubeClusterCreateTask) OnKubeClusterCreateComplateFailed(ctx context.Context, cluster *models.SKubeCluster, reason jsonutils.JSONObject)

type KubeClusterDeleteTask ¶ 

type KubeClusterDeleteTask struct {
	taskman.STask
}

func (*KubeClusterDeleteTask) OnInit ¶ 

func (self *KubeClusterDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type KubeClusterSyncstatusTask ¶ 

type KubeClusterSyncstatusTask struct {
	taskman.STask
}

func (*KubeClusterSyncstatusTask) OnInit ¶ 

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

type KubeNodePoolCreateTask ¶ 

type KubeNodePoolCreateTask struct {
	taskman.STask
}

func (*KubeNodePoolCreateTask) OnInit ¶ 

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

func (*KubeNodePoolCreateTask) OnKubeNodePoolCreateComplate ¶ 

func (self *KubeNodePoolCreateTask) OnKubeNodePoolCreateComplate(ctx context.Context, pool *models.SKubeNodePool, data jsonutils.JSONObject)

func (*KubeNodePoolCreateTask) OnKubeNodePoolCreateComplateFailed ¶ 

func (self *KubeNodePoolCreateTask) OnKubeNodePoolCreateComplateFailed(ctx context.Context, pool *models.SKubeNodePool, reason jsonutils.JSONObject)

type KubeNodePoolDeleteTask ¶ 

type KubeNodePoolDeleteTask struct {
	taskman.STask
}

func (*KubeNodePoolDeleteTask) OnInit ¶ 

func (self *KubeNodePoolDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type KubeNodePoolSyncstatusTask ¶ 

type KubeNodePoolSyncstatusTask struct {
	taskman.STask
}

func (*KubeNodePoolSyncstatusTask) OnInit ¶ 

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

type LoadbalancerAclCreateTask ¶ 

type LoadbalancerAclCreateTask struct {
	taskman.STask
}

func (*LoadbalancerAclCreateTask) OnInit ¶ 

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

func (*LoadbalancerAclCreateTask) OnLoadbalancerAclCreateComplete ¶ 

func (self *LoadbalancerAclCreateTask) OnLoadbalancerAclCreateComplete(ctx context.Context, lbacl *models.SLoadbalancerAcl, data jsonutils.JSONObject)

func (*LoadbalancerAclCreateTask) OnLoadbalancerAclCreateCompleteFailed ¶ 

func (self *LoadbalancerAclCreateTask) OnLoadbalancerAclCreateCompleteFailed(ctx context.Context, lbacl *models.SLoadbalancerAcl, reason jsonutils.JSONObject)

type LoadbalancerAclDeleteTask ¶ 

type LoadbalancerAclDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerAclDeleteTask) OnInit ¶ 

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

func (*LoadbalancerAclDeleteTask) OnLoadbalancerAclDeleteComplete ¶ 

func (self *LoadbalancerAclDeleteTask) OnLoadbalancerAclDeleteComplete(ctx context.Context, lbacl *models.SLoadbalancerAcl, data jsonutils.JSONObject)

func (*LoadbalancerAclDeleteTask) OnLoadbalancerAclDeleteCompleteFailed ¶ 

func (self *LoadbalancerAclDeleteTask) OnLoadbalancerAclDeleteCompleteFailed(ctx context.Context, lbacl *models.SLoadbalancerAcl, reason jsonutils.JSONObject)

type LoadbalancerAclSyncstatusTask ¶ 

type LoadbalancerAclSyncstatusTask struct {
	taskman.STask
}

func (*LoadbalancerAclSyncstatusTask) OnInit ¶ 

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

func (*LoadbalancerAclSyncstatusTask) OnLoadbalancerAclSyncstatusComplete ¶ 

func (self *LoadbalancerAclSyncstatusTask) OnLoadbalancerAclSyncstatusComplete(ctx context.Context, lbacl *models.SLoadbalancerAcl, data jsonutils.JSONObject)

func (*LoadbalancerAclSyncstatusTask) OnLoadbalancerAclSyncstatusCompleteFailed ¶ 

func (self *LoadbalancerAclSyncstatusTask) OnLoadbalancerAclSyncstatusCompleteFailed(ctx context.Context, lbacl *models.SLoadbalancerAcl, reason jsonutils.JSONObject)

type LoadbalancerAclUpdateTask ¶ 

type LoadbalancerAclUpdateTask struct {
	taskman.STask
}

func (*LoadbalancerAclUpdateTask) OnInit ¶ 

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

func (*LoadbalancerAclUpdateTask) OnLoadbalancerAclUpdateComplete ¶ 

func (self *LoadbalancerAclUpdateTask) OnLoadbalancerAclUpdateComplete(ctx context.Context, lbacl *models.SLoadbalancerAcl, data jsonutils.JSONObject)

func (*LoadbalancerAclUpdateTask) OnLoadbalancerAclUpdateCompleteFailed ¶ 

func (self *LoadbalancerAclUpdateTask) OnLoadbalancerAclUpdateCompleteFailed(ctx context.Context, lbacl *models.SLoadbalancerAcl, reason jsonutils.JSONObject)

type LoadbalancerBackendCreateTask ¶ 

type LoadbalancerBackendCreateTask struct {
	taskman.STask
}

func (*LoadbalancerBackendCreateTask) OnInit ¶ 

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

func (*LoadbalancerBackendCreateTask) OnLoadbalancerBackendCreateComplete ¶ 

func (self *LoadbalancerBackendCreateTask) OnLoadbalancerBackendCreateComplete(ctx context.Context, lbb *models.SLoadbalancerBackend, data jsonutils.JSONObject)

func (*LoadbalancerBackendCreateTask) OnLoadbalancerBackendCreateCompleteFailed ¶ 

func (self *LoadbalancerBackendCreateTask) OnLoadbalancerBackendCreateCompleteFailed(ctx context.Context, lbb *models.SLoadbalancerBackend, reason jsonutils.JSONObject)

type LoadbalancerBackendDeleteTask ¶ 

type LoadbalancerBackendDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerBackendDeleteTask) OnInit ¶ 

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

func (*LoadbalancerBackendDeleteTask) OnLoadbalancerBackendDeleteComplete ¶ 

func (self *LoadbalancerBackendDeleteTask) OnLoadbalancerBackendDeleteComplete(ctx context.Context, lbb *models.SLoadbalancerBackend, data jsonutils.JSONObject)

func (*LoadbalancerBackendDeleteTask) OnLoadbalancerBackendDeleteCompleteFailed ¶ 

func (self *LoadbalancerBackendDeleteTask) OnLoadbalancerBackendDeleteCompleteFailed(ctx context.Context, lbb *models.SLoadbalancerBackend, reason jsonutils.JSONObject)

type LoadbalancerBackendGroupDeleteTask ¶ 

type LoadbalancerBackendGroupDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerBackendGroupDeleteTask) OnInit ¶ 

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

func (*LoadbalancerBackendGroupDeleteTask) OnLoadbalancerBackendGroupDeleteComplete ¶ 

func (self *LoadbalancerBackendGroupDeleteTask) OnLoadbalancerBackendGroupDeleteComplete(ctx context.Context, lbbg *models.SLoadbalancerBackendGroup, data jsonutils.JSONObject)

func (*LoadbalancerBackendGroupDeleteTask) OnLoadbalancerBackendGroupDeleteCompleteFailed ¶ 

func (self *LoadbalancerBackendGroupDeleteTask) OnLoadbalancerBackendGroupDeleteCompleteFailed(ctx context.Context, lbbg *models.SLoadbalancerBackendGroup, reason jsonutils.JSONObject)

type LoadbalancerBackendSyncTask ¶ 

type LoadbalancerBackendSyncTask struct {
	taskman.STask
}

func (*LoadbalancerBackendSyncTask) OnInit ¶ 

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

func (*LoadbalancerBackendSyncTask) OnLoadbalancerBackendCreateComplete ¶ 

func (self *LoadbalancerBackendSyncTask) OnLoadbalancerBackendCreateComplete(ctx context.Context, lbb *models.SLoadbalancerBackend, data jsonutils.JSONObject)

func (*LoadbalancerBackendSyncTask) OnLoadbalancerBackendCreateCompleteFailed ¶ 

func (self *LoadbalancerBackendSyncTask) OnLoadbalancerBackendCreateCompleteFailed(ctx context.Context, lbb *models.SLoadbalancerBackend, reason jsonutils.JSONObject)

type LoadbalancerCertificateCreateTask ¶ 

type LoadbalancerCertificateCreateTask struct {
	taskman.STask
}

func (*LoadbalancerCertificateCreateTask) OnInit ¶ 

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

func (*LoadbalancerCertificateCreateTask) OnLoadbalancerCertificateCreateComplete ¶ 

func (self *LoadbalancerCertificateCreateTask) OnLoadbalancerCertificateCreateComplete(ctx context.Context, lbcert *models.SLoadbalancerCertificate, data jsonutils.JSONObject)

func (*LoadbalancerCertificateCreateTask) OnLoadbalancerCertificateCreateCompleteFailed ¶ 

func (self *LoadbalancerCertificateCreateTask) OnLoadbalancerCertificateCreateCompleteFailed(ctx context.Context, lbcert *models.SLoadbalancerCertificate, reason jsonutils.JSONObject)

type LoadbalancerCertificateDeleteTask ¶ 

type LoadbalancerCertificateDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerCertificateDeleteTask) OnInit ¶ 

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

func (*LoadbalancerCertificateDeleteTask) OnLoadbalancerCertificateDeleteComplete ¶ 

func (self *LoadbalancerCertificateDeleteTask) OnLoadbalancerCertificateDeleteComplete(ctx context.Context, lbcert *models.SLoadbalancerCertificate, data jsonutils.JSONObject)

func (*LoadbalancerCertificateDeleteTask) OnLoadbalancerCertificateDeleteCompleteFailed ¶ 

func (self *LoadbalancerCertificateDeleteTask) OnLoadbalancerCertificateDeleteCompleteFailed(ctx context.Context, lbcert *models.SLoadbalancerCertificate, reason jsonutils.JSONObject)

type LoadbalancerCertificateSyncstatusTask ¶ 

type LoadbalancerCertificateSyncstatusTask struct {
	taskman.STask
}

func (*LoadbalancerCertificateSyncstatusTask) OnInit ¶ 

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

func (*LoadbalancerCertificateSyncstatusTask) OnLoadbalancerCertificateSyncstatusComplete ¶ 

func (self *LoadbalancerCertificateSyncstatusTask) OnLoadbalancerCertificateSyncstatusComplete(ctx context.Context, lbcert *models.SLoadbalancerCertificate, data jsonutils.JSONObject)

func (*LoadbalancerCertificateSyncstatusTask) OnLoadbalancerCertificateSyncstatusCompleteFailed ¶ 

func (self *LoadbalancerCertificateSyncstatusTask) OnLoadbalancerCertificateSyncstatusCompleteFailed(ctx context.Context, lbcert *models.SLoadbalancerCertificate, reason jsonutils.JSONObject)

type LoadbalancerCreateTask ¶ 

type LoadbalancerCreateTask struct {
	taskman.STask
}

func (*LoadbalancerCreateTask) OnInit ¶ 

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

func (*LoadbalancerCreateTask) OnLoadbalancerCreateComplete ¶ 

func (self *LoadbalancerCreateTask) OnLoadbalancerCreateComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerCreateTask) OnLoadbalancerCreateCompleteFailed ¶ 

func (self *LoadbalancerCreateTask) OnLoadbalancerCreateCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, reason jsonutils.JSONObject)

func (*LoadbalancerCreateTask) OnLoadbalancerStartComplete ¶ 

func (self *LoadbalancerCreateTask) OnLoadbalancerStartComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerCreateTask) OnLoadbalancerStartCompleteFailed ¶ 

func (self *LoadbalancerCreateTask) OnLoadbalancerStartCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, reason jsonutils.JSONObject)

type LoadbalancerDeleteTask ¶ 

type LoadbalancerDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerDeleteTask) OnInit ¶ 

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

func (*LoadbalancerDeleteTask) OnLoadbalancerDeleteComplete ¶ 

func (self *LoadbalancerDeleteTask) OnLoadbalancerDeleteComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerDeleteTask) OnLoadbalancerDeleteCompleteFailed ¶ 

func (self *LoadbalancerDeleteTask) OnLoadbalancerDeleteCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, reason jsonutils.JSONObject)

type LoadbalancerListenerCreateTask ¶ 

type LoadbalancerListenerCreateTask struct {
	taskman.STask
}

func (*LoadbalancerListenerCreateTask) OnInit ¶ 

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

func (*LoadbalancerListenerCreateTask) OnLoadbalancerListenerCreateComplete ¶ 

func (self *LoadbalancerListenerCreateTask) OnLoadbalancerListenerCreateComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerCreateTask) OnLoadbalancerListenerCreateCompleteFailed ¶ 

func (self *LoadbalancerListenerCreateTask) OnLoadbalancerListenerCreateCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

func (*LoadbalancerListenerCreateTask) OnLoadbalancerListenerStartComplete ¶ 

func (self *LoadbalancerListenerCreateTask) OnLoadbalancerListenerStartComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerCreateTask) OnLoadbalancerListenerStartCompleteFailed ¶ 

func (self *LoadbalancerListenerCreateTask) OnLoadbalancerListenerStartCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

type LoadbalancerListenerDeleteTask ¶ 

type LoadbalancerListenerDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerListenerDeleteTask) OnInit ¶ 

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

func (*LoadbalancerListenerDeleteTask) OnLoadbalancerListenerDeleteComplete ¶ 

func (self *LoadbalancerListenerDeleteTask) OnLoadbalancerListenerDeleteComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerDeleteTask) OnLoadbalancerListenerDeleteCompleteFailed ¶ 

func (self *LoadbalancerListenerDeleteTask) OnLoadbalancerListenerDeleteCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

type LoadbalancerListenerRuleCreateTask ¶ 

type LoadbalancerListenerRuleCreateTask struct {
	taskman.STask
}

func (*LoadbalancerListenerRuleCreateTask) OnCreateLoadbalancerListenerRuleFailed ¶ 

func (self *LoadbalancerListenerRuleCreateTask) OnCreateLoadbalancerListenerRuleFailed(ctx context.Context, lbr *models.SLoadbalancerListenerRule, reason jsonutils.JSONObject)

func (*LoadbalancerListenerRuleCreateTask) OnInit ¶ 

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

func (*LoadbalancerListenerRuleCreateTask) OnLoadbalancerListenerRuleCreateComplete ¶ 

func (self *LoadbalancerListenerRuleCreateTask) OnLoadbalancerListenerRuleCreateComplete(ctx context.Context, lbr *models.SLoadbalancerListenerRule, data jsonutils.JSONObject)

func (*LoadbalancerListenerRuleCreateTask) OnLoadbalancerListenerRuleCreateCompleteFailed ¶ 

func (self *LoadbalancerListenerRuleCreateTask) OnLoadbalancerListenerRuleCreateCompleteFailed(ctx context.Context, lbr *models.SLoadbalancerListenerRule, reason jsonutils.JSONObject)

type LoadbalancerListenerRuleDeleteTask ¶ 

type LoadbalancerListenerRuleDeleteTask struct {
	taskman.STask
}

func (*LoadbalancerListenerRuleDeleteTask) OnInit ¶ 

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

func (*LoadbalancerListenerRuleDeleteTask) OnLoadbalancerListenerRuleDeleteComplete ¶ 

func (self *LoadbalancerListenerRuleDeleteTask) OnLoadbalancerListenerRuleDeleteComplete(ctx context.Context, lbr *models.SLoadbalancerListenerRule, data jsonutils.JSONObject)

func (*LoadbalancerListenerRuleDeleteTask) OnLoadbalancerListenerRuleDeleteCompleteFailed ¶ 

func (self *LoadbalancerListenerRuleDeleteTask) OnLoadbalancerListenerRuleDeleteCompleteFailed(ctx context.Context, lbr *models.SLoadbalancerListenerRule, reason jsonutils.JSONObject)

type LoadbalancerListenerStartTask ¶ 

type LoadbalancerListenerStartTask struct {
	taskman.STask
}

func (*LoadbalancerListenerStartTask) OnInit ¶ 

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

func (*LoadbalancerListenerStartTask) OnLoadbalancerListenerStartComplete ¶ 

func (self *LoadbalancerListenerStartTask) OnLoadbalancerListenerStartComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerStartTask) OnLoadbalancerListenerStartCompleteFailed ¶ 

func (self *LoadbalancerListenerStartTask) OnLoadbalancerListenerStartCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

type LoadbalancerListenerStopTask ¶ 

type LoadbalancerListenerStopTask struct {
	taskman.STask
}

func (*LoadbalancerListenerStopTask) OnInit ¶ 

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

func (*LoadbalancerListenerStopTask) OnLoadbalancerListenerStopComplete ¶ 

func (self *LoadbalancerListenerStopTask) OnLoadbalancerListenerStopComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerStopTask) OnLoadbalancerListenerStopCompleteFailed ¶ 

func (self *LoadbalancerListenerStopTask) OnLoadbalancerListenerStopCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

type LoadbalancerListenerSyncTask ¶ 

type LoadbalancerListenerSyncTask struct {
	taskman.STask
}

func (*LoadbalancerListenerSyncTask) OnInit ¶ 

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

func (*LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncComplete ¶ 

func (self *LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncCompleteFailed ¶ 

func (self *LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

func (*LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncStatusComplete ¶ 

func (self *LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncStatusComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncStatusCompleteFailed ¶ 

func (self *LoadbalancerListenerSyncTask) OnLoadbalancerListenerSyncStatusCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

type LoadbalancerListenerSyncstatusTask ¶ 

type LoadbalancerListenerSyncstatusTask struct {
	taskman.STask
}

func (*LoadbalancerListenerSyncstatusTask) OnInit ¶ 

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

func (*LoadbalancerListenerSyncstatusTask) OnLoadbalancerListenerSyncstatusComplete ¶ 

func (self *LoadbalancerListenerSyncstatusTask) OnLoadbalancerListenerSyncstatusComplete(ctx context.Context, lblis *models.SLoadbalancerListener, data jsonutils.JSONObject)

func (*LoadbalancerListenerSyncstatusTask) OnLoadbalancerListenerSyncstatusCompleteFailed ¶ 

func (self *LoadbalancerListenerSyncstatusTask) OnLoadbalancerListenerSyncstatusCompleteFailed(ctx context.Context, lblis *models.SLoadbalancerListener, reason jsonutils.JSONObject)

type LoadbalancerLoadbalancerBackendGroupCreateTask ¶ 

type LoadbalancerLoadbalancerBackendGroupCreateTask struct {
	taskman.STask
}

func (*LoadbalancerLoadbalancerBackendGroupCreateTask) OnInit ¶ 

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

func (*LoadbalancerLoadbalancerBackendGroupCreateTask) OnLoadbalancerBackendGroupCreateComplete ¶ 

func (self *LoadbalancerLoadbalancerBackendGroupCreateTask) OnLoadbalancerBackendGroupCreateComplete(ctx context.Context, lbbg *models.SLoadbalancerBackendGroup, data jsonutils.JSONObject)

func (*LoadbalancerLoadbalancerBackendGroupCreateTask) OnLoadbalancerBackendGroupCreateCompleteFailed ¶ 

func (self *LoadbalancerLoadbalancerBackendGroupCreateTask) OnLoadbalancerBackendGroupCreateCompleteFailed(ctx context.Context, lbbg *models.SLoadbalancerBackendGroup, reason jsonutils.JSONObject)

type LoadbalancerRemoteUpdateTask ¶ 

type LoadbalancerRemoteUpdateTask struct {
	taskman.STask
}

func (*LoadbalancerRemoteUpdateTask) OnInit ¶ 

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

func (*LoadbalancerRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *LoadbalancerRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *LoadbalancerRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *LoadbalancerRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *LoadbalancerRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

type LoadbalancerStartTask ¶ 

type LoadbalancerStartTask struct {
	taskman.STask
}

func (*LoadbalancerStartTask) OnInit ¶ 

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

func (*LoadbalancerStartTask) OnLoadbalancerStartComplete ¶ 

func (self *LoadbalancerStartTask) OnLoadbalancerStartComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerStartTask) OnLoadbalancerStartCompleteFailed ¶ 

func (self *LoadbalancerStartTask) OnLoadbalancerStartCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, reason jsonutils.JSONObject)

type LoadbalancerStopTask ¶ 

type LoadbalancerStopTask struct {
	taskman.STask
}

func (*LoadbalancerStopTask) OnInit ¶ 

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

func (*LoadbalancerStopTask) OnLoadbalancerStopComplete ¶ 

func (self *LoadbalancerStopTask) OnLoadbalancerStopComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerStopTask) OnLoadbalancerStopCompleteFailed ¶ 

func (self *LoadbalancerStopTask) OnLoadbalancerStopCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, reason jsonutils.JSONObject)

type LoadbalancerSyncstatusTask ¶ 

type LoadbalancerSyncstatusTask struct {
	taskman.STask
}

func (*LoadbalancerSyncstatusTask) OnInit ¶ 

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

func (*LoadbalancerSyncstatusTask) OnLoadbalancerSyncstatusComplete ¶ 

func (self *LoadbalancerSyncstatusTask) OnLoadbalancerSyncstatusComplete(ctx context.Context, lb *models.SLoadbalancer, data jsonutils.JSONObject)

func (*LoadbalancerSyncstatusTask) OnLoadbalancerSyncstatusCompleteFailed ¶ 

func (self *LoadbalancerSyncstatusTask) OnLoadbalancerSyncstatusCompleteFailed(ctx context.Context, lb *models.SLoadbalancer, reason jsonutils.JSONObject)

type ManagedGuestCreateDiskTask ¶ 

type ManagedGuestCreateDiskTask struct {
	SGuestCreateDiskBaseTask
}

func (*ManagedGuestCreateDiskTask) OnInit ¶ 

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

func (*ManagedGuestCreateDiskTask) OnManagedDiskPrepared ¶ 

func (self *ManagedGuestCreateDiskTask) OnManagedDiskPrepared(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type ManagedGuestLiveMigrateTask ¶ 

type ManagedGuestLiveMigrateTask struct {
	SGuestBaseTask
}

func (*ManagedGuestLiveMigrateTask) MigrateStart ¶ 

func (task *ManagedGuestLiveMigrateTask) MigrateStart(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestLiveMigrateTask) OnGuestSyncStatus ¶ 

func (task *ManagedGuestLiveMigrateTask) OnGuestSyncStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestLiveMigrateTask) OnGuestSyncStatusFailed ¶ 

func (task *ManagedGuestLiveMigrateTask) OnGuestSyncStatusFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestLiveMigrateTask) OnInit ¶ 

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

ManagedGuestLiveMigrateTask

func (*ManagedGuestLiveMigrateTask) OnMigrateComplete ¶ 

func (task *ManagedGuestLiveMigrateTask) OnMigrateComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestLiveMigrateTask) OnMigrateCompleteFailed ¶ 

func (task *ManagedGuestLiveMigrateTask) OnMigrateCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type ManagedGuestMigrateTask ¶ 

type ManagedGuestMigrateTask struct {
	SGuestBaseTask
}

func (*ManagedGuestMigrateTask) MigrateStart ¶ 

func (task *ManagedGuestMigrateTask) MigrateStart(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestMigrateTask) OnGuestStartSucc ¶ 

func (task *ManagedGuestMigrateTask) OnGuestStartSucc(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestMigrateTask) OnGuestStartSuccFailed ¶ 

func (task *ManagedGuestMigrateTask) OnGuestStartSuccFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestMigrateTask) OnGuestSyncStatus ¶ 

func (task *ManagedGuestMigrateTask) OnGuestSyncStatus(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestMigrateTask) OnGuestSyncStatusFailed ¶ 

func (task *ManagedGuestMigrateTask) OnGuestSyncStatusFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*ManagedGuestMigrateTask) OnInit ¶ 

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

ManagedGuestMigrateTask

func (*ManagedGuestMigrateTask) OnMigrateComplete ¶ 

func (task *ManagedGuestMigrateTask) OnMigrateComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ManagedGuestMigrateTask) OnMigrateCompleteFailed ¶ 

func (task *ManagedGuestMigrateTask) OnMigrateCompleteFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

type ManagedGuestRebuildRootTask ¶ 

type ManagedGuestRebuildRootTask struct {
	SGuestBaseTask
}

func (*ManagedGuestRebuildRootTask) OnGuestDeployComplete ¶ 

func (self *ManagedGuestRebuildRootTask) OnGuestDeployComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ManagedGuestRebuildRootTask) OnGuestDeployCompleteFailed ¶ 

func (self *ManagedGuestRebuildRootTask) OnGuestDeployCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ManagedGuestRebuildRootTask) OnHostCacheImageComplete ¶ 

func (self *ManagedGuestRebuildRootTask) OnHostCacheImageComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ManagedGuestRebuildRootTask) OnHostCacheImageCompleteFailed ¶ 

func (self *ManagedGuestRebuildRootTask) OnHostCacheImageCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*ManagedGuestRebuildRootTask) OnInit ¶ 

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

type ModelartsPoolChangeConfigTask ¶ 

type ModelartsPoolChangeConfigTask struct {
	taskman.STask
}

func (*ModelartsPoolChangeConfigTask) OnInit ¶ 

func (self *ModelartsPoolChangeConfigTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type ModelartsPoolCreateTask ¶ 

type ModelartsPoolCreateTask struct {
	taskman.STask
}

func (*ModelartsPoolCreateTask) OnInit ¶ 

func (modelartsCreateTask *ModelartsPoolCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*ModelartsPoolCreateTask) OnModelartsPoolCreateComplete ¶ 

func (modelartsCreateTask *ModelartsPoolCreateTask) OnModelartsPoolCreateComplete(ctx context.Context, modelarts *models.SModelartsPool, body jsonutils.JSONObject)

func (*ModelartsPoolCreateTask) OnModelartsPoolCreateCompleteFailed ¶ 

func (modelartsCreateTask *ModelartsPoolCreateTask) OnModelartsPoolCreateCompleteFailed(ctx context.Context, modelarts *models.SModelartsPool, err jsonutils.JSONObject)

func (*ModelartsPoolCreateTask) WaitStatus ¶ 

func (modelartsCreateTask *ModelartsPoolCreateTask) WaitStatus(ctx context.Context, opts *cloudprovider.ModelartsPoolCreateOption, pool *models.SModelartsPool) error

type ModelartsPoolDeleteTask ¶ 

type ModelartsPoolDeleteTask struct {
	taskman.STask
}

func (*ModelartsPoolDeleteTask) OnInit ¶ 

func (modelartsDeleteTask *ModelartsPoolDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type ModelartsPoolSyncstatusTask ¶ 

type ModelartsPoolSyncstatusTask struct {
	taskman.STask
}

func (*ModelartsPoolSyncstatusTask) OnInit ¶ 

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

type MongoDBDeleteTask ¶ 

type MongoDBDeleteTask struct {
	taskman.STask
}

func (*MongoDBDeleteTask) OnInit ¶ 

func (self *MongoDBDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type MongoDBRemoteUpdateTask ¶ 

type MongoDBRemoteUpdateTask struct {
	taskman.STask
}

func (*MongoDBRemoteUpdateTask) OnInit ¶ 

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

func (*MongoDBRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *MongoDBRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, mongodb *models.SMongoDB, data jsonutils.JSONObject)

func (*MongoDBRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *MongoDBRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, mongodb *models.SMongoDB, data jsonutils.JSONObject)

func (*MongoDBRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *MongoDBRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, mongodb *models.SMongoDB, data jsonutils.JSONObject)

type MongoDBSyncstatusTask ¶ 

type MongoDBSyncstatusTask struct {
	taskman.STask
}

func (*MongoDBSyncstatusTask) OnInit ¶ 

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

type MountTargetCreateTask ¶ 

type MountTargetCreateTask struct {
	taskman.STask
}

func (*MountTargetCreateTask) OnInit ¶ 

func (self *MountTargetCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type MountTargetDeleteTask ¶ 

type MountTargetDeleteTask struct {
	taskman.STask
}

func (*MountTargetDeleteTask) OnInit ¶ 

func (self *MountTargetDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type MountTargetSyncstatusTask ¶ 

type MountTargetSyncstatusTask struct {
	taskman.STask
}

func (*MountTargetSyncstatusTask) OnInit ¶ 

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

type NatGatewayCreateTask ¶ 

type NatGatewayCreateTask struct {
	taskman.STask
}

func (*NatGatewayCreateTask) OnCreateNatGatewayCreateComplete ¶ 

func (self *NatGatewayCreateTask) OnCreateNatGatewayCreateComplete(ctx context.Context, nat *models.SNatGateway, body jsonutils.JSONObject)

func (*NatGatewayCreateTask) OnCreateNatGatewayCreateCompleteFailed ¶ 

func (self *NatGatewayCreateTask) OnCreateNatGatewayCreateCompleteFailed(ctx context.Context, nat *models.SNatGateway, body jsonutils.JSONObject)

func (*NatGatewayCreateTask) OnDeployEipComplete ¶ 

func (self *NatGatewayCreateTask) OnDeployEipComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayCreateTask) OnDeployEipCompleteFailed ¶ 

func (self *NatGatewayCreateTask) OnDeployEipCompleteFailed(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayCreateTask) OnInit ¶ 

func (self *NatGatewayCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*NatGatewayCreateTask) OnSyncstatusComplete ¶ 

func (self *NatGatewayCreateTask) OnSyncstatusComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayCreateTask) OnSyncstatusCompleteFailed ¶ 

func (self *NatGatewayCreateTask) OnSyncstatusCompleteFailed(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

type NatGatewayDeleteTask ¶ 

type NatGatewayDeleteTask struct {
	taskman.STask
}

func (*NatGatewayDeleteTask) OnEipDissociateComplete ¶ 

func (self *NatGatewayDeleteTask) OnEipDissociateComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayDeleteTask) OnEipDissociateCompleteFailed ¶ 

func (self *NatGatewayDeleteTask) OnEipDissociateCompleteFailed(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayDeleteTask) OnInit ¶ 

func (self *NatGatewayDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type NatGatewayRemoteUpdateTask ¶ 

type NatGatewayRemoteUpdateTask struct {
	taskman.STask
}

func (*NatGatewayRemoteUpdateTask) OnInit ¶ 

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

func (*NatGatewayRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *NatGatewayRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *NatGatewayRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *NatGatewayRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

type NatGatewayRenewTask ¶ 

type NatGatewayRenewTask struct {
	taskman.STask
}

func (*NatGatewayRenewTask) OnInit ¶ 

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

func (*NatGatewayRenewTask) OnSyncstatusComplete ¶ 

func (self *NatGatewayRenewTask) OnSyncstatusComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewayRenewTask) OnSyncstatusCompleteFailed ¶ 

func (self *NatGatewayRenewTask) OnSyncstatusCompleteFailed(ctx context.Context, nat *models.SNatGateway, reason jsonutils.JSONObject)

type NatGatewaySetAutoRenewTask ¶ 

type NatGatewaySetAutoRenewTask struct {
	taskman.STask
}

func (*NatGatewaySetAutoRenewTask) OnInit ¶ 

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

func (*NatGatewaySetAutoRenewTask) OnNatGatewaySyncComplete ¶ 

func (self *NatGatewaySetAutoRenewTask) OnNatGatewaySyncComplete(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

func (*NatGatewaySetAutoRenewTask) OnNatGatewaySyncCompleteFailed ¶ 

func (self *NatGatewaySetAutoRenewTask) OnNatGatewaySyncCompleteFailed(ctx context.Context, nat *models.SNatGateway, data jsonutils.JSONObject)

type NatGatewaySyncstatusTask ¶ 

type NatGatewaySyncstatusTask struct {
	taskman.STask
}

func (*NatGatewaySyncstatusTask) OnInit ¶ 

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

func (*NatGatewaySyncstatusTask) OnNatGatewaySyncStatusComplete ¶ 

func (self *NatGatewaySyncstatusTask) OnNatGatewaySyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*NatGatewaySyncstatusTask) OnNatGatewaySyncStatusCompleteFailed ¶ 

func (self *NatGatewaySyncstatusTask) OnNatGatewaySyncStatusCompleteFailed(ctx context.Context, natgateway *models.SNatGateway, data jsonutils.JSONObject)

type Net ¶ 

type Net struct {
	*models.SNetwork
	StartIp netutils.IPV4Addr
}

type NetworkCreateTask ¶ 

type NetworkCreateTask struct {
	taskman.STask
}

func (*NetworkCreateTask) OnInit ¶ 

func (self *NetworkCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type NetworkDeleteTask ¶ 

type NetworkDeleteTask struct {
	taskman.STask
}

func (*NetworkDeleteTask) OnInit ¶ 

func (self *NetworkDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type NetworkRemoteUpdateTask ¶ 

type NetworkRemoteUpdateTask struct {
	taskman.STask
}

func (*NetworkRemoteUpdateTask) OnInit ¶ 

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

func (*NetworkRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *NetworkRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, net *models.SNetwork, data jsonutils.JSONObject)

func (*NetworkRemoteUpdateTask) OnRemoteUpdateCompleteFailed ¶ 

func (self *NetworkRemoteUpdateTask) OnRemoteUpdateCompleteFailed(ctx context.Context, net *models.SNetwork, data jsonutils.JSONObject)

func (*NetworkRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *NetworkRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, net *models.SNetwork, data jsonutils.JSONObject)

func (*NetworkRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *NetworkRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, net *models.SNetwork, data jsonutils.JSONObject)

type NetworkSyncstatusTask ¶ 

type NetworkSyncstatusTask struct {
	taskman.STask
}

func (*NetworkSyncstatusTask) OnInit ¶ 

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

type NetworksUnderWireMergeTask ¶ 

type NetworksUnderWireMergeTask struct {
	taskman.STask
}

func (*NetworksUnderWireMergeTask) OnInit ¶ 

func (self *NetworksUnderWireMergeTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type NutanixGuestCreateDiskTask ¶ 

type NutanixGuestCreateDiskTask struct {
	SGuestCreateDiskBaseTask
}

func (*NutanixGuestCreateDiskTask) OnInit ¶ 

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

type PodCreateTask ¶ 

type PodCreateTask struct {
	SGuestBaseTask
}

func (*PodCreateTask) OnContainerCreated ¶ 

func (t *PodCreateTask) OnContainerCreated(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodCreateTask) OnContainerCreatedFailed ¶ 

func (t *PodCreateTask) OnContainerCreatedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodCreateTask) OnInit ¶ 

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

func (*PodCreateTask) OnPodCreated ¶ 

func (t *PodCreateTask) OnPodCreated(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodCreateTask) OnPodCreatedFailed ¶ 

func (t *PodCreateTask) OnPodCreatedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodCreateTask) OnStatusSynced ¶ 

func (t *PodCreateTask) OnStatusSynced(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodCreateTask) OnStatusSyncedFailed ¶ 

func (t *PodCreateTask) OnStatusSyncedFailed(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodCreateTask) OnWaitPodCreated ¶ 

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

type PodDeleteTask ¶ 

type PodDeleteTask struct {
	SGuestBaseTask
}

func (*PodDeleteTask) OnContainerDeleted ¶ 

func (t *PodDeleteTask) OnContainerDeleted(ctx context.Context, pod *models.SGuest)

func (*PodDeleteTask) OnInit ¶ 

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

func (*PodDeleteTask) OnPodDeleted ¶ 

func (t *PodDeleteTask) OnPodDeleted(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodDeleteTask) OnPodDeletedFailed ¶ 

func (t *PodDeleteTask) OnPodDeletedFailed(ctx context.Context, pod *models.SGuest, reason jsonutils.JSONObject)

func (*PodDeleteTask) OnPodStopped ¶ 

func (t *PodDeleteTask) OnPodStopped(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodDeleteTask) OnPodStoppedFailed ¶ 

func (t *PodDeleteTask) OnPodStoppedFailed(ctx context.Context, pod *models.SGuest, reason jsonutils.JSONObject)

func (*PodDeleteTask) OnWaitContainerDeleted ¶ 

func (t *PodDeleteTask) OnWaitContainerDeleted(ctx context.Context, pod *models.SGuest, _ jsonutils.JSONObject)

func (*PodDeleteTask) OnWaitContainerDeletedFailed ¶ 

func (t *PodDeleteTask) OnWaitContainerDeletedFailed(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

type PodRestartTask ¶ 

type PodRestartTask struct {
	GuestRestartTask
}

func (*PodRestartTask) OnServerStartCompleteFailed ¶ 

func (t *PodRestartTask) OnServerStartCompleteFailed(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodRestartTask) OnServerStopComplete ¶ 

func (t *PodRestartTask) OnServerStopComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*PodRestartTask) StartServer ¶ 

func (t *PodRestartTask) StartServer(ctx context.Context, guest *models.SGuest)

type PodStartTask ¶ 

type PodStartTask struct {
	SGuestBaseTask
}

func (*PodStartTask) OnContainerStarted ¶ 

func (t *PodStartTask) OnContainerStarted(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodStartTask) OnContainerStartedFailed ¶ 

func (t *PodStartTask) OnContainerStartedFailed(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodStartTask) OnInit ¶ 

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

func (*PodStartTask) OnPodStarted ¶ 

func (t *PodStartTask) OnPodStarted(ctx context.Context, pod *models.SGuest, _ jsonutils.JSONObject)

func (*PodStartTask) OnPodStartedFailed ¶ 

func (t *PodStartTask) OnPodStartedFailed(ctx context.Context, pod *models.SGuest, reason jsonutils.JSONObject)

type PodStopTask ¶ 

type PodStopTask struct {
	SGuestBaseTask
}

func (*PodStopTask) OnContainerStopped ¶ 

func (t *PodStopTask) OnContainerStopped(ctx context.Context, pod *models.SGuest)

func (*PodStopTask) OnInit ¶ 

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

func (*PodStopTask) OnPodStopped ¶ 

func (t *PodStopTask) OnPodStopped(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodStopTask) OnPodStoppedFailed ¶ 

func (t *PodStopTask) OnPodStoppedFailed(ctx context.Context, pod *models.SGuest, reason jsonutils.JSONObject)

func (*PodStopTask) OnWaitContainerStopped ¶ 

func (t *PodStopTask) OnWaitContainerStopped(ctx context.Context, pod *models.SGuest, _ jsonutils.JSONObject)

func (*PodStopTask) OnWaitContainerStoppedFailed ¶ 

func (t *PodStopTask) OnWaitContainerStoppedFailed(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

type PodSyncstatusTask ¶ 

type PodSyncstatusTask struct {
	SGuestBaseTask
}

func (*PodSyncstatusTask) OnContainerSynced ¶ 

func (t *PodSyncstatusTask) OnContainerSynced(ctx context.Context, pod *models.SGuest)

func (*PodSyncstatusTask) OnInit ¶ 

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

func (*PodSyncstatusTask) OnPodSynced ¶ 

func (t *PodSyncstatusTask) OnPodSynced(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

func (*PodSyncstatusTask) OnPodSyncedFailed ¶ 

func (t *PodSyncstatusTask) OnPodSyncedFailed(ctx context.Context, pod *models.SGuest, reason jsonutils.JSONObject)

func (*PodSyncstatusTask) OnWaitContainerSynced ¶ 

func (t *PodSyncstatusTask) OnWaitContainerSynced(ctx context.Context, pod *models.SGuest, _ jsonutils.JSONObject)

func (*PodSyncstatusTask) OnWaitContainerSyncedFailed ¶ 

func (t *PodSyncstatusTask) OnWaitContainerSyncedFailed(ctx context.Context, pod *models.SGuest, data jsonutils.JSONObject)

type PrepaidRecycleHostRenewTask ¶ 

type PrepaidRecycleHostRenewTask struct {
	taskman.STask
}

func (*PrepaidRecycleHostRenewTask) OnInit ¶ 

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

type ProxmoxGuestCreateDiskTask ¶ 

type ProxmoxGuestCreateDiskTask struct {
	ESXiGuestCreateDiskTask
}

type RbdStorageUpdateTask ¶ 

type RbdStorageUpdateTask struct {
	taskman.STask
}

func (*RbdStorageUpdateTask) OnInit ¶ 

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

type RouteTableSyncStatusTask ¶ 

type RouteTableSyncStatusTask struct {
	taskman.STask
}

func (*RouteTableSyncStatusTask) OnInit ¶ 

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

type RouteTableUpdateTask ¶ 

type RouteTableUpdateTask struct {
	taskman.STask
}

func (*RouteTableUpdateTask) OnInit ¶ 

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

func (*RouteTableUpdateTask) OnSyncRouteTableComplete ¶ 

func (self *RouteTableUpdateTask) OnSyncRouteTableComplete(ctx context.Context, routeTable *models.SRouteTable, data jsonutils.JSONObject)

func (*RouteTableUpdateTask) OnSyncRouteTableCompleteFailed ¶ 

func (self *RouteTableUpdateTask) OnSyncRouteTableCompleteFailed(ctx context.Context, routeTable *models.SRouteTable, data jsonutils.JSONObject)

type SBaremetalBaseTask ¶ 

type SBaremetalBaseTask struct {
	taskman.STask
}

func (*SBaremetalBaseTask) Action ¶ 

func (self *SBaremetalBaseTask) Action() string

func (*SBaremetalBaseTask) GetBaremetal ¶ 

func (self *SBaremetalBaseTask) GetBaremetal() *models.SHost

type SDiskBaseTask ¶ 

type SDiskBaseTask struct {
	taskman.STask
}

func (*SDiskBaseTask) CleanHostSchedCache ¶ 

func (self *SDiskBaseTask) CleanHostSchedCache(disk *models.SDisk)

func (*SDiskBaseTask) SetStageFailed ¶ 

func (self *SDiskBaseTask) SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

type SGuestBaseTask ¶ 

type SGuestBaseTask struct {
	taskman.STask
}

func (*SGuestBaseTask) SetStageFailed ¶ 

func (self *SGuestBaseTask) SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

type SGuestCreateDiskBaseTask ¶ 

type SGuestCreateDiskBaseTask struct {
	SGuestBaseTask
}

func (*SGuestCreateDiskBaseTask) GetInputDisks ¶ 

func (self *SGuestCreateDiskBaseTask) GetInputDisks() ([]api.DiskConfig, error)

type SGuestQgaBaseTask ¶ 

type SGuestQgaBaseTask struct {
	SGuestBaseTask
}

type SNatDEntryCreateTask ¶ 

type SNatDEntryCreateTask struct {
	taskman.STask
}

func (*SNatDEntryCreateTask) OnAssociateEipComplete ¶ 

func (self *SNatDEntryCreateTask) OnAssociateEipComplete(ctx context.Context, dnat *models.SNatDEntry, body jsonutils.JSONObject)

func (*SNatDEntryCreateTask) OnAssociateEipCompleteFailed ¶ 

func (self *SNatDEntryCreateTask) OnAssociateEipCompleteFailed(ctx context.Context, dnat *models.SNatDEntry, reason jsonutils.JSONObject)

func (*SNatDEntryCreateTask) OnInit ¶ 

func (self *SNatDEntryCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SNatDEntryDeleteTask ¶ 

type SNatDEntryDeleteTask struct {
	taskman.STask
}

func (*SNatDEntryDeleteTask) OnInit ¶ 

func (self *SNatDEntryDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SNatSEntryCreateTask ¶ 

type SNatSEntryCreateTask struct {
	taskman.STask
}

func (*SNatSEntryCreateTask) OnAssociateEipComplete ¶ 

func (self *SNatSEntryCreateTask) OnAssociateEipComplete(ctx context.Context, snat *models.SNatSEntry, body jsonutils.JSONObject)

func (*SNatSEntryCreateTask) OnAssociateEipCompleteFailed ¶ 

func (self *SNatSEntryCreateTask) OnAssociateEipCompleteFailed(ctx context.Context, snatEntry *models.SNatSEntry, reason jsonutils.JSONObject)

func (*SNatSEntryCreateTask) OnInit ¶ 

func (self *SNatSEntryCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SNatSEntryDeleteTask ¶ 

type SNatSEntryDeleteTask struct {
	taskman.STask
}

func (*SNatSEntryDeleteTask) OnInit ¶ 

func (self *SNatSEntryDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SSHable ¶ 

type SSHable struct {
	Ok     bool
	Reason string

	User string
	Host string
	Port int
}

type SScalingActionDesc ¶ 

type SScalingActionDesc struct {
}

func (SScalingActionDesc) CheckCoolTime ¶ 

func (s SScalingActionDesc) CheckCoolTime() bool

func (SScalingActionDesc) Exec ¶ 

func (s SScalingActionDesc) Exec(desire int) int

type SScalingTriggerDesc ¶ 

type SScalingTriggerDesc struct {
	Guest string
}

func (SScalingTriggerDesc) TriggerDescription ¶ 

func (s SScalingTriggerDesc) TriggerDescription() string

type SSchedTask ¶ 

type SSchedTask struct {
	taskman.STask
	// contains filtered or unexported fields
}

func (*SSchedTask) OnScheduleComplete ¶ 

func (self *SSchedTask) OnScheduleComplete(ctx context.Context, items []db.IStandaloneModel, data *jsonutils.JSONDict)

func (*SSchedTask) OnScheduleFailCallback ¶ 

func (self *SSchedTask) OnScheduleFailCallback(ctx context.Context, obj IScheduleModel, reason jsonutils.JSONObject, index int)

func (*SSchedTask) OnScheduleFailed ¶ 

func (self *SSchedTask) OnScheduleFailed(ctx context.Context, reason jsonutils.JSONObject)

func (*SSchedTask) OnStartSchedule ¶ 

func (self *SSchedTask) OnStartSchedule(obj IScheduleModel)

func (*SSchedTask) SaveScheduleResult ¶ 

func (self *SSchedTask) SaveScheduleResult(ctx context.Context, obj IScheduleModel, candidate *schedapi.CandidateResource, index int)

func (*SSchedTask) SaveScheduleResultWithBackup ¶ 

func (self *SSchedTask) SaveScheduleResultWithBackup(ctx context.Context, obj IScheduleModel, master, slave *schedapi.CandidateResource, index int)

type SangForGuestCreateDiskTask ¶ 

type SangForGuestCreateDiskTask struct {
	NutanixGuestCreateDiskTask
}

type ScalingGroupDeleteTask ¶ 

type ScalingGroupDeleteTask struct {
	taskman.STask
}

func (*ScalingGroupDeleteTask) OnInit ¶ 

func (self *ScalingGroupDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SecurityGroupCreateTask ¶ 

type SecurityGroupCreateTask struct {
	taskman.STask
}

func (*SecurityGroupCreateTask) OnInit ¶ 

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

type SecurityGroupDeleteTask ¶ 

type SecurityGroupDeleteTask struct {
	taskman.STask
}

func (*SecurityGroupDeleteTask) OnInit ¶ 

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

func (*SecurityGroupDeleteTask) OnSecurityGroupDeleteComplete ¶ 

func (self *SecurityGroupDeleteTask) OnSecurityGroupDeleteComplete(ctx context.Context, secgroup *models.SSecurityGroup, data jsonutils.JSONObject)

func (*SecurityGroupDeleteTask) OnSecurityGroupDeleteCompleteFailed ¶ 

func (self *SecurityGroupDeleteTask) OnSecurityGroupDeleteCompleteFailed(ctx context.Context, secgroup *models.SSecurityGroup, data jsonutils.JSONObject)

type SecurityGroupRemoteUpdateTask ¶ 

type SecurityGroupRemoteUpdateTask struct {
	taskman.STask
}

func (*SecurityGroupRemoteUpdateTask) OnInit ¶ 

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

type SecurityGroupRuleCreateTask ¶ 

type SecurityGroupRuleCreateTask struct {
	taskman.STask
}

func (*SecurityGroupRuleCreateTask) OnInit ¶ 

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

type SecurityGroupRuleDeleteTask ¶ 

type SecurityGroupRuleDeleteTask struct {
	taskman.STask
}

func (*SecurityGroupRuleDeleteTask) OnInit ¶ 

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

type SecurityGroupRuleUpdateTask ¶ 

type SecurityGroupRuleUpdateTask struct {
	taskman.STask
}

func (*SecurityGroupRuleUpdateTask) OnInit ¶ 

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

type SecurityGroupSyncTask ¶ 

type SecurityGroupSyncTask struct {
	taskman.STask
}

func (*SecurityGroupSyncTask) OnInit ¶ 

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

type ServerSkuCreateTask ¶ 

type ServerSkuCreateTask struct {
	taskman.STask
}

func (*ServerSkuCreateTask) OnInit ¶ 

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

type ServerSkuDeleteTask ¶ 

type ServerSkuDeleteTask struct {
	taskman.STask
}

func (*ServerSkuDeleteTask) OnInit ¶ 

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

type SnapshotCleanupTask ¶ 

type SnapshotCleanupTask struct {
	taskman.STask
}

func (*SnapshotCleanupTask) OnDeleteSnapshot ¶ 

func (self *SnapshotCleanupTask) OnDeleteSnapshot(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*SnapshotCleanupTask) OnDeleteSnapshotFailed ¶ 

func (self *SnapshotCleanupTask) OnDeleteSnapshotFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*SnapshotCleanupTask) OnInit ¶ 

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

func (*SnapshotCleanupTask) OnInitFailed ¶ 

func (self *SnapshotCleanupTask) OnInitFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*SnapshotCleanupTask) StartSnapshotsDelete ¶ 

func (self *SnapshotCleanupTask) StartSnapshotsDelete(ctx context.Context, snapshots []models.SSnapshot)

type SnapshotCreateTask ¶ 

type SnapshotCreateTask struct {
	taskman.STask
}

func (*SnapshotCreateTask) DoDiskSnapshot ¶ 

func (self *SnapshotCreateTask) DoDiskSnapshot(ctx context.Context, snapshot *models.SSnapshot)

func (*SnapshotCreateTask) OnCreateSnapshot ¶ 

func (self *SnapshotCreateTask) OnCreateSnapshot(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotCreateTask) OnCreateSnapshotFailed ¶ 

func (self *SnapshotCreateTask) OnCreateSnapshotFailed(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotCreateTask) OnInit ¶ 

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

func (*SnapshotCreateTask) TaskComplete ¶ 

func (self *SnapshotCreateTask) TaskComplete(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotCreateTask) TaskFailed ¶ 

func (self *SnapshotCreateTask) TaskFailed(ctx context.Context, snapshot *models.SSnapshot, reason jsonutils.JSONObject)

type SnapshotDeleteTask ¶ 

type SnapshotDeleteTask struct {
	taskman.STask
}

func (*SnapshotDeleteTask) OnDeleteSnapshot ¶ 

func (self *SnapshotDeleteTask) OnDeleteSnapshot(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) OnDeleteSnapshotFailed ¶ 

func (self *SnapshotDeleteTask) OnDeleteSnapshotFailed(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) OnInit ¶ 

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

func (*SnapshotDeleteTask) OnKvmSnapshotDelete ¶ 

func (self *SnapshotDeleteTask) OnKvmSnapshotDelete(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) OnManagedSnapshotDelete ¶ 

func (self *SnapshotDeleteTask) OnManagedSnapshotDelete(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) OnReloadDiskSnapshot ¶ 

func (self *SnapshotDeleteTask) OnReloadDiskSnapshot(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) OnRequestSnapshot ¶ 

func (self *SnapshotDeleteTask) OnRequestSnapshot(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) OnRequestSnapshotFailed ¶ 

func (self *SnapshotDeleteTask) OnRequestSnapshotFailed(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) TaskComplete ¶ 

func (self *SnapshotDeleteTask) TaskComplete(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

func (*SnapshotDeleteTask) TaskFailed ¶ 

func (self *SnapshotDeleteTask) TaskFailed(ctx context.Context, snapshot *models.SSnapshot, reason jsonutils.JSONObject)

type SnapshotPolicyCreateTask ¶ 

type SnapshotPolicyCreateTask struct {
	taskman.STask
}

func (*SnapshotPolicyCreateTask) OnCreateSnapshotPolicyComplete ¶ 

func (self *SnapshotPolicyCreateTask) OnCreateSnapshotPolicyComplete(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

func (*SnapshotPolicyCreateTask) OnCreateSnapshotPolicyCompleteFailed ¶ 

func (self *SnapshotPolicyCreateTask) OnCreateSnapshotPolicyCompleteFailed(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

func (*SnapshotPolicyCreateTask) OnInit ¶ 

func (self *SnapshotPolicyCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SnapshotPolicyDeleteTask ¶ 

type SnapshotPolicyDeleteTask struct {
	taskman.STask
}

func (*SnapshotPolicyDeleteTask) OnInit ¶ 

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

func (*SnapshotPolicyDeleteTask) OnSnapshotPolicyDeleteComplete ¶ 

func (self *SnapshotPolicyDeleteTask) OnSnapshotPolicyDeleteComplete(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

func (*SnapshotPolicyDeleteTask) OnSnapshotPolicyDeleteCompleteFailed ¶ 

func (self *SnapshotPolicyDeleteTask) OnSnapshotPolicyDeleteCompleteFailed(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

type SnapshotSyncstatusTask ¶ 

type SnapshotSyncstatusTask struct {
	taskman.STask
}

func (*SnapshotSyncstatusTask) OnInit ¶ 

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

func (*SnapshotSyncstatusTask) OnSnapshotSyncStatusComplete ¶ 

func (self *SnapshotSyncstatusTask) OnSnapshotSyncStatusComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*SnapshotSyncstatusTask) OnSnapshotSyncStatusCompleteFailed ¶ 

func (self *SnapshotSyncstatusTask) OnSnapshotSyncStatusCompleteFailed(ctx context.Context, snapshot *models.SSnapshot, data jsonutils.JSONObject)

type SnapshotpolicyBindDisksTask ¶ 

type SnapshotpolicyBindDisksTask struct {
	taskman.STask
}

func (*SnapshotpolicyBindDisksTask) OnInit ¶ 

func (self *SnapshotpolicyBindDisksTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*SnapshotpolicyBindDisksTask) OnSnapshotPolicyBindDisksComplete ¶ 

func (self *SnapshotpolicyBindDisksTask) OnSnapshotPolicyBindDisksComplete(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

func (*SnapshotpolicyBindDisksTask) OnSnapshotPolicyBindDisksCompleteFailed ¶ 

func (self *SnapshotpolicyBindDisksTask) OnSnapshotPolicyBindDisksCompleteFailed(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

type SnapshotpolicySyncstatusTask ¶ 

type SnapshotpolicySyncstatusTask struct {
	taskman.STask
}

func (*SnapshotpolicySyncstatusTask) OnInit ¶ 

func (self *SnapshotpolicySyncstatusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type SnapshotpolicyUnbindDisksTask ¶ 

type SnapshotpolicyUnbindDisksTask struct {
	taskman.STask
}

func (*SnapshotpolicyUnbindDisksTask) OnInit ¶ 

func (self *SnapshotpolicyUnbindDisksTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

func (*SnapshotpolicyUnbindDisksTask) OnSnapshotPolicyUnbindDisksComplete ¶ 

func (self *SnapshotpolicyUnbindDisksTask) OnSnapshotPolicyUnbindDisksComplete(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

func (*SnapshotpolicyUnbindDisksTask) OnSnapshotPolicyUnbindDisksCompleteFailed ¶ 

func (self *SnapshotpolicyUnbindDisksTask) OnSnapshotPolicyUnbindDisksCompleteFailed(ctx context.Context, sp *models.SSnapshotPolicy, data jsonutils.JSONObject)

type StartRescueTask ¶ 

type StartRescueTask struct {
	SGuestBaseTask
}

func (*StartRescueTask) OnInit ¶ 

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

func (*StartRescueTask) OnRescuePrepareComplete ¶ 

func (self *StartRescueTask) OnRescuePrepareComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*StartRescueTask) OnRescuePrepareCompleteFailed ¶ 

func (self *StartRescueTask) OnRescuePrepareCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*StartRescueTask) OnRescueStartServerComplete ¶ 

func (self *StartRescueTask) OnRescueStartServerComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*StartRescueTask) OnRescueStartServerCompleteFailed ¶ 

func (self *StartRescueTask) OnRescueStartServerCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*StartRescueTask) OnServerStopComplete ¶ 

func (self *StartRescueTask) OnServerStopComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*StartRescueTask) OnServerStopCompleteFailed ¶ 

func (self *StartRescueTask) OnServerStopCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*StartRescueTask) PrepareRescue ¶ 

func (self *StartRescueTask) PrepareRescue(ctx context.Context, guest *models.SGuest)

func (*StartRescueTask) RescueStartServer ¶ 

func (self *StartRescueTask) RescueStartServer(ctx context.Context, guest *models.SGuest)

func (*StartRescueTask) StopServer ¶ 

func (self *StartRescueTask) StopServer(ctx context.Context, guest *models.SGuest)

type StopRescueTask ¶ 

type StopRescueTask struct {
	SGuestBaseTask
}

func (*StopRescueTask) ClearRescue ¶ 

func (self *StopRescueTask) ClearRescue(ctx context.Context, guest *models.SGuest)

func (*StopRescueTask) OnInit ¶ 

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

func (*StopRescueTask) OnRescueClearComplete ¶ 

func (self *StopRescueTask) OnRescueClearComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*StopRescueTask) OnRescueClearCompleteFailed ¶ 

func (self *StopRescueTask) OnRescueClearCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*StopRescueTask) OnRescueStartServerComplete ¶ 

func (self *StopRescueTask) OnRescueStartServerComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*StopRescueTask) OnRescueStartServerCompleteFailed ¶ 

func (self *StopRescueTask) OnRescueStartServerCompleteFailed(ctx context.Context, obj db.IStandaloneModel, err jsonutils.JSONObject)

func (*StopRescueTask) OnServerStopComplete ¶ 

func (self *StopRescueTask) OnServerStopComplete(ctx context.Context, guest *models.SGuest, data jsonutils.JSONObject)

func (*StopRescueTask) OnServerStopCompleteFailed ¶ 

func (self *StopRescueTask) OnServerStopCompleteFailed(ctx context.Context, guest *models.SGuest, err jsonutils.JSONObject)

func (*StopRescueTask) RescueStartServer ¶ 

func (self *StopRescueTask) RescueStartServer(ctx context.Context, guest *models.SGuest)

func (*StopRescueTask) StopServer ¶ 

func (self *StopRescueTask) StopServer(ctx context.Context, guest *models.SGuest)

type StorageCacheImageTask ¶ 

type StorageCacheImageTask struct {
	taskman.STask
}

func (*StorageCacheImageTask) OnCacheFailed ¶ 

func (self *StorageCacheImageTask) OnCacheFailed(ctx context.Context, cache *models.SStoragecache, imageId string, scimg *models.SStoragecachedimage, reason jsonutils.JSONObject, extImgId string)

func (*StorageCacheImageTask) OnCacheSucc ¶ 

func (self *StorageCacheImageTask) OnCacheSucc(ctx context.Context, cache *models.SStoragecache, data *jsonutils.JSONDict)

func (*StorageCacheImageTask) OnImageCacheComplete ¶ 

func (self *StorageCacheImageTask) OnImageCacheComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*StorageCacheImageTask) OnImageCacheCompleteFailed ¶ 

func (self *StorageCacheImageTask) OnImageCacheCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*StorageCacheImageTask) OnInit ¶ 

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

func (*StorageCacheImageTask) OnRelinquishLeastUsedCachedImageComplete ¶ 

func (self *StorageCacheImageTask) OnRelinquishLeastUsedCachedImageComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type StorageDeleteRbdDiskTask ¶ 

type StorageDeleteRbdDiskTask struct {
	taskman.STask
}

func (*StorageDeleteRbdDiskTask) DeleteDisk ¶ 

func (self *StorageDeleteRbdDiskTask) DeleteDisk(ctx context.Context, storage *models.SStorage, data jsonutils.JSONObject)

func (*StorageDeleteRbdDiskTask) OnDeleteDisk ¶ 

func (self *StorageDeleteRbdDiskTask) OnDeleteDisk(ctx context.Context, storage *models.SStorage, data jsonutils.JSONObject)

func (*StorageDeleteRbdDiskTask) OnDeleteDiskFailed ¶ 

func (self *StorageDeleteRbdDiskTask) OnDeleteDiskFailed(ctx context.Context, storage *models.SStorage, data jsonutils.JSONObject)

func (*StorageDeleteRbdDiskTask) OnInit ¶ 

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

type StorageUncacheImageTask ¶ 

type StorageUncacheImageTask struct {
	taskman.STask
}

func (*StorageUncacheImageTask) OnImageUncacheComplete ¶ 

func (self *StorageUncacheImageTask) OnImageUncacheComplete(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*StorageUncacheImageTask) OnImageUncacheCompleteFailed ¶ 

func (self *StorageUncacheImageTask) OnImageUncacheCompleteFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*StorageUncacheImageTask) OnInit ¶ 

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

func (*StorageUncacheImageTask) OnTaskFailed ¶ 

func (self *StorageUncacheImageTask) OnTaskFailed(ctx context.Context, storageCache *models.SStoragecache, reason error)

func (*StorageUncacheImageTask) RequestUncacheDeactivateImage ¶ 

func (self *StorageUncacheImageTask) RequestUncacheDeactivateImage(ctx context.Context, storageCache *models.SStoragecache)

func (*StorageUncacheImageTask) RequestUncacheRemoveImage ¶ 

func (self *StorageUncacheImageTask) RequestUncacheRemoveImage(ctx context.Context, storageCache *models.SStoragecache)

type StorageUpdateTask ¶ 

type StorageUpdateTask struct {
	taskman.STask
}

func (*StorageUpdateTask) OnInit ¶ 

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

func (*StorageUpdateTask) OnStorageUpdate ¶ 

func (self *StorageUpdateTask) OnStorageUpdate(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

func (*StorageUpdateTask) OnStorageUpdateFailed ¶ 

func (self *StorageUpdateTask) OnStorageUpdateFailed(ctx context.Context, obj db.IStandaloneModel, data jsonutils.JSONObject)

type VpcCreateTask ¶ 

type VpcCreateTask struct {
	taskman.STask
}

func (*VpcCreateTask) OnCreateVpcComplete ¶ 

func (self *VpcCreateTask) OnCreateVpcComplete(ctx context.Context, vpc *models.SVpc, data jsonutils.JSONObject)

func (*VpcCreateTask) OnCreateVpcCompleteFailed ¶ 

func (self *VpcCreateTask) OnCreateVpcCompleteFailed(ctx context.Context, vpc *models.SVpc, data jsonutils.JSONObject)

func (*VpcCreateTask) OnInit ¶ 

func (self *VpcCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type VpcDeleteTask ¶ 

type VpcDeleteTask struct {
	taskman.STask
}

func (*VpcDeleteTask) OnDeleteVpcComplete ¶ 

func (self *VpcDeleteTask) OnDeleteVpcComplete(ctx context.Context, vpc *models.SVpc, body jsonutils.JSONObject)

func (*VpcDeleteTask) OnDeleteVpcCompleteFailed ¶ 

func (self *VpcDeleteTask) OnDeleteVpcCompleteFailed(ctx context.Context, vpc *models.SVpc, reason jsonutils.JSONObject)

func (*VpcDeleteTask) OnInit ¶ 

func (self *VpcDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type VpcPeeringConnectionCreateTask ¶ 

type VpcPeeringConnectionCreateTask struct {
	taskman.STask
}

func (*VpcPeeringConnectionCreateTask) OnInit ¶ 

func (self *VpcPeeringConnectionCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type VpcPeeringConnectionDeleteTask ¶ 

type VpcPeeringConnectionDeleteTask struct {
	taskman.STask
}

func (*VpcPeeringConnectionDeleteTask) OnInit ¶ 

func (self *VpcPeeringConnectionDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type VpcPeeringConnectionSyncstatusTask ¶ 

type VpcPeeringConnectionSyncstatusTask struct {
	taskman.STask
}

func (*VpcPeeringConnectionSyncstatusTask) OnInit ¶ 

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

type VpcSyncstatusTask ¶ 

type VpcSyncstatusTask struct {
	taskman.STask
}

func (*VpcSyncstatusTask) OnInit ¶ 

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

type WafCreateTask ¶ 

type WafCreateTask struct {
	taskman.STask
}

func (*WafCreateTask) OnInit ¶ 

func (self *WafCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafDeleteTask ¶ 

type WafDeleteTask struct {
	taskman.STask
}

func (*WafDeleteTask) OnInit ¶ 

func (self *WafDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafIPSetDeleteTask ¶ 

type WafIPSetDeleteTask struct {
	taskman.STask
}

func (*WafIPSetDeleteTask) OnInit ¶ 

func (self *WafIPSetDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafInstanceRemoteUpdateTask ¶ 

type WafInstanceRemoteUpdateTask struct {
	taskman.STask
}

func (*WafInstanceRemoteUpdateTask) OnInit ¶ 

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

func (*WafInstanceRemoteUpdateTask) OnRemoteUpdateComplete ¶ 

func (self *WafInstanceRemoteUpdateTask) OnRemoteUpdateComplete(ctx context.Context, waf *models.SWafInstance, data jsonutils.JSONObject)

func (*WafInstanceRemoteUpdateTask) OnSyncStatusComplete ¶ 

func (self *WafInstanceRemoteUpdateTask) OnSyncStatusComplete(ctx context.Context, waf *models.SWafInstance, data jsonutils.JSONObject)

func (*WafInstanceRemoteUpdateTask) OnSyncStatusCompleteFailed ¶ 

func (self *WafInstanceRemoteUpdateTask) OnSyncStatusCompleteFailed(ctx context.Context, waf *models.SWafInstance, data jsonutils.JSONObject)

type WafRegexSetDeleteTask ¶ 

type WafRegexSetDeleteTask struct {
	taskman.STask
}

func (*WafRegexSetDeleteTask) OnInit ¶ 

func (self *WafRegexSetDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafRuleCreateTask ¶ 

type WafRuleCreateTask struct {
	taskman.STask
}

func (*WafRuleCreateTask) OnInit ¶ 

func (self *WafRuleCreateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafRuleDeleteTask ¶ 

type WafRuleDeleteTask struct {
	taskman.STask
}

func (*WafRuleDeleteTask) OnInit ¶ 

func (self *WafRuleDeleteTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafRuleSyncstatusTask ¶ 

type WafRuleSyncstatusTask struct {
	taskman.STask
}

func (*WafRuleSyncstatusTask) OnInit ¶ 

func (self *WafRuleSyncstatusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafRuleUpdateTask ¶ 

type WafRuleUpdateTask struct {
	taskman.STask
}

func (*WafRuleUpdateTask) OnInit ¶ 

func (self *WafRuleUpdateTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

type WafSyncstatusTask ¶ 

type WafSyncstatusTask struct {
	taskman.STask
}

func (*WafSyncstatusTask) OnInit ¶ 

func (self *WafSyncstatusTask) OnInit(ctx context.Context, obj db.IStandaloneModel, body jsonutils.JSONObject)

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.