executor

type AsyncExecutor interface {
	Executor
	Poll(ctx context.Context, task ExecuteTask, externalTaskID string) (ExecuteResult, error)
	Cancel(ctx context.Context, task ExecuteTask, externalTaskID string) error
}

type ContainerExecutor struct{}

type Dispatcher interface {
	Dispatch(task ExecuteTask) (Executor, error)
}

type ExecuteResult struct {
	Status          Status         `json:"status,omitempty"`
	Output          any            `json:"output,omitempty"`
	Variables       map[string]any `json:"variables,omitempty"`
	DeleteVariables []string       `json:"delete_variables,omitempty"`
	Error           string         `json:"error,omitempty"`
	Metadata        map[string]any `json:"metadata,omitempty"`
	Logs            []string       `json:"logs,omitempty"`
	ExternalTaskID  string         `json:"external_task_id,omitempty"`
	RetryAfter      time.Duration  `json:"retry_after,omitempty"`
	FinishedAt      time.Time      `json:"finished_at,omitempty"`
}

type ExecuteTask struct {
	RunID           string         `json:"run_id"`
	NodeID          string         `json:"node_id"`
	ExecutorType    string         `json:"executor_type"`
	ExecutorRef     string         `json:"executor_ref,omitempty"`
	CredentialScope string         `json:"credential_scope,omitempty"`
	Attempt         int            `json:"attempt,omitempty"`
	MaxAttempts     int            `json:"max_attempts,omitempty"`
	Input           any            `json:"input,omitempty"`
	Params          map[string]any `json:"params,omitempty"`
	Context         map[string]any `json:"context,omitempty"`
	Timeout         time.Duration  `json:"timeout,omitempty"`
	Deadline        time.Time      `json:"deadline,omitempty"`
	Async           bool           `json:"async,omitempty"`
	PollInterval    time.Duration  `json:"poll_interval,omitempty"`
	HeartbeatFreq   time.Duration  `json:"heartbeat_freq,omitempty"`
}

type ExecutionFailure struct {
	Err        error
	Retry      bool
	RetryAfter time.Duration
}

type Executor interface {
	Type() Type
	Execute(ctx context.Context, task ExecuteTask) (ExecuteResult, error)
}

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

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

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

type LocalFunc func(ctx context.Context, req Request) (Result, error)

type NodeExecutor struct{}

type PythonExecutor struct{}

type QueueBroker interface {
	Enqueue(ctx context.Context, queue string, task ExecuteTask) (string, error)
	Dequeue(ctx context.Context, queue string, wait time.Duration) (*QueuedTask, error)
	Ack(ctx context.Context, ticket string, result ExecuteResult) error
	Poll(ctx context.Context, ticket string) (ExecuteResult, error)
	Cancel(ctx context.Context, ticket string) error
}

type QueueExecutor struct {
	Broker QueueBroker
}

type QueuedTask struct {
	Ticket string      `json:"ticket"`
	Queue  string      `json:"queue"`
	Task   ExecuteTask `json:"task"`
}

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

type RegistryDispatcher struct {
	Registry *Registry
}

type RemoteExecutor struct{}

type Request = ExecuteTask

type Result = ExecuteResult

type ScriptExecutor struct{}

type Status string

type Type string