executor

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

type Capability uint64

type ExecutionContext struct {
	// WithConfig is the yaml config passed to the executor
	WithConfig    []byte
	Inputs        map[string]any
	Stdout        io.Writer
	Stderr        io.Writer
	UserUUID      string
	NamespaceName string // human-readable namespace name for API calls
	APIKey        string // executor API key for authenticating with the server
	APIBaseURL    string // server base URL for API calls
}

type Executor interface {
	Execute(ctx context.Context, execCtx ExecutionContext) (outputs map[string]string, err error)
	GetArtifactsDir() string
}

type FlowStatusResponse struct {
	ID              string          `json:"id"`
	FlowName        string          `json:"flow_name"`
	FlowID          string          `json:"flow_id"`
	Status          string          `json:"status"`
	TriggerType     string          `json:"trigger_type"`
	Input           json.RawMessage `json:"input,omitempty"`
	TriggeredBy     string          `json:"triggered_by"`
	CurrentActionID string          `json:"current_action_id"`
	CreatedAt       string          `json:"created_at"`
	StartedAt       string          `json:"started_at"`
	CompletedAt     string          `json:"completed_at"`
	ScheduledAt     string          `json:"scheduled_at,omitempty"`
}

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

type NewExecutorFunc func(name string, driver NodeDriver, execID string) (Executor, error)

type Node struct {
	Hostname       string
	Port           int
	Username       string
	Auth           NodeAuth
	ConnectionType string
	OSFamily       string
}

type NodeAuth struct {
	Method string
	Key    string
}

type NodeDriver interface {
	Upload(ctx context.Context, localPath, remotePath string) error
	Download(ctx context.Context, remotePath, localPath string) error
	CreateDir(ctx context.Context, path string) error
	CreateFile(ctx context.Context, path string) error
	GetWorkingDirectory() string
	Remove(ctx context.Context, path string) error
	SetPermissions(ctx context.Context, path string, perms os.FileMode) error
	Exec(ctx context.Context, command string, workingDir string, env []string, stdout, stderr io.Writer) error
	Dial(network, address string) (net.Conn, error)
	IsRemote() bool
	TempDir() string
	Join(parts ...string) string
	// ListFiles should only return top level files and no directories
	ListFiles(ctx context.Context, dirPath string) ([]string, error)
	Close() error
}

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

type TriggerFlowResponse struct {
	ExecID      string  `json:"exec_id"`
	ScheduledAt *string `json:"scheduled_at,omitempty"`
}