executor

Mar 15, 2018

Changes in this version

+ const MAX_RETRY_TIME

+ const RETRY_INTERVAL

+ func CheckSnapshotDeleted(volumeId string) bool

+ func ExecuteAsynchronizedWorkflow(asynWorkflow AsynchronizedWorkflow) error

+ func ExecuteSynchronizedWorkflow(synWorkflow SynchronizedWorkflow) error

+ func ParseInterval(interval string) (int, error)

+ type AsynchronizedExecutor interface

+ Asynchronized func() error

+ Init func(in string) error

+ type AsynchronizedWorkflow map[string]AsynchronizedExecutor

+ func RegisterAsynchronizedWorkflow(req interface{}, tags map[string]string, dockInfo *model.DockSpec, in string) (AsynchronizedWorkflow, error)

+ type DeleteSnapshotExecutor struct

+ DockInfo *model.DockSpec

+ Request *pb.DeleteVolumeSnapshotOpts

+ VolumeId string

+ func (dse *DeleteSnapshotExecutor) Asynchronized() error

+ func (dse *DeleteSnapshotExecutor) Init(in string) (err error)

+ type IntervalSnapshotExecutor struct

+ DockInfo *model.DockSpec

+ Interval string

+ Request *pb.CreateVolumeSnapshotOpts

+ TotalNum int

+ func (ise *IntervalSnapshotExecutor) Asynchronized() error

+ func (ise *IntervalSnapshotExecutor) Init(in string) (err error)

+ type SynchronizedExecutor interface

+ Init func() error

+ Synchronized func() error

+ type SynchronizedWorkflow map[string]SynchronizedExecutor

+ func RegisterSynchronizedWorkflow(req interface{}, tags map[string]interface{}) (SynchronizedWorkflow, error)