task

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func QualifyImageName 

func QualifyImageName(snapshot string) (err error)

func QualifyNormalName 

func QualifyNormalName(input string) (err error)

func QualifySnapshotName 

func QualifySnapshotName(snapshot string) (err error)

Types

type AddAddressRangeExecutor 

type AddAddressRangeExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*AddAddressRangeExecutor) Execute 

func (executor *AddAddressRangeExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type AddComputePoolExecutor 

type AddComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*AddComputePoolExecutor) Execute 

func (executor *AddComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type CreateAddressPoolExecutor 

type CreateAddressPoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*CreateAddressPoolExecutor) Execute 

func (executor *CreateAddressPoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type CreateComputePoolExecutor 

type CreateComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*CreateComputePoolExecutor) Execute 

func (executor *CreateComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type CreateDiskImageExecutor 

type CreateDiskImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
	Client         *http.Client
}

func (*CreateDiskImageExecutor) Execute 

func (executor *CreateDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type CreateGuestExecutor 

type CreateGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
	Client         *http.Client
}

func (*CreateGuestExecutor) CancelResource 

func (executor *CreateGuestExecutor) CancelResource(id string) error

func (*CreateGuestExecutor) Execute 

func (executor *CreateGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

func (*CreateGuestExecutor) ResponseFail 

func (executor *CreateGuestExecutor) ResponseFail(resp framework.Message, err, target string) error

type CreateMediaImageExecutor 

type CreateMediaImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*CreateMediaImageExecutor) Execute 

func (executor *CreateMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type CreateMigrationExecutor 

type CreateMigrationExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*CreateMigrationExecutor) Execute 

func (executor *CreateMigrationExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type CreateSnapshotExecutor 

type CreateSnapshotExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*CreateSnapshotExecutor) Execute 

func (executor *CreateSnapshotExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type CreateStoragePoolExecutor 

type CreateStoragePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*CreateStoragePoolExecutor) Execute 

func (executor *CreateStoragePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DeleteAddressPoolExecutor 

type DeleteAddressPoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteAddressPoolExecutor) Execute 

func (executor *DeleteAddressPoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DeleteComputePoolExecutor 

type DeleteComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteComputePoolExecutor) Execute 

func (executor *DeleteComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type DeleteDiskImageExecutor 

type DeleteDiskImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteDiskImageExecutor) Execute 

func (executor *DeleteDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DeleteGuestExecutor 

type DeleteGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteGuestExecutor) Execute 

func (executor *DeleteGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type DeleteMediaImageExecutor 

type DeleteMediaImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteMediaImageExecutor) Execute 

func (executor *DeleteMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type DeleteSnapshotExecutor 

type DeleteSnapshotExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteSnapshotExecutor) Execute 

func (executor *DeleteSnapshotExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type DeleteStoragePoolExecutor 

type DeleteStoragePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DeleteStoragePoolExecutor) Execute 

func (executor *DeleteStoragePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type DisableComputeCellExecutor 

type DisableComputeCellExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*DisableComputeCellExecutor) Execute 

func (executor *DisableComputeCellExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type EjectMediaExecutor 

type EjectMediaExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*EjectMediaExecutor) Execute 

func (executor *EjectMediaExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type EnableComputeCellExecutor 

type EnableComputeCellExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*EnableComputeCellExecutor) Execute 

func (executor *EnableComputeCellExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetAddressPoolExecutor 

type GetAddressPoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetAddressPoolExecutor) Execute 

func (executor *GetAddressPoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetAddressRangeExecutor 

type GetAddressRangeExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetAddressRangeExecutor) Execute 

func (executor *GetAddressRangeExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetBatchCreateGuestExecutor 

type GetBatchCreateGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetBatchCreateGuestExecutor) Execute 

func (executor *GetBatchCreateGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetBatchDeleteGuestExecutor 

type GetBatchDeleteGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetBatchDeleteGuestExecutor) Execute 

func (executor *GetBatchDeleteGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetBatchStopGuestExecutor 

type GetBatchStopGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetBatchStopGuestExecutor) Execute 

func (executor *GetBatchStopGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetComputeCellExecutor 

type GetComputeCellExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetComputeCellExecutor) Execute 

func (executor *GetComputeCellExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetComputeCellStatusExecutor 

type GetComputeCellStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetComputeCellStatusExecutor) Execute 

func (executor *GetComputeCellStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type GetComputePoolExecutor 

type GetComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetComputePoolExecutor) Execute 

func (executor *GetComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetComputePoolStatusExecutor 

type GetComputePoolStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetComputePoolStatusExecutor) Execute 

func (executor *GetComputePoolStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type GetDiskImageExecutor 

type GetDiskImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetDiskImageExecutor) Execute 

func (executor *GetDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetGuestConfigExecutor 

type GetGuestConfigExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetGuestConfigExecutor) Execute 

