runtime

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

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

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

type InMemoryTaskManagerOption func(*InMemoryTaskManager)

type LogReader interface {
	ReadIncrement(ctx context.Context, taskID corepkg.TaskID, offset uint64, limit int) (items []TaskLogEntry, nextOffset uint64, hasMore bool, err error)
}

type NopTaskEventStore struct{}

type QuotaManager interface {
	Acquire(ctx context.Context, key string) error
	Release(key string)
}

type Scheduler interface {
	Enqueue(ctx context.Context, taskID corepkg.TaskID) error
}

type SubAgentCoordinator interface {
	Spawn(ctx context.Context, spec TaskSpec) (corepkg.TaskID, error)
	Wait(ctx context.Context, id corepkg.TaskID) (TaskResult, error)
}

type Task struct {
	ID         corepkg.TaskID
	Spec       TaskSpec
	Status     corepkg.TaskStatus
	Attempt    int
	Output     []byte
	CreatedAt  time.Time
	StartedAt  *time.Time
	FinishedAt *time.Time
	ErrorCode  string
}

type TaskEvent struct {
	Type      TaskEventType
	Offset    uint64
	TaskID    corepkg.TaskID
	SessionID corepkg.SessionID
	TraceID   corepkg.TraceID
	Status    corepkg.TaskStatus
	Attempt   int
	Payload   []byte
	Metadata  map[string]string
	ErrorCode string
	Timestamp time.Time
}

type TaskEventStore interface {
	AppendTaskEvent(ctx context.Context, event TaskEvent) error
	AppendTaskLog(ctx context.Context, taskID corepkg.TaskID, entry TaskLogEntry) error
}

type TaskEventType string

type TaskExecutionRegistry interface {
	RegisterExecution(token string, executor TaskExecutorFunc)
	UnregisterExecution(token string)
}

type TaskExecutorFunc func(ctx context.Context, task Task) ([]byte, error)

type TaskLogEntry struct {
	TaskID    corepkg.TaskID
	Offset    uint64
	Payload   []byte
	Timestamp time.Time
}

type TaskManager interface {
	Submit(ctx context.Context, spec TaskSpec) (corepkg.TaskID, error)
	Get(ctx context.Context, id corepkg.TaskID) (Task, error)
	Cancel(ctx context.Context, id corepkg.TaskID, reason string) error
	Retry(ctx context.Context, id corepkg.TaskID) (corepkg.TaskID, error)
	Stream(ctx context.Context, id corepkg.TaskID) (<-chan TaskEvent, error)
	Wait(ctx context.Context, id corepkg.TaskID) (TaskResult, error)
}

type TaskResult struct {
	TaskID     corepkg.TaskID
	Status     corepkg.TaskStatus
	Output     []byte
	ErrorCode  string
	FinishedAt time.Time
}

type TaskSpec struct {
	SessionID        corepkg.SessionID
	TraceID          corepkg.TraceID
	Name             string
	Kind             string
	Input            []byte
	ParentTaskID     corepkg.TaskID
	Timeout          time.Duration
	MaxRetries       int
	Background       bool
	IsolatedWorktree bool
	Metadata         map[string]string
}

type TransitionOptions struct {
	AllowRetryTransition bool
}

type WorktreeHandle struct {
	ID     string
	Path   string
	Branch string
	Commit string
}

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

type WorktreeRequest struct {
	InvocationID  string
	WorkspaceRoot string
}