service

type CoreMemoryService ¶

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

CoreMemoryService implements the interfaces.TaskService interface with in-memory storage

func (s *CoreMemoryService) AddTaskLog(ctx context.Context, taskID string, message string, level string) error

func (s *CoreMemoryService) ApproveTaskPlan(ctx context.Context, taskID string, reqObj interface{}) (interface{}, error)

func (s *CoreMemoryService) CreateTask(ctx context.Context, reqObj interface{}) (interface{}, error)

func (s *CoreMemoryService) GetTask(ctx context.Context, taskID string) (interface{}, error)

func (s *CoreMemoryService) GetTaskLogs(ctx context.Context, taskID string) ([]*core.Log, error)

func (s *CoreMemoryService) ListTasks(ctx context.Context, filterObj interface{}) ([]interface{}, error)

func (s *CoreMemoryService) UpdateTask(ctx context.Context, taskID string, updatesObj interface{}) (interface{}, error)

type InMemoryTaskService ¶

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

InMemoryTaskService implements the Service interface with an in-memory storage

func NewInMemoryTaskService(logger logging.Logger, planner interfaces.TaskPlanner, executor TaskRunner) *InMemoryTaskService

func (s *InMemoryTaskService) AddTaskLog(ctx context.Context, taskID string, message string, level string) error

func (s *InMemoryTaskService) ApproveTaskPlan(ctx context.Context, taskID string, req task.ApproveTaskPlanRequest) (*task.Task, error)

func (s *InMemoryTaskService) CreateTask(ctx context.Context, req task.CreateTaskRequest) (*task.Task, error)

func (s *InMemoryTaskService) GetTask(ctx context.Context, taskID string) (*task.Task, error)

func (s *InMemoryTaskService) ListTasks(ctx context.Context, filter task.TaskFilter) ([]*task.Task, error)

func (s *InMemoryTaskService) UpdateTask(ctx context.Context, taskID string, updates []task.TaskUpdate) (*task.Task, error)

type TaskRunner ¶ added in v0.2.73

type TaskRunner interface {
	ExecuteTask(ctx context.Context, t *task.Task) error
}

TaskRunner executes an approved task.

This is the only executor capability InMemoryTaskService uses, so it is the only one the constructor asks for.

It exists because the service previously took an interfaces.TaskExecutor, which nothing in this module satisfies: *task/executor.TaskExecutor has no CancelTask, GetTaskStatus, ExecuteWorkflow or ExecuteWorkflowAsync, and its ExecuteStep/ExecuteTask take concrete types rather than the interface{} that contract declares. The service was therefore uninstantiable with anything at all -- an eight-method interface with zero implementations. Asking only for the one method actually used makes it implementable in a few lines, without repairing an interface nobody can satisfy.

Note that *task/executor.TaskExecutor still does NOT satisfy this, for a separate reason worth recording: it operates on *task/core.Task while this service operates on *task.Task, and those are two distinct structs rather than an alias. pkg/task and pkg/task/core are parallel type hierarchies for the same concept. Reconciling them is a larger change than this one and is left deliberately undone rather than papered over with a conversion shim.