service

package

v0.2.2 Latest Latest Go to latest Published: Jun 4, 2026 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

View Source

var ErrInvalidInput = errors.New("invalid input")

This section is empty.

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

func New(tasks store.TaskStore, researchRuns store.ResearchRunStore) *Service

func NewWithAgentRuns(tasks store.TaskStore, researchRuns store.ResearchRunStore, agentRuns store.AgentRunStore) *Service

func (svc *Service) AppendAgentStep(ctx context.Context, runID string, input model.AppendAgentStepInput) (model.AgentRun, error)

func (svc *Service) CompleteAgentRun(ctx context.Context, runID string, input model.CompleteAgentRunInput) (model.AgentRun, error)

func (svc *Service) CompleteTask(ctx context.Context, id string) (model.Task, error)

func (svc *Service) CreateAgentRun(ctx context.Context, input model.CreateAgentRunInput) (model.AgentRun, error)

func (svc *Service) CreateResearchRun(ctx context.Context, input model.CreateResearchRunInput) (model.ResearchRun, error)

func (svc *Service) CreateTask(ctx context.Context, input model.CreateTaskInput) (model.Task, error)

func (svc *Service) FailTask(ctx context.Context, id string) (model.Task, error)

func (svc *Service) GetAgentRun(ctx context.Context, id string) (model.AgentRun, error)

func (svc *Service) GetResearchRun(ctx context.Context, id string) (model.ResearchRun, error)

func (svc *Service) GetTask(ctx context.Context, id string) (model.Task, error)

func (svc *Service) PromoteAgentArtifact(ctx context.Context, runID string, input model.PromoteAgentArtifactInput) (model.AgentRun, error)

func (svc *Service) SetPolicyRecorder(recorder *agentactivity.Recorder)

func (svc *Service) StartTask(ctx context.Context, id string) (model.Task, error)