block

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

type Block struct {
	Name        string                  `yaml:"name"`
	Metadata    map[string]interface{}  `yaml:"metadata,omitempty"`
	Path        string                  `yaml:"-"` // Filesystem path
	Runtime     RuntimeType             `yaml:"runtime"`
	Description string                  `yaml:"description,omitempty"`
	Inputs      map[string]InputSchema  `yaml:"inputs,omitempty"`
	Outputs     map[string]OutputSchema `yaml:"outputs,omitempty"`

	// Runtime-specific fields
	Workflow *ast.Workflow     `yaml:"workflow,omitempty"` // For native blocks
	Script   string            `yaml:"script,omitempty"`   // For go blocks
	Image    string            `yaml:"image,omitempty"`    // For docker blocks
	Command  []string          `yaml:"command,omitempty"`  // For docker blocks
	Env      map[string]string `yaml:"env,omitempty"`      // For docker blocks

	// Cached data
	ModTime      time.Time `yaml:"-"`
	CompiledPath string    `yaml:"-"` // For go blocks
}

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

type ExecutionError struct {
	Message string                 `json:"message"`
	Code    string                 `json:"code,omitempty"`
	Details string                 `json:"details,omitempty"`
	Data    map[string]interface{} `json:"data,omitempty"`
}

type ExecutionInput struct {
	Inputs map[string]interface{} `json:"inputs"`
	Env    map[string]string      `json:"-"`
}

type Executor interface {
	// Execute runs a block with the given inputs
	Execute(execCtx *execcontext.ExecutionContext, block *Block, inputs map[string]interface{}) (interface{}, error)

	// Validate checks if the executor can handle the given block
	Validate(block *Block) error
}

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

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

type InputSchema struct {
	Type        string      `yaml:"type"`
	Description string      `yaml:"description,omitempty"`
	Required    bool        `yaml:"required,omitempty"`
	Default     interface{} `yaml:"default,omitempty"`
	Enum        []string    `yaml:"enum,omitempty"`
	Items       interface{} `yaml:"items,omitempty"`      // For arrays
	Properties  interface{} `yaml:"properties,omitempty"` // For objects
}

type Loader interface {
	// Load loads a block from the given path
	Load(ctx context.Context, path string) (*Block, error)

	// GetFromCache returns a cached block if available
	GetFromCache(path string) (*Block, bool)

	// InvalidateCache removes a block from the cache
	InvalidateCache(path string)
}

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

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

type OutputSchema struct {
	Type        string `yaml:"type"`
	Description string `yaml:"description,omitempty"`
	From        string `yaml:"from,omitempty"` // For docker blocks reading from files
}

type Registry interface {
	// Register registers an executor for a runtime type
	Register(runtime RuntimeType, executor Executor)

	// Get returns the executor for a runtime type
	Get(runtime RuntimeType) (Executor, bool)
}

type RuntimeType string

type WorkflowEngine interface {
	Execute(execCtx *execcontext.ExecutionContext, workflow *ast.Workflow, inputs map[string]interface{}) (map[string]interface{}, error)
}