Documentation
¶
Index ¶
- func NewCoreMemoryService(logger logging.Logger, planner interfaces.TaskPlanner) interfaces.TaskService
- type CoreMemoryService
- 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
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCoreMemoryService ¶
func NewCoreMemoryService(logger logging.Logger, planner interfaces.TaskPlanner) interfaces.TaskService
NewCoreMemoryService creates a new in-memory service for core tasks
Types ¶
type CoreMemoryService ¶
type CoreMemoryService struct {
// contains filtered or unexported fields
}
CoreMemoryService implements the interfaces.TaskService interface with in-memory storage
func (*CoreMemoryService) AddTaskLog ¶
func (s *CoreMemoryService) AddTaskLog(ctx context.Context, taskID string, message string, level string) error
AddTaskLog adds a log entry to a task
func (*CoreMemoryService) ApproveTaskPlan ¶
func (s *CoreMemoryService) ApproveTaskPlan(ctx context.Context, taskID string, reqObj interface{}) (interface{}, error)
ApproveTaskPlan approves or rejects a task plan
func (*CoreMemoryService) CreateTask ¶
func (s *CoreMemoryService) CreateTask(ctx context.Context, reqObj interface{}) (interface{}, error)
CreateTask creates a new task
func (*CoreMemoryService) GetTask ¶
func (s *CoreMemoryService) GetTask(ctx context.Context, taskID string) (interface{}, error)
GetTask gets a task by ID
func (*CoreMemoryService) GetTaskLogs ¶
GetTaskLogs returns all logs for a task
func (*CoreMemoryService) ListTasks ¶
func (s *CoreMemoryService) ListTasks(ctx context.Context, filterObj interface{}) ([]interface{}, error)
ListTasks returns tasks based on the filter
func (*CoreMemoryService) UpdateTask ¶
func (s *CoreMemoryService) UpdateTask(ctx context.Context, taskID string, updatesObj interface{}) (interface{}, error)
UpdateTask updates a task
type InMemoryTaskService ¶
type InMemoryTaskService struct {
// contains filtered or unexported fields
}
InMemoryTaskService implements the Service interface with an in-memory storage
func NewInMemoryTaskService
deprecated
func NewInMemoryTaskService(logger logging.Logger, planner interfaces.TaskPlanner, executor interfaces.TaskExecutor) *InMemoryTaskService
NewInMemoryTaskService creates a new in-memory task service.
Deprecated: the executor parameter is an interfaces.TaskExecutor, which no type in this module satisfies. This constructor cannot be called with any executor the SDK provides and will change signature when that interface is removed.
func (*InMemoryTaskService) AddTaskLog ¶
func (s *InMemoryTaskService) AddTaskLog(ctx context.Context, taskID string, message string, level string) error
AddTaskLog adds a log entry to a task
func (*InMemoryTaskService) ApproveTaskPlan ¶
func (s *InMemoryTaskService) ApproveTaskPlan(ctx context.Context, taskID string, req task.ApproveTaskPlanRequest) (*task.Task, error)
ApproveTaskPlan approves or rejects a task plan
func (*InMemoryTaskService) CreateTask ¶
func (s *InMemoryTaskService) CreateTask(ctx context.Context, req task.CreateTaskRequest) (*task.Task, error)
CreateTask creates a new task
func (*InMemoryTaskService) ListTasks ¶
func (s *InMemoryTaskService) ListTasks(ctx context.Context, filter task.TaskFilter) ([]*task.Task, error)
ListTasks returns tasks filtered by the provided criteria
func (*InMemoryTaskService) UpdateTask ¶
func (s *InMemoryTaskService) UpdateTask(ctx context.Context, taskID string, updates []task.TaskUpdate) (*task.Task, error)
UpdateTask updates an existing task with new steps or modifications
Source Files