executor

Documentation

Index

• Constants
• func CheckSnapshotDeleted(volumeId string) bool
• func ExecuteAsynchronizedWorkflow(asynWorkflow AsynchronizedWorkflow) error
• func ExecuteSynchronizedWorkflow(synWorkflow SynchronizedWorkflow) error
• func ParseInterval(interval string) (int, error)
• type AsynchronizedExecutor
• type AsynchronizedWorkflow
  • func RegisterAsynchronizedWorkflow(req interface{}, tags map[string]string, dockInfo *model.DockSpec, in string) (AsynchronizedWorkflow, error)
• type DeleteSnapshotExecutor
  • func (dse *DeleteSnapshotExecutor) Asynchronized() error
  • func (dse *DeleteSnapshotExecutor) Init(in string) (err error)
• type IntervalSnapshotExecutor
  • func (ise *IntervalSnapshotExecutor) Asynchronized() error
  • func (ise *IntervalSnapshotExecutor) Init(in string) (err error)
• type SynchronizedExecutor
• type SynchronizedWorkflow
  • func RegisterSynchronizedWorkflow(req interface{}, tags map[string]interface{}) (SynchronizedWorkflow, error)

Constants

const (
	RETRY_INTERVAL = 5
	MAX_RETRY_TIME = 10
)

Functions

func CheckSnapshotDeleted

func CheckSnapshotDeleted(volumeId string) bool

func ExecuteAsynchronizedWorkflow

func ExecuteAsynchronizedWorkflow(asynWorkflow AsynchronizedWorkflow) error

ExecuteAsynchronizedWorkflow

func ExecuteSynchronizedWorkflow

func ExecuteSynchronizedWorkflow(synWorkflow SynchronizedWorkflow) error

ExecuteSynchronizedWorkflow

func ParseInterval

func ParseInterval(interval string) (int, error)

Types

type AsynchronizedExecutor

type AsynchronizedExecutor interface {
	Init(in string) error
	Asynchronized() error
}

AsynchronizedExecutor

type AsynchronizedWorkflow

type AsynchronizedWorkflow map[string]AsynchronizedExecutor

AsynchronizedWorkflow

func RegisterAsynchronizedWorkflow

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

RegisterAsynchronizedWorkflow

type DeleteSnapshotExecutor

type DeleteSnapshotExecutor struct {
	client.Client

	VolumeId string
	Request  *pb.DeleteVolumeSnapshotOpts
	DockInfo *model.DockSpec
}

func (*DeleteSnapshotExecutor) Asynchronized

func (dse *DeleteSnapshotExecutor) Asynchronized() error

func (*DeleteSnapshotExecutor) Init

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

type IntervalSnapshotExecutor

type IntervalSnapshotExecutor struct {
	client.Client

	Request  *pb.CreateVolumeSnapshotOpts
	DockInfo *model.DockSpec
	Interval string
	TotalNum int
}

func (*IntervalSnapshotExecutor) Asynchronized

func (ise *IntervalSnapshotExecutor) Asynchronized() error

func (*IntervalSnapshotExecutor) Init

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

type SynchronizedExecutor

type SynchronizedExecutor interface {
	Init() error
	Synchronized() error
}

SynchronizedExecutor

type SynchronizedWorkflow

type SynchronizedWorkflow map[string]SynchronizedExecutor

SynchronizedWorkflow

func RegisterSynchronizedWorkflow

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

RegisterSynchronizedWorkflow