services

Documentation

Index

• Constants
• Variables
• type AgentService
  • func (svc *AgentService) Configure(ctx *context.Context) error
  • func (svc AgentService) Id() string
  • func (svc *AgentService) LoadAgents(project *workers.Project) error
  • func (svc *AgentService) RegisterAgent(project *workers.Project, agent *workers.Agent) error
  • func (svc *AgentService) Start() error
• type HttpService
  • func (svc *HttpService) Configure(ctx *context.Context) error
  • func (svc HttpService) Id() string
  • func (svc *HttpService) Start() error
• type Pong
• type ProjectService
  • func (svc *ProjectService) Execute(req *dto.PromptRequest) (*workers.Project, error)
  • func (svc ProjectService) Id() string
  • func (svc *ProjectService) Run(p *workers.Project) (*workers.Project, error)
  • func (svc *ProjectService) Start() error
  • func (svc *ProjectService) Status(projectID string) (*workers.Project, error)
• type TaskService
  • func (svc *TaskService) Execute(project *workers.Project, task *models.Task) (*models.WorkerResponse, error)
  • func (svc TaskService) Id() string
  • func (svc *TaskService) PromptToTask(req *dto.PromptRequest) *models.Task
  • func (svc *TaskService) Start() error

Constants

const AGENT_SVC = "agent_svc"

const PROJECT_SVC = "project_svc"

const TASK_SVC = "task_svc"

Variables

var DeleteResponseOK = `{"status": 200, "error": ""}`

var ErrUnauthorized = errors.New("unauthorized")

Types

type AgentService

type AgentService struct {
	services.DefaultService
	// contains filtered or unexported fields
}

func (*AgentService) Configure

func (svc *AgentService) Configure(ctx *context.Context) error

func (AgentService) Id

func (svc AgentService) Id() string

func (*AgentService) LoadAgents

func (svc *AgentService) LoadAgents(project *workers.Project) error

func (*AgentService) RegisterAgent

func (svc *AgentService) RegisterAgent(project *workers.Project, agent *workers.Agent) error

func (*AgentService) Start

func (svc *AgentService) Start() error

type HttpService

type HttpService struct {
	services.DefaultService
	BaseURL string
	Port    int
	// contains filtered or unexported fields
}

func (*HttpService) Configure

func (svc *HttpService) Configure(ctx *context.Context) error

func (HttpService) Id

func (svc HttpService) Id() string

func (*HttpService) Start

func (svc *HttpService) Start() error

type Pong

type Pong struct {
	Message string `json:"message"`
}

type ProjectService

type ProjectService struct {
	services.DefaultService
	// contains filtered or unexported fields
}

func (*ProjectService) Execute

func (svc *ProjectService) Execute(req *dto.PromptRequest) (*workers.Project, error)

func (ProjectService) Id

func (svc ProjectService) Id() string

func (*ProjectService) Run

func (svc *ProjectService) Run(p *workers.Project) (*workers.Project, error)

func (*ProjectService) Start

func (svc *ProjectService) Start() error

func (*ProjectService) Status

func (svc *ProjectService) Status(projectID string) (*workers.Project, error)

type TaskService

type TaskService struct {
	services.DefaultService
	// contains filtered or unexported fields
}

func (*TaskService) Execute

func (svc *TaskService) Execute(project *workers.Project, task *models.Task) (*models.WorkerResponse, error)

Execute a task

func (TaskService) Id

func (svc TaskService) Id() string

func (*TaskService) PromptToTask

func (svc *TaskService) PromptToTask(req *dto.PromptRequest) *models.Task

func (*TaskService) Start

func (svc *TaskService) Start() error