services

Documentation

Index

• func NewFileService() domain.FileService
• type FileServiceImpl
  • func (s *FileServiceImpl) GetFileInfo(path string) (domain.FileInfo, error)
  • func (s *FileServiceImpl) ListProjectFiles() ([]string, error)
  • func (s *FileServiceImpl) ReadFile(path string) (string, error)
  • func (s *FileServiceImpl) ReadFileLines(path string, startLine, endLine int) (string, error)
  • func (s *FileServiceImpl) ValidateFile(path string) error
• type HTTPModelService
  • func NewHTTPModelService(baseURL, apiKey string) *HTTPModelService
  • func (s *HTTPModelService) GetCurrentModel() string
  • func (s *HTTPModelService) IsModelAvailable(modelID string) bool
  • func (s *HTTPModelService) ListModels(ctx context.Context) ([]string, error)
  • func (s *HTTPModelService) SelectModel(modelID string) error
  • func (s *HTTPModelService) ValidateModel(modelID string) error
• type InMemoryConversationRepository
  • func NewInMemoryConversationRepository() *InMemoryConversationRepository
  • func (r *InMemoryConversationRepository) AddMessage(msg domain.ConversationEntry) error
  • func (r *InMemoryConversationRepository) Clear() error
  • func (r *InMemoryConversationRepository) Export(format domain.ExportFormat) ([]byte, error)
  • func (r *InMemoryConversationRepository) GetMessageCount() int
  • func (r *InMemoryConversationRepository) GetMessages() []domain.ConversationEntry
  • func (r *InMemoryConversationRepository) UpdateLastMessage(content string) error
  • func (r *InMemoryConversationRepository) UpdateLastMessageToolCalls(toolCalls *[]sdk.ChatCompletionMessageToolCall) error
• type LLMToolService
  • func NewLLMToolService(cfg *config.Config) *LLMToolService
  • func NewLLMToolServiceWithRegistry(cfg *config.Config, registry *tools.Registry) *LLMToolService
  • func (s *LLMToolService) ExecuteTool(ctx context.Context, name string, args map[string]interface{}) (*domain.ToolExecutionResult, error)
  • func (s *LLMToolService) IsToolEnabled(name string) bool
  • func (s *LLMToolService) ListTools() []domain.ToolDefinition
  • func (s *LLMToolService) ValidateTool(name string, args map[string]interface{}) error
• type ModelsResponse
• type NoOpToolService
  • func NewNoOpToolService() *NoOpToolService
  • func (s *NoOpToolService) ExecuteTool(ctx context.Context, name string, args map[string]interface{}) (*domain.ToolExecutionResult, error)
  • func (s *NoOpToolService) IsToolEnabled(name string) bool
  • func (s *NoOpToolService) ListTools() []domain.ToolDefinition
  • func (s *NoOpToolService) ValidateTool(name string, args map[string]interface{}) error
• type StreamingChatService
  • func NewStreamingChatService(baseURL, apiKey string, timeoutSeconds int, toolService domain.ToolService, ...) *StreamingChatService
  • func (s *StreamingChatService) CancelRequest(requestID string) error
  • func (s *StreamingChatService) GetMetrics(requestID string) *domain.ChatMetrics
  • func (s *StreamingChatService) SendMessage(ctx context.Context, model string, messages []sdk.Message) (<-chan domain.ChatEvent, error)

Functions

func NewFileService

func NewFileService() domain.FileService

NewFileService creates a new file service

Types

type FileServiceImpl

type FileServiceImpl struct{}

FileServiceImpl implements domain.FileService

func (*FileServiceImpl) GetFileInfo

func (s *FileServiceImpl) GetFileInfo(path string) (domain.FileInfo, error)

GetFileInfo returns information about a file

func (*FileServiceImpl) ListProjectFiles

func (s *FileServiceImpl) ListProjectFiles() ([]string, error)

ListProjectFiles returns a list of all files in the current directory and subdirectories

func (*FileServiceImpl) ReadFile

func (s *FileServiceImpl) ReadFile(path string) (string, error)

ReadFile reads the content of a file

func (*FileServiceImpl) ReadFileLines

func (s *FileServiceImpl) ReadFileLines(path string, startLine, endLine int) (string, error)

ReadFileLines reads specific lines from a file

func (*FileServiceImpl) ValidateFile

func (s *FileServiceImpl) ValidateFile(path string) error

ValidateFile checks if a file path is valid and accessible

type HTTPModelService

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

HTTPModelService implements ModelService using HTTP API calls

func NewHTTPModelService

func NewHTTPModelService(baseURL, apiKey string) *HTTPModelService

NewHTTPModelService creates a new HTTP-based model service

func (*HTTPModelService) GetCurrentModel

