tasks

package
v0.3.11-8 Latest Latest
Warning

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

Go to latest
Published: Oct 12, 2024 License: Apache-2.0 Imports: 52 Imported by: 2

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 ¶

type AccessGroupDeleteTask ¶

type AccessGroupDeleteTask struct {
	taskman.STask
}

func (*AccessGroupDeleteTask) OnInit ¶

type AccessGroupRuleCreateTask ¶

type AccessGroupRuleCreateTask struct {
	taskman.STask
}

func (*AccessGroupRuleCreateTask) OnInit ¶

type AccessGroupRuleDeleteTask ¶

type AccessGroupRuleDeleteTask struct {
	taskman.STask
}

func (*AccessGroupRuleDeleteTask) OnInit ¶

type AccessGroupSyncstatusTask ¶

type AccessGroupSyncstatusTask struct {
	taskman.STask
}

func (*AccessGroupSyncstatusTask) OnInit ¶

type AppRemoteUpdateTask ¶

type AppRemoteUpdateTask struct {
	taskman.STask
}

func (*AppRemoteUpdateTask) OnInit ¶

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 ¶

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 ¶

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 (*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 ¶

type BaremetalCreateTask ¶

type BaremetalCreateTask struct {
	SBaremetalBaseTask
}

func (*BaremetalCreateTask) OnInit ¶

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 ¶

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 (*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 ¶

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 (*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 ¶

type BaremetalServerStartTask ¶

type BaremetalServerStartTask struct {
	SGuestBaseTask
}

func (*BaremetalServerStartTask) OnInit ¶

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 (*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 ¶

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 ¶

type BaremetalSyncConfigTask ¶

type BaremetalSyncConfigTask struct {
	SBaremetalBaseTask
}

func (*BaremetalSyncConfigTask) DoSyncConfig ¶

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

func (*BaremetalSyncConfigTask) OnInit ¶

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 (*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 (*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 (*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 (*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 ¶

type BucketDeleteTask ¶

type BucketDeleteTask struct {
	taskman.STask
}

func (*BucketDeleteTask) OnInit ¶

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 ¶

type CDNDomainCreateTask ¶

type CDNDomainCreateTask struct {
	taskman.STask
}

func (*CDNDomainCreateTask) OnInit ¶

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 ¶

type CDNDomainRemoteUpdateTask ¶

type CDNDomainRemoteUpdateTask struct {
	taskman.STask
}

func (*CDNDomainRemoteUpdateTask) OnInit ¶

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 ¶

type CloudAccountDeleteTask ¶

type CloudAccountDeleteTask struct {
	taskman.STask
}

func (*CloudAccountDeleteTask) OnInit ¶

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 ¶

type CloudAccountSyncSkusTask ¶

type CloudAccountSyncSkusTask struct {
	taskman.STask
}

func (*CloudAccountSyncSkusTask) OnInit ¶

type CloudProviderDeleteTask ¶

type CloudProviderDeleteTask struct {
	taskman.STask
}

func (*CloudProviderDeleteTask) OnInit ¶

type CloudProviderSyncInfoTask ¶

type CloudProviderSyncInfoTask struct {
	taskman.STask
}

func (*CloudProviderSyncInfoTask) GetSyncRange ¶

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

func (*CloudProviderSyncInfoTask) OnInit ¶

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 ¶

type CloudpodsGuestCreateDiskTask ¶

type CloudpodsGuestCreateDiskTask struct {
	NutanixGuestCreateDiskTask
}

type CloudregionSyncImagesTask ¶

type CloudregionSyncImagesTask struct {
	taskman.STask
}

func (*CloudregionSyncImagesTask) OnInit ¶

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 (*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 ¶

type DBInstanceAccountDeleteTask ¶

type DBInstanceAccountDeleteTask struct {
	taskman.STask
}

func (*DBInstanceAccountDeleteTask) DeleteDBInstanceAccount ¶

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

func (*DBInstanceAccountDeleteTask) OnInit ¶

type DBInstanceAccountGrantPrivilegeTask ¶

type DBInstanceAccountGrantPrivilegeTask struct {
	taskman.STask
}

func (*DBInstanceAccountGrantPrivilegeTask) OnInit ¶

type DBInstanceAccountResetPasswordTask ¶

type DBInstanceAccountResetPasswordTask struct {
	taskman.STask
}

func (*DBInstanceAccountResetPasswordTask) OnInit ¶

type DBInstanceAccountRevokePrivilegeTask ¶

type DBInstanceAccountRevokePrivilegeTask struct {
	taskman.STask
}

func (*DBInstanceAccountRevokePrivilegeTask) OnInit ¶

type DBInstanceAccountSetPrivilegesTask ¶

type DBInstanceAccountSetPrivilegesTask struct {
	taskman.STask
}

func (*DBInstanceAccountSetPrivilegesTask) OnInit ¶

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 ¶

type DBInstanceBackupDeleteTask ¶

type DBInstanceBackupDeleteTask struct {
	taskman.STask
}

func (*DBInstanceBackupDeleteTask) DeleteDBInstanceBackup ¶

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

func (*DBInstanceBackupDeleteTask) OnInit ¶

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 ¶

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 (*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 (*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 ¶

type DBInstanceDatabaseDeleteTask ¶

type DBInstanceDatabaseDeleteTask struct {
	taskman.STask
}

func (*DBInstanceDatabaseDeleteTask) DeleteDBInstanceDatabase ¶

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

func (*DBInstanceDatabaseDeleteTask) OnInit ¶

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 ¶

type DBInstancePublicConnectionTask ¶

type DBInstancePublicConnectionTask struct {
	taskman.STask
}

func (*DBInstancePublicConnectionTask) DBInstancePublicConnectionOperation ¶

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

func (*DBInstancePublicConnectionTask) OnInit ¶

type DBInstanceRebootTask ¶

type DBInstanceRebootTask struct {
	taskman.STask
}

func (*DBInstanceRebootTask) OnInit ¶

func (*DBInstanceRebootTask) RebootDBInstance ¶

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

type DBInstanceRecoveryTask ¶

type DBInstanceRecoveryTask struct {
	taskman.STask
}

func (*DBInstanceRecoveryTask) OnInit ¶

type DBInstanceRemoteUpdateTask ¶

type DBInstanceRemoteUpdateTask struct {
	taskman.STask
}

func (*DBInstanceRemoteUpdateTask) OnInit ¶

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 (*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 ¶

type DBInstanceSyncSecgroupsTask ¶

type DBInstanceSyncSecgroupsTask struct {
	taskman.STask
}

func (*DBInstanceSyncSecgroupsTask) OnInit ¶

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 (*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 (*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 ¶

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 ¶

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 ¶

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 (*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 (*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 (*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 ¶

type DnsRecordCreateTask ¶

type DnsRecordCreateTask struct {
	taskman.STask
}

func (*DnsRecordCreateTask) OnInit ¶

type DnsRecordDeleteTask ¶

type DnsRecordDeleteTask struct {
	taskman.STask
}

func (*DnsRecordDeleteTask) OnInit ¶

type DnsRecordSetEnabledTask ¶

type DnsRecordSetEnabledTask struct {
	taskman.STask
}

func (*DnsRecordSetEnabledTask) OnInit ¶

type DnsRecordUpdateTask ¶

type DnsRecordUpdateTask struct {
	taskman.STask
}

func (*DnsRecordUpdateTask) OnInit ¶

type DnsZoneAddVpcsTask ¶

type DnsZoneAddVpcsTask struct {
	taskman.STask
}

func (*DnsZoneAddVpcsTask) OnInit ¶

type DnsZoneCreateTask ¶

type DnsZoneCreateTask struct {
	taskman.STask
}

func (*DnsZoneCreateTask) OnInit ¶

type DnsZoneDeleteTask ¶

type DnsZoneDeleteTask struct {
	taskman.STask
}

func (*DnsZoneDeleteTask) OnInit ¶

type DnsZoneRemoveVpcsTask ¶

type DnsZoneRemoveVpcsTask struct {
	taskman.STask
}

func (*DnsZoneRemoveVpcsTask) OnInit ¶

type DnsZoneSyncstatusTask ¶

type DnsZoneSyncstatusTask struct {
	taskman.STask
}

func (*DnsZoneSyncstatusTask) OnInit ¶

type ESXiGuestCreateDiskTask ¶

type ESXiGuestCreateDiskTask struct {
	SGuestCreateDiskBaseTask
}

func (*ESXiGuestCreateDiskTask) OnInit ¶

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 (*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 ¶

type EipChangeBandwidthTask ¶

type EipChangeBandwidthTask struct {
	taskman.STask
}

func (*EipChangeBandwidthTask) OnInit ¶

func (*EipChangeBandwidthTask) TaskFail ¶

type EipDeallocateTask ¶

type EipDeallocateTask struct {
	taskman.STask
}

func (*EipDeallocateTask) OnInit ¶

type EipDissociateTask ¶

type EipDissociateTask struct {
	taskman.STask
}

func (*EipDissociateTask) OnInit ¶

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 (*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 ¶

type ElasticSearchDeleteTask ¶

type ElasticSearchDeleteTask struct {
	taskman.STask
}

func (*ElasticSearchDeleteTask) OnInit ¶

type ElasticSearchRemoteUpdateTask ¶

type ElasticSearchRemoteUpdateTask struct {
	taskman.STask
}

func (*ElasticSearchRemoteUpdateTask) OnInit ¶

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 ¶

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 ¶

type ElasticcacheAccountDeleteTask ¶

type ElasticcacheAccountDeleteTask struct {
	taskman.STask
}

func (*ElasticcacheAccountDeleteTask) OnInit ¶

type ElasticcacheAccountResetPasswordTask ¶

type ElasticcacheAccountResetPasswordTask struct {
	taskman.STask
}

func (*ElasticcacheAccountResetPasswordTask) OnInit ¶

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 ¶

type ElasticcacheAclDeleteTask ¶

type ElasticcacheAclDeleteTask struct {
	taskman.STask
}

func (*ElasticcacheAclDeleteTask) OnInit ¶

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 ¶

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 ¶

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 ¶

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 ¶

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 ¶

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 (*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 ¶

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 ¶

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 ¶

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 ¶

type ElasticcacheRemoteUpdateTask ¶

type ElasticcacheRemoteUpdateTask struct {
	taskman.STask
}

func (*ElasticcacheRemoteUpdateTask) OnInit ¶

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 ¶

type ElasticcacheRestartTask ¶

type ElasticcacheRestartTask struct {
	taskman.STask
}

func (*ElasticcacheRestartTask) OnInit ¶

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 ¶

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 ¶

type ElasticcacheSyncTask ¶

type ElasticcacheSyncTask struct {
	taskman.STask
}

func (*ElasticcacheSyncTask) OnInit ¶

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 ¶

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 ¶

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 ¶

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 ¶

type ExternalProjectCreateTask ¶

type ExternalProjectCreateTask struct {
	taskman.STask
}

func (*ExternalProjectCreateTask) OnInit ¶

type FileSystemCreateTask ¶

type FileSystemCreateTask struct {
	taskman.STask
}

func (*FileSystemCreateTask) OnInit ¶

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 ¶

type FileSystemRemoteUpdateTask ¶

type FileSystemRemoteUpdateTask struct {
	taskman.STask
}

func (*FileSystemRemoteUpdateTask) OnInit ¶

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 ¶

type GlobalVpcCreateTask ¶

type GlobalVpcCreateTask struct {
	taskman.STask
}

func (*GlobalVpcCreateTask) OnInit ¶

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 ¶

type GlobalVpcSyncstatusTask ¶

type GlobalVpcSyncstatusTask struct {
	taskman.STask
}

func (*GlobalVpcSyncstatusTask) OnInit ¶

type GuestAttachDiskTask ¶

type GuestAttachDiskTask struct {
	SGuestBaseTask
}

func (*GuestAttachDiskTask) OnInit ¶

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 (*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 (*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 (*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 (*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 (*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 (*GuestChangeDisksStorageTask) GetInputParams ¶

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 (*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 (*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 (*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 ¶

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 (*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 ¶

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 (*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 (*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 (*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 ¶

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 ¶

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 (*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 ¶

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 (*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 ¶

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 ¶

type GuestHardResetTask ¶

type GuestHardResetTask struct {
	SGuestBaseTask
}

func (*GuestHardResetTask) OnInit ¶

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 (*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 (*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 (*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 (*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 ¶

type GuestQgaRestartNetworkTask ¶

type GuestQgaRestartNetworkTask struct {
	SGuestBaseTask
}

func (*GuestQgaRestartNetworkTask) OnInit ¶

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 ¶

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 (*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 (*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 (*GuestSetNicTrafficsTask) OnSetNicTrafficLimit ¶

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

type GuestSoftResetTask ¶

type GuestSoftResetTask struct {
	SGuestBaseTask
}

func (*GuestSoftResetTask) OnInit ¶

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 (*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) OnInit ¶

func (self *GuestStartTask) OnInit(ctx context.Context, obj db.IStandaloneModel, 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 (*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) 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 (*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 ¶

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 (*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 ¶

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 (*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 ¶

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 ¶

type HostGuestsMigrateTask ¶

type HostGuestsMigrateTask struct {
	taskman.STask
}

func (*HostGuestsMigrateTask) OnInit ¶

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 (*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 (*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 ¶

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 ¶

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 (*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 (*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 (*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 (*InstanceBackupRecoveryTask) OnCreateGuestFailed ¶

func (self *InstanceBackupRecoveryTask) OnCreateGuestFailed(ctx context.Context, ib *models.SInstanceBackup, data jsonutils.JSONObject)

func (*InstanceBackupRecoveryTask) OnInit ¶

type InstanceBackupSyncstatusTask ¶

type InstanceBackupSyncstatusTask struct {
	taskman.STask
}

func (*InstanceBackupSyncstatusTask) OnInit ¶

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 (*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 (*InstanceSnapshotAndCloneTask) SetStageFailed ¶

func (self *InstanceSnapshotAndCloneTask) SetStageFailed(ctx context.Context, reason jsonutils.JSONObject)

type InstanceSnapshotCreateTask ¶

type InstanceSnapshotCreateTask struct {
	taskman.STask
}

func (*InstanceSnapshotCreateTask) OnInit ¶

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 (*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 (*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 (*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 ¶

type InterVpcNetworkDeleteTask ¶

type InterVpcNetworkDeleteTask struct {
	taskman.STask
}

func (*InterVpcNetworkDeleteTask) OnInit ¶

type InterVpcNetworkRemoveVpcTask ¶

type InterVpcNetworkRemoveVpcTask struct {
	taskman.STask
}

func (*InterVpcNetworkRemoveVpcTask) OnInit ¶

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 ¶

type InterVpcNetworkUpdateRoutesetTask ¶

type InterVpcNetworkUpdateRoutesetTask struct {
	taskman.STask
}

func (*InterVpcNetworkUpdateRoutesetTask) OnInit ¶

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 (*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 (*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 (*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 ¶

type KubeClusterCreateTask ¶

type KubeClusterCreateTask struct {
	taskman.STask
}

func (*KubeClusterCreateTask) OnInit ¶

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 ¶

type KubeClusterSyncstatusTask ¶

type KubeClusterSyncstatusTask struct {
	taskman.STask
}

func (*KubeClusterSyncstatusTask) OnInit ¶

type KubeNodePoolCreateTask ¶

type KubeNodePoolCreateTask struct {
	taskman.STask
}

func (*KubeNodePoolCreateTask) OnInit ¶

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 ¶

type KubeNodePoolSyncstatusTask ¶

type KubeNodePoolSyncstatusTask struct {
	taskman.STask
}

func (*KubeNodePoolSyncstatusTask) OnInit ¶

type LoadbalancerAclCreateTask ¶

type LoadbalancerAclCreateTask struct {
	taskman.STask
}

func (*LoadbalancerAclCreateTask) OnInit ¶

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 ¶

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 ¶

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 ¶

type ModelartsPoolChangeConfigTask ¶

type ModelartsPoolChangeConfigTask struct {
	taskman.STask
}

func (*ModelartsPoolChangeConfigTask) OnInit ¶

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 ¶

type MongoDBDeleteTask ¶

type MongoDBDeleteTask struct {
	taskman.STask
}

func (*MongoDBDeleteTask) OnInit ¶

type MongoDBRemoteUpdateTask ¶

type MongoDBRemoteUpdateTask struct {
	taskman.STask
}

func (*MongoDBRemoteUpdateTask) OnInit ¶

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 ¶

type MountTargetCreateTask ¶

type MountTargetCreateTask struct {
	taskman.STask
}

func (*MountTargetCreateTask) OnInit ¶

type MountTargetDeleteTask ¶

type MountTargetDeleteTask struct {
	taskman.STask
}

func (*MountTargetDeleteTask) OnInit ¶

type MountTargetSyncstatusTask ¶

type MountTargetSyncstatusTask struct {
	taskman.STask
}

func (*MountTargetSyncstatusTask) OnInit ¶

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 (*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 ¶

type NatGatewayRemoteUpdateTask ¶

type NatGatewayRemoteUpdateTask struct {
	taskman.STask
}

func (*NatGatewayRemoteUpdateTask) OnInit ¶

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 (*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 (*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 (*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 ¶

type NetworkDeleteTask ¶

type NetworkDeleteTask struct {
	taskman.STask
}

func (*NetworkDeleteTask) OnInit ¶

type NetworkRemoteUpdateTask ¶

type NetworkRemoteUpdateTask struct {
	taskman.STask
}

func (*NetworkRemoteUpdateTask) OnInit ¶

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 ¶

type NetworksUnderWireMergeTask ¶

type NetworksUnderWireMergeTask struct {
	taskman.STask
}

func (*NetworksUnderWireMergeTask) OnInit ¶

type NutanixGuestCreateDiskTask ¶

type NutanixGuestCreateDiskTask struct {
	SGuestCreateDiskBaseTask
}

func (*NutanixGuestCreateDiskTask) OnInit ¶

type PrepaidRecycleHostRenewTask ¶

type PrepaidRecycleHostRenewTask struct {
	taskman.STask
}

func (*PrepaidRecycleHostRenewTask) OnInit ¶

type ProxmoxGuestCreateDiskTask ¶

type ProxmoxGuestCreateDiskTask struct {
	ESXiGuestCreateDiskTask
}

type RbdStorageUpdateTask ¶

type RbdStorageUpdateTask struct {
	taskman.STask
}

func (*RbdStorageUpdateTask) OnInit ¶

type RouteTableSyncStatusTask ¶

type RouteTableSyncStatusTask struct {
	taskman.STask
}

func (*RouteTableSyncStatusTask) OnInit ¶

type RouteTableUpdateTask ¶

type RouteTableUpdateTask struct {
	taskman.STask
}

func (*RouteTableUpdateTask) OnInit ¶

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 ¶

type SNatDEntryDeleteTask ¶

type SNatDEntryDeleteTask struct {
	taskman.STask
}

func (*SNatDEntryDeleteTask) OnInit ¶

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 ¶

type SNatSEntryDeleteTask ¶

type SNatSEntryDeleteTask struct {
	taskman.STask
}

func (*SNatSEntryDeleteTask) OnInit ¶

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 ScalingGroupDeleteTask ¶

type ScalingGroupDeleteTask struct {
	taskman.STask
}

func (*ScalingGroupDeleteTask) OnInit ¶

type SecurityGroupCreateTask ¶

type SecurityGroupCreateTask struct {
	taskman.STask
}

func (*SecurityGroupCreateTask) OnInit ¶

type SecurityGroupDeleteTask ¶

type SecurityGroupDeleteTask struct {
	taskman.STask
}

func (*SecurityGroupDeleteTask) OnInit ¶

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 ¶

type SecurityGroupRuleCreateTask ¶

type SecurityGroupRuleCreateTask struct {
	taskman.STask
}

func (*SecurityGroupRuleCreateTask) OnInit ¶

type SecurityGroupRuleDeleteTask ¶

type SecurityGroupRuleDeleteTask struct {
	taskman.STask
}

func (*SecurityGroupRuleDeleteTask) OnInit ¶

type SecurityGroupRuleUpdateTask ¶

type SecurityGroupRuleUpdateTask struct {
	taskman.STask
}

func (*SecurityGroupRuleUpdateTask) OnInit ¶

type SecurityGroupSyncTask ¶

type SecurityGroupSyncTask struct {
	taskman.STask
}

func (*SecurityGroupSyncTask) OnInit ¶

type ServerSkuCreateTask ¶

type ServerSkuCreateTask struct {
	taskman.STask
}

func (*ServerSkuCreateTask) OnInit ¶

type ServerSkuDeleteTask ¶

type ServerSkuDeleteTask struct {
	taskman.STask
}

func (*ServerSkuDeleteTask) OnInit ¶

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 (*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 (*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 (*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 ¶

type SnapshotPolicyDeleteTask ¶

type SnapshotPolicyDeleteTask struct {
	taskman.STask
}

func (*SnapshotPolicyDeleteTask) OnInit ¶

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 (*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 (*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 ¶

type SnapshotpolicyUnbindDisksTask ¶

type SnapshotpolicyUnbindDisksTask struct {
	taskman.STask
}

func (*SnapshotpolicyUnbindDisksTask) OnInit ¶

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 (*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 ¶

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 (*StorageUncacheImageTask) OnTaskFailed ¶

func (self *StorageUncacheImageTask) OnTaskFailed(ctx context.Context, storageCache *models.SStoragecache, reason jsonutils.JSONObject)

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 (*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 ¶

type VpcPeeringConnectionDeleteTask ¶

type VpcPeeringConnectionDeleteTask struct {
	taskman.STask
}

func (*VpcPeeringConnectionDeleteTask) OnInit ¶

type VpcPeeringConnectionSyncstatusTask ¶

type VpcPeeringConnectionSyncstatusTask struct {
	taskman.STask
}

func (*VpcPeeringConnectionSyncstatusTask) OnInit ¶

type VpcSyncstatusTask ¶

type VpcSyncstatusTask struct {
	taskman.STask
}

func (*VpcSyncstatusTask) OnInit ¶

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 ¶

type WafInstanceRemoteUpdateTask ¶

type WafInstanceRemoteUpdateTask struct {
	taskman.STask
}

func (*WafInstanceRemoteUpdateTask) OnInit ¶

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 ¶

type WafRuleCreateTask ¶

type WafRuleCreateTask struct {
	taskman.STask
}

func (*WafRuleCreateTask) OnInit ¶

type WafRuleDeleteTask ¶

type WafRuleDeleteTask struct {
	taskman.STask
}

func (*WafRuleDeleteTask) OnInit ¶

type WafRuleSyncstatusTask ¶

type WafRuleSyncstatusTask struct {
	taskman.STask
}

func (*WafRuleSyncstatusTask) OnInit ¶

type WafRuleUpdateTask ¶

type WafRuleUpdateTask struct {
	taskman.STask
}

func (*WafRuleUpdateTask) OnInit ¶

type WafSyncstatusTask ¶

type WafSyncstatusTask struct {
	taskman.STask
}

func (*WafSyncstatusTask) OnInit ¶

Source Files ¶

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL