flow

Documentation

Index

• type Context
  • func NewContext(flowfile types.Flowfile, workdir, homedir, args string) *Context
  • func (c *Context) Execute(ctx context.Context, flow types.Flow) error
• type ShellRunner

Types

type Context

type Context struct {
	// contains filtered or unexported fields
}

func NewContext

func NewContext(flowfile types.Flowfile, workdir, homedir, args string) *Context

func (*Context) Execute

func (c *Context) Execute(ctx context.Context, flow types.Flow) error

type ShellRunner

type ShellRunner interface {
	Run(ctx context.Context, script string, envs []string) error
}