flow

func (*Flow) Chunks ¶

func (f *Flow) Chunks()

Chunks is the handle method for generic Chunk package.

func (*Flow) Date ¶

func (f *Flow) Date() error

Date is the handle method for generic Auto Increment or Decrement package.

func (*Flow) EvalRetry ¶

func (f *Flow) EvalRetry() bool

func (*Flow) Execute ¶

func (f *Flow) Execute()

Execute is a method to render and execute command and save result into variables and then are interpreted to take other decisions.

func (*Flow) GetChunkLimit ¶

func (f *Flow) GetChunkLimit() int

GetChunkLimit get the limit of chunks from config or variables.

func (*Flow) GetChunkTotal ¶

func (f *Flow) GetChunkTotal() int

GetChunkTotal get the total of chunks from config or variables.

func (*Flow) GetFormat ¶

func (f *Flow) GetFormat() config.Format

func (*Flow) GetGlobalVariables ¶

func (f *Flow) GetGlobalVariables() map[string]interface{}

func (*Flow) GetPipePrint ¶

func (f *Flow) GetPipePrint() []string

func (*Flow) GetPipeUnset ¶

func (f *Flow) GetPipeUnset() []string

func (*Flow) GetPipeVariables ¶

func (f *Flow) GetPipeVariables() map[string]interface{}

func (*Flow) GetProperty ¶

func (f *Flow) GetProperty(name string) string

GetProperty get value string by key name from config struct.

func (*Flow) GetRetryAttempts ¶

func (f *Flow) GetRetryAttempts() int

func (*Flow) GetRetryExpression ¶

func (f *Flow) GetRetryExpression() string

func (*Flow) GetRetryWait ¶

func (f *Flow) GetRetryWait() int

func (*Flow) GetSlackChannel ¶

func (f *Flow) GetSlackChannel() string

func (*Flow) GetSlackColor ¶

func (f *Flow) GetSlackColor() string

func (*Flow) GetSlackExpression ¶

func (f *Flow) GetSlackExpression() string

func (*Flow) GetSlackMessage ¶

func (f *Flow) GetSlackMessage() string

func (*Flow) GetSlackTitle ¶

func (f *Flow) GetSlackTitle() string

func (*Flow) GetSubTaskVariables ¶

func (f *Flow) GetSubTaskVariables() map[string]interface{}

func (*Flow) GetTitle ¶

func (f *Flow) GetTitle() string

func (*Flow) GetVariable ¶

func (f *Flow) GetVariable(name string) interface{}

func (*Flow) IsValidChunk ¶

func (f *Flow) IsValidChunk() bool

IsValidChunk is the sanity check for settings.

func (*Flow) List ¶

func (f *Flow) List()

func (*Flow) PipeName ¶

func (f *Flow) PipeName() string

func (*Flow) Pipes ¶

func (f *Flow) Pipes()

func (*Flow) PrintRetry ¶

func (f *Flow) PrintRetry()

PrintRetry show the retry progress.

func (*Flow) Render ¶

func (f *Flow) Render(s string) string

Render a template with variables.

func (*Flow) Retry ¶

func (f *Flow) Retry(fn func())

func (*Flow) Run ¶

func (f *Flow) Run()

func (*Flow) SetDefaults ¶

func (f *Flow) SetDefaults()

func (*Flow) SubTaskName ¶

func (f *Flow) SubTaskName() string

func (*Flow) Subtask ¶

func (f *Flow) Subtask()

func (*Flow) TaskName ¶

func (f *Flow) TaskName() string

func (*Flow) Tasks ¶

func (f *Flow) Tasks()

func (*Flow) Valid ¶

func (f *Flow) Valid(pipeName string) bool