inline

Documentation

Index

• type InlineRunner
  • func NewRunner(req *InlineRunnerReq) (*InlineRunner, error)
  • func (r *InlineRunner) Cancel() error
  • func (r *InlineRunner) Start(failCh chan *state.RunNamespacedKey) error
• type InlineRunnerReq

Types

type InlineRunner

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

func NewRunner

func NewRunner(req *InlineRunnerReq) (*InlineRunner, error)

func (*InlineRunner) Cancel

func (r *InlineRunner) Cancel() error

func (*InlineRunner) Start

func (r *InlineRunner) Start(failCh chan *state.RunNamespacedKey) error

type InlineRunnerReq

type InlineRunnerReq struct {
	Client *api.Client
	Logger *zap.Logger

	DataDir  string
	RunID    ulid.ULID
	Flow     *state.Flow
	Vars     map[string]any
	EvalCtx  *hcl.EvalContext
	RPRCAddr string
}