Documentation ¶
Index ¶
- func NewInputFn(cfg *Config) fn.BlockInstanceRunner
- func NewLocalOrOutputFn(cfg *Config) fn.BlockInstanceRunner
- func NewPackageFn(cfg *Config) fn.BlockInstanceRunner
- func NewResourceFn(cfg *Config) fn.BlockInstanceRunner
- func NewRootFn(cfg *Config) fn.BlockInstanceRunner
- type Config
- type ExecHandler
- type Initializer
- type Map
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewInputFn ¶
func NewInputFn(cfg *Config) fn.BlockInstanceRunner
provide and input runner, which runs per input instance
func NewLocalOrOutputFn ¶
func NewLocalOrOutputFn(cfg *Config) fn.BlockInstanceRunner
func NewPackageFn ¶
func NewPackageFn(cfg *Config) fn.BlockInstanceRunner
func NewResourceFn ¶
func NewResourceFn(cfg *Config) fn.BlockInstanceRunner
func NewRootFn ¶
func NewRootFn(cfg *Config) fn.BlockInstanceRunner
Types ¶
type Config ¶
type Config struct { Provider bool // inidcates if this is a provider or a regular dag run PackageName string BlockName string RootPackageName string DataStore *data.DataStore Recorder recorder.Recorder[diag.Diagnostic] // used for the provider DAG run + resources run to find the provider client ProviderInstances store.Storer[plugin.Provider] // used for the provider DAG run only ProviderInventory store.Storer[types.Provider] }
type ExecHandler ¶
type ExecHandler struct { RootPackageName string PackageName string BlockName string DataStore *data.DataStore Recorder recorder.Recorder[diag.Diagnostic] // contains filtered or unexported fields }
func NewExecHandler ¶
func NewExecHandler(ctx context.Context, cfg *Config) *ExecHandler
func (*ExecHandler) BlockRun ¶
func (r *ExecHandler) BlockRun(ctx context.Context, vertexName string, vctx *types.VertexContext) bool
type Initializer ¶
type Initializer func(*Config) fn.BlockInstanceRunner
Click to show internal directories.
Click to hide internal directories.