agenttask

type EventSink func(context.Context, string, any) error

type Options struct {
	Tasks      *database.TaskRepository
	AgentTasks *database.AgentTaskRepository
	Workflows  *database.WorkflowRepository
	Runner     Runner
	Logger     *slog.Logger
	Timeout    time.Duration

	Concurrency        int
	SessionConcurrency int
	QueueCapacity      int
}

type Result struct {
	Text      string
	UsageJSON string
}

type Runner interface {
	Run(context.Context, *database.AgentTaskEntity, EventSink) (Result, error)
}

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

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

type SubmitRequest struct {
	ParentTaskID   string
	OwnerSessionID string
	ChildSessionID string
	ConcurrencyKey string
	AgentName      string
	Prompt         string
	Model          string
	Provider       string
	PolicyJSON     string
	Depth          int
}

type Subscription struct {
	Events <-chan database.TaskEventEntity
	Cancel func()
}