func (executor *GetGuestConfigExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type GetGuestPasswordExecutor 

type GetGuestPasswordExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetGuestPasswordExecutor) Execute 

func (executor *GetGuestPasswordExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type GetInstanceStatusExecutor 

type GetInstanceStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetInstanceStatusExecutor) Execute 

func (executor *GetInstanceStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type GetMediaImageExecutor 

type GetMediaImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetMediaImageExecutor) Execute 

func (executor *GetMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetMigrationExecutor 

type GetMigrationExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetMigrationExecutor) Execute 

func (executor *GetMigrationExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type GetSnapshotExecutor 

type GetSnapshotExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetSnapshotExecutor) Execute 

func (executor *GetSnapshotExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type GetStoragePoolExecutor 

type GetStoragePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*GetStoragePoolExecutor) Execute 

func (executor *GetStoragePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type HandleAddressChangedExecutor 

type HandleAddressChangedExecutor struct {
	ResourceModule modules.ResourceModule
}

func (*HandleAddressChangedExecutor) Execute 

func (executor *HandleAddressChangedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleCellAvailableExecutor 

type HandleCellAvailableExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleCellAvailableExecutor) Execute 

func (executor *HandleCellAvailableExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleCellDisconnectedExecutor 

type HandleCellDisconnectedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleCellDisconnectedExecutor) Execute 

func (executor *HandleCellDisconnectedExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type HandleCellStatusUpdatedExecutor 

type HandleCellStatusUpdatedExecutor struct {
	ResourceModule modules.ResourceModule
}

func (*HandleCellStatusUpdatedExecutor) Execute 

func (executor *HandleCellStatusUpdatedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleGuestCreatedExecutor 

type HandleGuestCreatedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleGuestCreatedExecutor) Execute 

func (executor *HandleGuestCreatedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleGuestDeletedExecutor 

type HandleGuestDeletedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleGuestDeletedExecutor) Execute 

func (executor *HandleGuestDeletedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleGuestStartedExecutor 

type HandleGuestStartedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleGuestStartedExecutor) Execute 

func (executor *HandleGuestStartedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleGuestStoppedExecutor 

type HandleGuestStoppedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleGuestStoppedExecutor) Execute 

func (executor *HandleGuestStoppedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleGuestSystemResetExecutor 

type HandleGuestSystemResetExecutor struct {
	ResourceModule modules.ResourceModule
}

func (*HandleGuestSystemResetExecutor) Execute 

func (executor *HandleGuestSystemResetExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type HandleGuestUpdatedExecutor 

type HandleGuestUpdatedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleGuestUpdatedExecutor) Execute 

func (executor *HandleGuestUpdatedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleInstanceMigratedExecutor 

type HandleInstanceMigratedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleInstanceMigratedExecutor) Execute 

func (executor *HandleInstanceMigratedExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type HandleMediaAttachedExecutor 

type HandleMediaAttachedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleMediaAttachedExecutor) Execute 

func (executor *HandleMediaAttachedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type HandleMediaDetachedExecutor 

type HandleMediaDetachedExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*HandleMediaDetachedExecutor) Execute 

func (executor *HandleMediaDetachedExecutor) Execute(id framework.SessionID, event framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type InsertMediaExecutor 

type InsertMediaExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*InsertMediaExecutor) Execute 

func (executor *InsertMediaExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyAddressPoolExecutor 

type ModifyAddressPoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyAddressPoolExecutor) Execute 

func (executor *ModifyAddressPoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type ModifyComputePoolExecutor 

type ModifyComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyComputePoolExecutor) Execute 

func (executor *ModifyComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyDiskImageExecutor 

type ModifyDiskImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyDiskImageExecutor) Execute 

func (executor *ModifyDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type ModifyGuestCoreExecutor 

type ModifyGuestCoreExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestCoreExecutor) Execute 

func (executor *ModifyGuestCoreExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyGuestDiskThresholdExecutor 

type ModifyGuestDiskThresholdExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestDiskThresholdExecutor) Execute 

func (executor *ModifyGuestDiskThresholdExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type ModifyGuestMemoryExecutor 

type ModifyGuestMemoryExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestMemoryExecutor) Execute 

func (executor *ModifyGuestMemoryExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyGuestNameExecutor 

type ModifyGuestNameExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestNameExecutor) Execute 

func (executor *ModifyGuestNameExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyGuestNetworkThresholdExecutor 

type ModifyGuestNetworkThresholdExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestNetworkThresholdExecutor) Execute 

func (executor *ModifyGuestNetworkThresholdExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type ModifyGuestPasswordExecutor 

type ModifyGuestPasswordExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestPasswordExecutor) Execute 

func (executor *ModifyGuestPasswordExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyGuestPriorityExecutor 

type ModifyGuestPriorityExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyGuestPriorityExecutor) Execute 

func (executor *ModifyGuestPriorityExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ModifyMediaImageExecutor 

type ModifyMediaImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyMediaImageExecutor) Execute 

func (executor *ModifyMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type ModifyStoragePoolExecutor 

type ModifyStoragePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ModifyStoragePoolExecutor) Execute 

func (executor *ModifyStoragePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryAddressPoolExecutor 

type QueryAddressPoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryAddressPoolExecutor) Execute 

func (executor *QueryAddressPoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryAddressRangeExecutor 

type QueryAddressRangeExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryAddressRangeExecutor) Execute 

func (executor *QueryAddressRangeExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryCellsByPoolExecutor 

type QueryCellsByPoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryCellsByPoolExecutor) Execute 

func (executor *QueryCellsByPoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryComputeCellStatusExecutor 

type QueryComputeCellStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryComputeCellStatusExecutor) Execute 

func (executor *QueryComputeCellStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryComputePoolExecutor 

type QueryComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryComputePoolExecutor) Execute 

func (executor *QueryComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryComputePoolStatusExecutor 

type QueryComputePoolStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryComputePoolStatusExecutor) Execute 

func (executor *QueryComputePoolStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryDiskImageExecutor 

type QueryDiskImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryDiskImageExecutor) Execute 

func (executor *QueryDiskImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryGuestConfigExecutor 

type QueryGuestConfigExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryGuestConfigExecutor) Execute 

func (executor *QueryGuestConfigExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryInstanceStatusExecutor 

type QueryInstanceStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryInstanceStatusExecutor) Execute 

func (executor *QueryInstanceStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryMediaImageExecutor 

type QueryMediaImageExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryMediaImageExecutor) Execute 

func (executor *QueryMediaImageExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QueryMigrationExecutor 

type QueryMigrationExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryMigrationExecutor) Execute 

func (executor *QueryMigrationExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type QuerySnapshotExecutor 

type QuerySnapshotExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QuerySnapshotExecutor) Execute 

func (executor *QuerySnapshotExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryStoragePoolExecutor 

type QueryStoragePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryStoragePoolExecutor) Execute 

func (executor *QueryStoragePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryUnallocatedCellsExecutor 

type QueryUnallocatedCellsExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryUnallocatedCellsExecutor) Execute 

func (executor *QueryUnallocatedCellsExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type QueryZoneStatusExecutor 

type QueryZoneStatusExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*QueryZoneStatusExecutor) Execute 

func (executor *QueryZoneStatusExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type RemoveAddressRangeExecutor 

type RemoveAddressRangeExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*RemoveAddressRangeExecutor) Execute 

func (executor *RemoveAddressRangeExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type RemoveComputePoolExecutor 

type RemoveComputePoolExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*RemoveComputePoolExecutor) Execute 

func (executor *RemoveComputePoolExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ResetGuestSystemExecutor 

type ResetGuestSystemExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
	Client         *http.Client
}

func (*ResetGuestSystemExecutor) Execute 

func (executor *ResetGuestSystemExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

func (*ResetGuestSystemExecutor) ResponseFail 

func (executor *ResetGuestSystemExecutor) ResponseFail(resp framework.Message, err, target string) error

type ResizeGuestDiskExecutor 

type ResizeGuestDiskExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ResizeGuestDiskExecutor) Execute 

func (executor *ResizeGuestDiskExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type RestoreSnapshotExecutor 

type RestoreSnapshotExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*RestoreSnapshotExecutor) Execute 

func (executor *RestoreSnapshotExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type ShrinkGuestDiskExecutor 

type ShrinkGuestDiskExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*ShrinkGuestDiskExecutor) Execute 

func (executor *ShrinkGuestDiskExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type StartBatchCreateGuestExecutor 

type StartBatchCreateGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*StartBatchCreateGuestExecutor) Execute 

func (executor *StartBatchCreateGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type StartBatchDeleteGuestExecutor 

type StartBatchDeleteGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*StartBatchDeleteGuestExecutor) Execute 

func (executor *StartBatchDeleteGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type StartBatchStopGuestExecutor 

type StartBatchStopGuestExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*StartBatchStopGuestExecutor) Execute 

func (executor *StartBatchStopGuestExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

type StartInstanceExecutor 

type StartInstanceExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*StartInstanceExecutor) Execute 

func (executor *StartInstanceExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type StopInstanceExecutor 

type StopInstanceExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
}

func (*StopInstanceExecutor) Execute 

func (executor *StopInstanceExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) error

type SyncImageServerExecutor 

type SyncImageServerExecutor struct {
	Sender         framework.MessageSender
	ResourceModule modules.ResourceModule
	Client         *http.Client
}

func (*SyncImageServerExecutor) Execute 

func (executor *SyncImageServerExecutor) Execute(id framework.SessionID, request framework.Message,
	incoming chan framework.Message, terminate chan bool) (err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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