workflow

type AgentOptions struct {
	NodeKey        string `json:"node_key"`
	AgentName      string `json:"agent_name"`
	Model          string `json:"model"`
	Provider       string `json:"provider"`
	ConcurrencyKey string `json:"concurrency_key"`
	Depth          int    `json:"depth"`
}

type AgentRequest struct {
	ParentTaskID    string
	OwnerSessionID  string
	NodeKey         string
	Prompt          string
	Options         AgentOptions
	InvocationIndex int
}

type Controller interface {
	Submit(context.Context, *AgentRequest) (*database.AgentTaskEntity, error)
	Get(context.Context, string) (*database.AgentTaskEntity, bool, error)
	Await(context.Context, string) (*database.AgentTaskEntity, error)
	Cancel(context.Context, string, string, string) (*database.TaskEntity, bool, error)
}

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

type DispatcherOptions struct {
	Service     *Service
	Tasks       *database.TaskRepository
	Logger      *slog.Logger
	Concurrency int
	Buffer      int
	Interval    time.Duration
}

type Event struct {
	Task            TaskResult
	Kind            EventKind
	TaskID          string
	NodeKey         string
	InvocationIndex int
}

type EventKind string

type EventSink func(context.Context, Event) error

type PipelineResult struct {
	Value any
	Error string
	Index int
}

type RunRequest struct {
	RunID          string
	Name           string
	Source         string
	OwnerSessionID string
	OnEvent        EventSink
	Arguments      map[string]any
	PersistedLinks []database.WorkflowAgentTaskEntity
}

type RunResult struct {
	Value           any
	Stdout          string
	Stderr          string
	LaunchedTaskIDs []string
	TaskResults     []TaskResult
}

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

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

type ServiceRequest struct {
	Name           string
	Source         string
	SourceVersion  string
	ArgumentsJSON  string
	OwnerSessionID string
}

type TaskResult struct {
	ID           string `json:"id"`
	State        string `json:"state"`
	Result       string `json:"result"`
	ErrorCode    string `json:"error_code"`
	ErrorMessage string `json:"error_message"`
}