tasks

Documentation

Index

• func GetSuspendStepDurationWaiting(step v1beta1.WorkflowStep) (time.Duration, error)
• func NewTaskDiscoverFromRevision(ctx monitorContext.Context, providerHandlers providers.Providers, ...) types.TaskDiscover
• func NewViewTaskDiscover(pd *packages.PackageDiscover, cli client.Client, cfg *rest.Config, ...) types.TaskDiscover
• func StepGroup(step v1beta1.WorkflowStep, opt *types.GeneratorOptions) (types.TaskRunner, error)

Functions

func GetSuspendStepDurationWaiting

func GetSuspendStepDurationWaiting(step v1beta1.WorkflowStep) (time.Duration, error)

GetSuspendStepDurationWaiting get suspend step wait duration

func NewTaskDiscoverFromRevision

func NewTaskDiscoverFromRevision(ctx monitorContext.Context, providerHandlers providers.Providers, pd *packages.PackageDiscover, rev *v1beta1.ApplicationRevision, dm discoverymapper.DiscoveryMapper, pCtx process.Context) types.TaskDiscover

NewTaskDiscoverFromRevision will create a client for load task generator from ApplicationRevision.

func NewViewTaskDiscover

func NewViewTaskDiscover(pd *packages.PackageDiscover, cli client.Client, cfg *rest.Config, apply kube.Dispatcher, delete kube.Deleter, viewNs string, logLevel int, pCtx process.Context, loader template.Loader) types.TaskDiscover

NewViewTaskDiscover will create a client for load task generator.

func StepGroup

func StepGroup(step v1beta1.WorkflowStep, opt *types.GeneratorOptions) (types.TaskRunner, error)

StepGroup is the step group runner