Documentation ¶
Index ¶
- func CloudSync(conf *SyncConf) error
- func NewTaskProcessor(scheduler *taskScheduler) *taskProcessor
- func NewTaskScheduler(conf *SchedulerConf) (*taskScheduler, error)
- func SyncCloudResource(taskChan chan *metadata.CloudSyncTask, conf *SyncConf)
- type CloudSyncInterface
- type HostSyncor
- type SchedulerConf
- type SyncConf
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTaskProcessor ¶
func NewTaskProcessor(scheduler *taskScheduler) *taskProcessor
func SyncCloudResource ¶
func SyncCloudResource(taskChan chan *metadata.CloudSyncTask, conf *SyncConf)
同步云资源
Types ¶
type CloudSyncInterface ¶
type CloudSyncInterface interface {
Sync(task chan *metadata.CloudSyncTask) error
}
云同步接口
type HostSyncor ¶
type HostSyncor struct {
// contains filtered or unexported fields
}
云主机同步器
func (*HostSyncor) SetSyncResultStatus ¶
func (h *HostSyncor) SetSyncResultStatus(syncResult *metadata.SyncResult, startTime time.Time) error
设置SyncResult的状态信息
Click to show internal directories.
Click to hide internal directories.