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.