func (s *HTTPModelService) GetCurrentModel() string

func (*HTTPModelService) IsModelAvailable

func (s *HTTPModelService) IsModelAvailable(modelID string) bool

func (*HTTPModelService) ListModels

func (s *HTTPModelService) ListModels(ctx context.Context) ([]string, error)

func (*HTTPModelService) SelectModel

func (s *HTTPModelService) SelectModel(modelID string) error

func (*HTTPModelService) ValidateModel

func (s *HTTPModelService) ValidateModel(modelID string) error

type InMemoryConversationRepository

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

InMemoryConversationRepository implements ConversationRepository using in-memory storage

func NewInMemoryConversationRepository

func NewInMemoryConversationRepository() *InMemoryConversationRepository

NewInMemoryConversationRepository creates a new in-memory conversation repository

func (*InMemoryConversationRepository) AddMessage

func (r *InMemoryConversationRepository) AddMessage(msg domain.ConversationEntry) error

func (*InMemoryConversationRepository) Clear

func (r *InMemoryConversationRepository) Clear() error

func (*InMemoryConversationRepository) Export

func (r *InMemoryConversationRepository) Export(format domain.ExportFormat) ([]byte, error)

func (*InMemoryConversationRepository) GetMessageCount

func (r *InMemoryConversationRepository) GetMessageCount() int

func (*InMemoryConversationRepository) GetMessages

func (r *InMemoryConversationRepository) GetMessages() []domain.ConversationEntry

func (*InMemoryConversationRepository) UpdateLastMessage

func (r *InMemoryConversationRepository) UpdateLastMessage(content string) error

func (*InMemoryConversationRepository) UpdateLastMessageToolCalls

func (r *InMemoryConversationRepository) UpdateLastMessageToolCalls(toolCalls *[]sdk.ChatCompletionMessageToolCall) error

type LLMToolService

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

LLMToolService implements ToolService with the new tools package architecture

func NewLLMToolService

func NewLLMToolService(cfg *config.Config) *LLMToolService

NewLLMToolService creates a new LLM tool service with a new registry

func NewLLMToolServiceWithRegistry

func NewLLMToolServiceWithRegistry(cfg *config.Config, registry *tools.Registry) *LLMToolService

NewLLMToolServiceWithRegistry creates a new LLM tool service with an existing registry

func (*LLMToolService) ExecuteTool

func (s *LLMToolService) ExecuteTool(ctx context.Context, name string, args map[string]interface{}) (*domain.ToolExecutionResult, error)

ExecuteTool executes a tool with the given arguments

func (*LLMToolService) IsToolEnabled

func (s *LLMToolService) IsToolEnabled(name string) bool

IsToolEnabled checks if a tool is enabled

func (*LLMToolService) ListTools

func (s *LLMToolService) ListTools() []domain.ToolDefinition

ListTools returns definitions for all enabled tools

func (*LLMToolService) ValidateTool

func (s *LLMToolService) ValidateTool(name string, args map[string]interface{}) error

ValidateTool validates tool arguments

type ModelsResponse

type ModelsResponse struct {
	Data []struct {
		ID     string `json:"id"`
		Object string `json:"object"`
	} `json:"data"`
}

ModelsResponse represents the API response for listing models

type NoOpToolService

type NoOpToolService struct{}

NoOpToolService implements ToolService as a no-op (when tools are disabled)

func NewNoOpToolService

func NewNoOpToolService() *NoOpToolService

NewNoOpToolService creates a new no-op tool service

func (*NoOpToolService) ExecuteTool

func (s *NoOpToolService) ExecuteTool(ctx context.Context, name string, args map[string]interface{}) (*domain.ToolExecutionResult, error)

func (*NoOpToolService) IsToolEnabled

func (s *NoOpToolService) IsToolEnabled(name string) bool

func (*NoOpToolService) ListTools

func (s *NoOpToolService) ListTools() []domain.ToolDefinition

func (*NoOpToolService) ValidateTool

func (s *NoOpToolService) ValidateTool(name string, args map[string]interface{}) error

type StreamingChatService

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

StreamingChatService implements ChatService using streaming SDK client

func NewStreamingChatService

func NewStreamingChatService(baseURL, apiKey string, timeoutSeconds int, toolService domain.ToolService, systemPrompt string) *StreamingChatService

NewStreamingChatService creates a new streaming chat service

func (*StreamingChatService) CancelRequest

func (s *StreamingChatService) CancelRequest(requestID string) error

func (*StreamingChatService) GetMetrics

func (s *StreamingChatService) GetMetrics(requestID string) *domain.ChatMetrics

func (*StreamingChatService) SendMessage

func (s *StreamingChatService) SendMessage(ctx context.Context, model string, messages []sdk.Message) (<-chan domain.ChatEvent, error)