builder

Documentation

Index

• func ExamplesExecFlowFile(opts ...Option) *executable.FlowFile
• func ExamplesMultiExecFlowFile(opts ...Option) *executable.FlowFile
• func ExamplesRequestExecFlowFile(opts ...Option) *executable.FlowFile
• func ExecWithArgs(opts ...Option) *executable.Executable
• func ExecWithExit(opts ...Option) *executable.Executable
• func ExecWithLogMode(opts ...Option) *executable.Executable
• func ExecWithParams(opts ...Option) *executable.Executable
• func ExecWithPauses(opts ...Option) *executable.Executable
• func ExecWithTimeout(opts ...Option) *executable.Executable
• func ExecWithTmpDir(opts ...Option) *executable.Executable
• func ParallelExecByRefConfig(opts ...Option) *executable.Executable
• func ParallelExecWithExit(opts ...Option) *executable.Executable
• func ParallelExecWithMaxThreads(opts ...Option) *executable.Executable
• func RequestExec(opts ...Option) *executable.Executable
• func RequestExecWithBody(opts ...Option) *executable.Executable
• func RequestExecWithTimeout(opts ...Option) *executable.Executable
• func RequestExecWithTransform(opts ...Option) *executable.Executable
• func RequestExecWithValidatedStatus(opts ...Option) *executable.Executable
• func SerialExecByRefConfig(opts ...Option) *executable.Executable
• func SerialExecWithExit(opts ...Option) *executable.Executable
• func SimpleExec(opts ...Option) *executable.Executable
• type Option
  • func WithFlowFilePath(path string) Option
  • func WithNamespaceName(name string) Option
  • func WithWorkspaceName(name string) Option
  • func WithWorkspacePath(path string) Option
• type OptionsValue
  • func NewOptionValues(opts ...Option) *OptionsValue

Functions

func ExamplesExecFlowFile

func ExamplesExecFlowFile(opts ...Option) *executable.FlowFile

func ExamplesMultiExecFlowFile

func ExamplesMultiExecFlowFile(opts ...Option) *executable.FlowFile

func ExamplesRequestExecFlowFile

func ExamplesRequestExecFlowFile(opts ...Option) *executable.FlowFile

func ExecWithArgs

func ExecWithArgs(opts ...Option) *executable.Executable

func ExecWithExit

func ExecWithExit(opts ...Option) *executable.Executable

func ExecWithLogMode

func ExecWithLogMode(opts ...Option) *executable.Executable

func ExecWithParams

func ExecWithParams(opts ...Option) *executable.Executable

func ExecWithPauses

func ExecWithPauses(opts ...Option) *executable.Executable

func ExecWithTimeout

func ExecWithTimeout(opts ...Option) *executable.Executable

func ExecWithTmpDir

func ExecWithTmpDir(opts ...Option) *executable.Executable

func ParallelExecByRefConfig

func ParallelExecByRefConfig(opts ...Option) *executable.Executable

func ParallelExecWithExit

func ParallelExecWithExit(opts ...Option) *executable.Executable

func ParallelExecWithMaxThreads

func ParallelExecWithMaxThreads(opts ...Option) *executable.Executable

func RequestExec

func RequestExec(opts ...Option) *executable.Executable

func RequestExecWithBody

func RequestExecWithBody(opts ...Option) *executable.Executable

func RequestExecWithTimeout

func RequestExecWithTimeout(opts ...Option) *executable.Executable

func RequestExecWithTransform

func RequestExecWithTransform(opts ...Option) *executable.Executable

func RequestExecWithValidatedStatus

func RequestExecWithValidatedStatus(opts ...Option) *executable.Executable

func SerialExecByRefConfig

func SerialExecByRefConfig(opts ...Option) *executable.Executable

func SerialExecWithExit

func SerialExecWithExit(opts ...Option) *executable.Executable

func SimpleExec

func SimpleExec(opts ...Option) *executable.Executable

Types

type Option

type Option func(*OptionsValue)

func WithFlowFilePath

func WithFlowFilePath(path string) Option

func WithNamespaceName

func WithNamespaceName(name string) Option

func WithWorkspaceName

func WithWorkspaceName(name string) Option

func WithWorkspacePath

func WithWorkspacePath(path string) Option

type OptionsValue

type OptionsValue struct {
	WorkspaceName string
	WorkspacePath string
	NamespaceName string
	FlowFilePath  string
}

func NewOptionValues

func NewOptionValues(opts ...Option) *OptionsValue