Help us shape the future of Go! Take the 2026 Go Developer Survey

mcp

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 28, 2025 License: AGPL-3.0 Imports: 34 Imported by: 0

Documentation

Overview

internal/mcp/path_resolver.go

internal/mcp/workspace_handlers.go

internal/mcp/workspace_manager.go

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ParseToolCall 

func ParseToolCall(text string) (serverName, toolName string, arguments map[string]interface{}, found bool)

ParseToolCall parses a tool call from AI response

func SetupRecursiveAgent 

func SetupRecursiveAgent(server *MateyMCPServer, newTermChatFunc func() interface{})

SetupRecursiveAgent configures the MCP server to use recursive TermChat instances This function should be called from the chat package to avoid circular imports

Types

type AddContextRequest 

type AddContextRequest struct {
	Type     string                 `json:"type"`
	FilePath string                 `json:"file_path,omitempty"`
	Content  string                 `json:"content"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
	Priority float64                `json:"priority,omitempty"`
}

AddContextRequest represents a request to add context

type AddContextResponse 

type AddContextResponse struct {
	Success    bool                   `json:"success"`
	ItemID     string                 `json:"item_id,omitempty"`
	TokenCount int                    `json:"token_count"`
	Error      string                 `json:"error,omitempty"`
	Metadata   map[string]interface{} `json:"metadata,omitempty"`
}

AddContextResponse represents the response from adding context

type AgentFactory 

type AgentFactory func() interface{}

AgentFactory represents a function that can create a new TermChat instance

type AgentProgress 

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

AgentProgress tracks progress of a sub-agent execution

func NewAgentProgress 

func NewAgentProgress() *AgentProgress

NewAgentProgress creates a new progress tracker

func (*AgentProgress) GetSummary 

func (p *AgentProgress) GetSummary() string

GetSummary returns a final summary of the agent execution

func (*AgentProgress) UpdateDisplay 

func (p *AgentProgress) UpdateDisplay(toolCall ToolCallSummary)

UpdateDisplay updates the progress display with a new tool call

type AgentResult 

type AgentResult struct {
	ObjectiveCompleted bool           `json:"objective_completed"`
	Result             string         `json:"result"`
	ExecutionSummary   string         `json:"execution_summary"`
	ExecutionLog       []string       `json:"execution_log,omitempty"`
	ToolCallsMade      int            `json:"tool_calls_made"`
	ToolsUsed          map[string]int `json:"tools_used"`
	DurationSeconds    float64        `json:"duration_seconds"`
	StructuredData     interface{}    `json:"structured_data,omitempty"`
	Errors             []string       `json:"errors,omitempty"`
}

AgentResult represents the structured result from agent execution

type BashCommandArgs 

type BashCommandArgs struct {
	Command          string `json:"command"`
	WorkingDirectory string `json:"working_directory,omitempty"`
	Timeout          int    `json:"timeout,omitempty"` // in seconds
	Description      string `json:"description,omitempty"`
}

BashCommandArgs represents arguments for bash command execution

type BashCommandResult 

type BashCommandResult struct {
	Command     string `json:"command"`
	ExitCode    int    `json:"exit_code"`
	Stdout      string `json:"stdout"`
	Stderr      string `json:"stderr"`
	Duration    string `json:"duration"`
	WorkingDir  string `json:"working_dir"`
	Description string `json:"description,omitempty"`
}

BashCommandResult represents the result of bash command execution

type BasicGetWorkingDirectoryResult 

type BasicGetWorkingDirectoryResult struct {
	WorkingDirectory string `json:"working_directory"`
	AbsolutePath     string `json:"absolute_path"`
}

BasicGetWorkingDirectoryResult represents the result of getting working directory

type BasicListFilesRequest 

type BasicListFilesRequest struct {
	DirectoryPath string `json:"directory_path,omitempty"`
	Recursive     bool   `json:"recursive,omitempty"`
	MaxResults    int    `json:"max_results,omitempty"`
}

BasicListFilesRequest represents a request to list files

type BasicListFilesResult 

type BasicListFilesResult struct {
	Files []FileInfo `json:"files"`
	Count int        `json:"count"`
	Error string     `json:"error,omitempty"`
}

BasicListFilesResult represents the result of listing files

type BasicReadFileRequest 

type BasicReadFileRequest struct {
	AbsolutePath string `json:"absolute_path"`
	Offset       int    `json:"offset,omitempty"`
	Limit        int    `json:"limit,omitempty"`
}

BasicReadFileRequest represents a request to read a file

type BasicReadFileResult 

type BasicReadFileResult struct {
	Content string `json:"content"`
	Error   string `json:"error,omitempty"`
}

BasicReadFileResult represents the result of reading a file

type BasicWriteFileRequest 

type BasicWriteFileRequest struct {
	FilePath string `json:"file_path"`
	Content  string `json:"content"`
}

BasicWriteFileRequest represents a request to write a file

type BasicWriteFileResult 

type BasicWriteFileResult struct {
	Success  bool   `json:"success"`
	FilePath string `json:"file_path"`
	Error    string `json:"error,omitempty"`
}

BasicWriteFileResult represents the result of writing a file

type ClearContextRequest 

type ClearContextRequest struct {
	Types     []string `json:"types,omitempty"`
	OlderThan int64    `json:"older_than,omitempty"` // Unix timestamp
	FilePath  string   `json:"file_path,omitempty"`
}

ClearContextRequest represents a request to clear context

type ClearContextResponse 

type ClearContextResponse struct {
	Success      bool                   `json:"success"`
	ItemsRemoved int                    `json:"items_removed"`
	Error        string                 `json:"error,omitempty"`
	Metadata     map[string]interface{} `json:"metadata,omitempty"`
}

ClearContextResponse represents the response from clearing context

type Content 

type Content struct {
	Type string `json:"type"`
	Text string `json:"text"`
}

Content represents content in a tool result

type ContextToolConfig 

type ContextToolConfig struct {
	MaxTokens          int     `json:"max_tokens"`
	TruncationStrategy string  `json:"truncation_strategy"`
	EnableMentions     bool    `json:"enable_mentions"`
	AutoTrack          bool    `json:"auto_track"`
	RelevanceThreshold float64 `json:"relevance_threshold"`
	MaxContextItems    int     `json:"max_context_items"`
}

ContextToolConfig configures the context-aware MCP tools

type ContextTools 

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

ContextTools provides MCP tools with intelligent context management

func NewContextTools 

func NewContextTools(
	config ContextToolConfig,
	contextManager *appcontext.ContextManager,
	fileDiscovery *appcontext.FileDiscovery,
	mentionProcessor *appcontext.MentionProcessor,
	parser *treesitter.TreeSitterParser,
) *ContextTools

NewContextTools creates a new context tools instance

func (*ContextTools) AddContext 

func (ct *ContextTools) AddContext(ctx context.Context, request AddContextRequest) (*AddContextResponse, error)

AddContext implements the add_context MCP tool

func (*ContextTools) ClearContext 

func (ct *ContextTools) ClearContext(ctx context.Context, request ClearContextRequest) (*ClearContextResponse, error)

ClearContext implements the clear_context MCP tool

func (*ContextTools) GetContext 

func (ct *ContextTools) GetContext(ctx context.Context, request GetContextRequest) (*GetContextResponse, error)

GetContext implements the get_context MCP tool

func (*ContextTools) GetContextStats 

func (ct *ContextTools) GetContextStats(ctx context.Context, request GetContextStatsRequest) (*GetContextStatsResponse, error)

GetContextStats implements the get_context_stats MCP tool

func (*ContextTools) GetRelevantFiles 

func (ct *ContextTools) GetRelevantFiles(ctx context.Context, request GetRelevantFilesRequest) (*GetRelevantFilesResponse, error)

GetRelevantFiles implements the get_relevant_files MCP tool

func (*ContextTools) ProcessMentions 

func (ct *ContextTools) ProcessMentions(ctx context.Context, request ProcessMentionsRequest) (*ProcessMentionsResponse, error)

ProcessMentions implements the process_mentions MCP tool

type EditFileRequest 

type EditFileRequest struct {
	FilePath    string `json:"file_path"`
	Content     string `json:"content,omitempty"`
	DiffContent string `json:"diff_content,omitempty"`
	CreateFile  bool   `json:"create_file,omitempty"`
	ShowPreview bool   `json:"show_preview,omitempty"`
	AutoApprove bool   `json:"auto_approve,omitempty"`
}

EditFileRequest represents a request to edit a file

type EditFileResponse 

type EditFileResponse struct {
	Success     bool                   `json:"success"`
	FilePath    string                 `json:"file_path"`
	Applied     bool                   `json:"applied"`
	Preview     string                 `json:"preview,omitempty"`
	DiffPreview string                 `json:"diff_preview,omitempty"`
	Backup      string                 `json:"backup,omitempty"`
	Error       string                 `json:"error,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
}

EditFileResponse represents the response from editing a file

type EnhancedToolConfig 

type EnhancedToolConfig struct {
	EnableVisualDiff  bool   `json:"enable_visual_diff"`
	EnablePreview     bool   `json:"enable_preview"`
	AutoApprove       bool   `json:"auto_approve"`
	MaxFileSize       int64  `json:"max_file_size"`
	ContextTracking   bool   `json:"context_tracking"`
	BackupEnabled     bool   `json:"backup_enabled"`
	ValidationEnabled bool   `json:"validation_enabled"`
	DiffMode          string `json:"diff_mode"` // unified, side-by-side, inline
}

EnhancedToolConfig configures the enhanced MCP tools

type EnhancedTools 

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

EnhancedTools provides MCP tools with advanced visual and context features

func NewEnhancedTools 

func NewEnhancedTools(
	config EnhancedToolConfig,
	fileEditor *edit.FileEditor,
	contextManager *appcontext.ContextManager,
	fileDiscovery *appcontext.FileDiscovery,
	parser *treesitter.TreeSitterParser,
	mentionProcessor *appcontext.MentionProcessor,
) *EnhancedTools

NewEnhancedTools creates a new enhanced tools instance

func (*EnhancedTools) EditFile 

func (et *EnhancedTools) EditFile(ctx context.Context, request EditFileRequest) (*EditFileResponse, error)

EditFile implements the enhanced edit_file MCP tool

func (*EnhancedTools) ListDefinitions 

func (et *EnhancedTools) ListDefinitions(ctx context.Context, request ListDefinitionsRequest) (*ListDefinitionsResponse, error)

ListDefinitions implements the list_definitions MCP tool

func (*EnhancedTools) ParseCode 

func (et *EnhancedTools) ParseCode(ctx context.Context, request ParseCodeRequest) (*ParseCodeResponse, error)

ParseCode implements the parse_code MCP tool

func (*EnhancedTools) ReadFile 

func (et *EnhancedTools) ReadFile(ctx context.Context, request ReadFileRequest) (*ReadFileResponse, error)

ReadFile implements the enhanced read_file MCP tool

func (*EnhancedTools) SearchFiles 

func (et *EnhancedTools) SearchFiles(ctx context.Context, request SearchFilesRequest) (*SearchFilesResponse, error)

SearchFiles implements the enhanced search_files MCP tool

type FileInfo 

type FileInfo struct {
	Name         string `json:"name"`
	Path         string `json:"path"`
	RelativePath string `json:"relative_path"`
	IsDirectory  bool   `json:"is_directory"`
	Size         int64  `json:"size"`
	ModTime      string `json:"mod_time"`
	Mode         string `json:"mode"`
}

FileInfo represents information about a file

type FileSearchResult 

type FileSearchResult struct {
	FilePath     string `json:"file_path"`
	RelativePath string `json:"relative_path"`
	Language     string `json:"language,omitempty"`
	Size         int64  `json:"size"`
	ModTime      string `json:"mod_time"`
	Score        int    `json:"score,omitempty"`
	Preview      string `json:"preview,omitempty"`
	GitStatus    string `json:"git_status,omitempty"`
}

FileSearchResult represents a single file search result

type FilesystemTools 

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

FilesystemTools provides basic filesystem operations similar to Gemini CLI

func NewFilesystemTools 

func NewFilesystemTools(workingDirectory string) *FilesystemTools

NewFilesystemTools creates a new filesystem tools instance

func (*FilesystemTools) GetWorkingDirectory 

func (ft *FilesystemTools) GetWorkingDirectory(ctx context.Context) (*BasicGetWorkingDirectoryResult, error)

GetWorkingDirectory returns the current working directory

func (*FilesystemTools) ListFiles 

func (ft *FilesystemTools) ListFiles(ctx context.Context, request BasicListFilesRequest) (*BasicListFilesResult, error)

ListFiles lists files in a directory

func (*FilesystemTools) ReadFile 

func (ft *FilesystemTools) ReadFile(ctx context.Context, request BasicReadFileRequest) (*BasicReadFileResult, error)

ReadFile reads a file with optional line range

func (*FilesystemTools) WriteFile 

func (ft *FilesystemTools) WriteFile(ctx context.Context, request BasicWriteFileRequest) (*BasicWriteFileResult, error)

WriteFile writes content to a file

type GetContextRequest 

type GetContextRequest struct {
	IncludeFiles    bool     `json:"include_files,omitempty"`
	IncludeEdits    bool     `json:"include_edits,omitempty"`
	IncludeMentions bool     `json:"include_mentions,omitempty"`
	IncludeLogs     bool     `json:"include_logs,omitempty"`
	FilterTypes     []string `json:"filter_types,omitempty"`
	MaxItems        int      `json:"max_items,omitempty"`
	SinceTimestamp  int64    `json:"since_timestamp,omitempty"`
}

GetContextRequest represents a request to get current context

type GetContextResponse 

type GetContextResponse struct {
	Success     bool                      `json:"success"`
	Context     *appcontext.ContextWindow `json:"context"`
	Items       []appcontext.ContextItem  `json:"items"`
	TotalTokens int                       `json:"total_tokens"`
	TotalItems  int                       `json:"total_items"`
	Truncated   bool                      `json:"truncated"`
	Strategy    string                    `json:"strategy,omitempty"`
	Error       string                    `json:"error,omitempty"`
	Metadata    map[string]interface{}    `json:"metadata,omitempty"`
}

GetContextResponse represents the response from getting context

type GetContextStatsRequest 

type GetContextStatsRequest struct {
	IncludeDetails bool `json:"include_details,omitempty"`
}

GetContextStatsRequest represents a request for context statistics

type GetContextStatsResponse 

type GetContextStatsResponse struct {
	Success  bool                   `json:"success"`
	Stats    map[string]interface{} `json:"stats"`
	Error    string                 `json:"error,omitempty"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

GetContextStatsResponse represents context statistics

type GetRelevantFilesRequest 

type GetRelevantFilesRequest struct {
	Query          string   `json:"query"`
	CurrentFile    string   `json:"current_file,omitempty"`
	FileTypes      []string `json:"file_types,omitempty"`
	MaxResults     int      `json:"max_results,omitempty"`
	IncludeContent bool     `json:"include_content,omitempty"`
	UseContext     bool     `json:"use_context,omitempty"`
}

GetRelevantFilesRequest represents a request to get relevant files

type GetRelevantFilesResponse 

type GetRelevantFilesResponse struct {
	Success  bool                   `json:"success"`
	Query    string                 `json:"query"`
	Files    []RelevantFile         `json:"files"`
	Count    int                    `json:"count"`
	Error    string                 `json:"error,omitempty"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

GetRelevantFilesResponse represents the response from getting relevant files

type ListDefinitionsRequest 

type ListDefinitionsRequest struct {
	Directory  string   `json:"directory,omitempty"`
	FilePaths  []string `json:"file_paths,omitempty"`
	Types      []string `json:"types,omitempty"`
	Languages  []string `json:"languages,omitempty"`
	MaxResults int      `json:"max_results,omitempty"`
}

ListDefinitionsRequest represents a request to list code definitions

type ListDefinitionsResponse 

type ListDefinitionsResponse struct {
	Success     bool                    `json:"success"`
	Definitions []treesitter.Definition `json:"definitions"`
	Count       int                     `json:"count"`
	Error       string                  `json:"error,omitempty"`
	Metadata    map[string]interface{}  `json:"metadata,omitempty"`
}

ListDefinitionsResponse represents the response from listing definitions

type MCPClient 

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

MCPClient represents a client for connecting to MCP servers via proxy

func NewMCPClient 

func NewMCPClient(proxyURL string) *MCPClient

NewMCPClient creates a new MCP client

func (*MCPClient) CallTool 

func (c *MCPClient) CallTool(ctx context.Context, serverName, toolName string, arguments map[string]interface{}) (*ToolResult, error)

CallTool calls a specific tool on an MCP server

func (*MCPClient) ExecuteToolCall 

func (c *MCPClient) ExecuteToolCall(ctx context.Context, serverName, toolName string, arguments map[string]interface{}) string

ExecuteToolCall executes a tool call and returns formatted result

func (*MCPClient) GetAvailableTools 

func (c *MCPClient) GetAvailableTools(ctx context.Context) string

GetAvailableTools returns a formatted list of all available tools

func (*MCPClient) GetServerTools 

func (c *MCPClient) GetServerTools(ctx context.Context, serverName string) ([]Tool, error)

GetServerTools gets all tools for a specific server

func (*MCPClient) ListServers 

func (c *MCPClient) ListServers(ctx context.Context) ([]ServerInfo, error)

ListServers lists all available MCP servers

type MCPError 

type MCPError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

MCPError represents an error from an MCP server

type MCPRequest 

type MCPRequest struct {
	Method string      `json:"method"`
	Params interface{} `json:"params"`
}

MCPRequest represents a request to an MCP server

type MCPResponse 

type MCPResponse struct {
	Result interface{} `json:"result,omitempty"`
	Error  *MCPError   `json:"error,omitempty"`
}

MCPResponse represents a response from an MCP server

type MCPServerIntegration 

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

MCPServerIntegration provides enhanced MCP server functionality

func NewMCPServerIntegration 

func NewMCPServerIntegration(cfg *config.ComposeConfig) (*MCPServerIntegration, error)

NewMCPServerIntegration creates a new MCP server integration

func (*MCPServerIntegration) CallTool 

func (msi *MCPServerIntegration) CallTool(ctx context.Context, name string, params json.RawMessage) (interface{}, error)

CallTool handles MCP tool calls

func (*MCPServerIntegration) GetStats 

func (msi *MCPServerIntegration) GetStats() map[string]interface{}

GetStats returns statistics about the MCP server integration

func (*MCPServerIntegration) GetToolDefinitions 

func (msi *MCPServerIntegration) GetToolDefinitions() []ToolDefinition

GetToolDefinitions returns all available tool definitions

func (*MCPServerIntegration) Shutdown 

func (msi *MCPServerIntegration) Shutdown(ctx context.Context) error

Shutdown gracefully shuts down the MCP server integration

type MateyMCPServer 

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

MateyMCPServer provides MCP tools for interacting with Matey and the cluster

func NewMateyMCPServer 

func NewMateyMCPServer(mateyBinary, configFile, namespace string) *MateyMCPServer

NewMateyMCPServer creates a new Matey MCP server

func (*MateyMCPServer) ExecuteTool 

func (m *MateyMCPServer) ExecuteTool(ctx context.Context, name string, arguments map[string]interface{}) (*ToolResult, error)

ExecuteTool executes a tool by name with the given arguments - slimmed down version

func (*MateyMCPServer) GetTools 

func (m *MateyMCPServer) GetTools() []Tool

GetTools returns the available MCP tools - slimmed down version with 21 consolidated tools

func (*MateyMCPServer) SetAgentFactory 

func (m *MateyMCPServer) SetAgentFactory(factory AgentFactory)

SetAgentFactory sets the factory function for creating TermChat instances

type MountInfo 

type MountInfo struct {
	WorkflowName string    `json:"workflowName"`
	ExecutionID  string    `json:"executionID"`
	PVCName      string    `json:"pvcName"`
	MountPath    string    `json:"mountPath"`
	MountedAt    time.Time `json:"mountedAt"`
	LastAccess   time.Time `json:"lastAccess"`
	AccessCount  int64     `json:"accessCount"`
}

MountInfo represents information about a mounted workspace

type ParseCodeRequest 

type ParseCodeRequest struct {
	FilePath    string   `json:"file_path"`
	Content     string   `json:"content,omitempty"`
	QueryTypes  []string `json:"query_types,omitempty"`
	IncludeBody bool     `json:"include_body,omitempty"`
}

ParseCodeRequest represents a request to parse code structure

type ParseCodeResponse 

type ParseCodeResponse struct {
	Success     bool                    `json:"success"`
	FilePath    string                  `json:"file_path"`
	Language    string                  `json:"language"`
	Definitions []treesitter.Definition `json:"definitions"`
	Structure   map[string]interface{}  `json:"structure,omitempty"`
	Error       string                  `json:"error,omitempty"`
	Metadata    map[string]interface{}  `json:"metadata,omitempty"`
}

ParseCodeResponse represents the response from parsing code

type PathMapping 

type PathMapping struct {
	HostPath      string `json:"host_path"`
	ContainerPath string `json:"container_path"`
	ServerName    string `json:"server_name"`
}

PathMapping represents a path mapping between host and container

type PathResolver 

type PathResolver struct {
	// Host working directory (where user started)
	HostWorkingDir string

	// Container working directory (for current MCP server)
	ContainerWorkingDir string
	// contains filtered or unexported fields
}

PathResolver handles path translation between different MCP server contexts

func NewPathResolver 

func NewPathResolver() *PathResolver

NewPathResolver creates a new path resolver with dynamic mappings

func (*PathResolver) AddMapping 

func (pr *PathResolver) AddMapping(hostPath, containerPath, serverName string)

AddMapping adds a custom path mapping

func (*PathResolver) GetContextInfo 

func (pr *PathResolver) GetContextInfo() map[string]interface{}

GetContextInfo returns context information for the AI

func (*PathResolver) GetCurrentWorkingDir 

func (pr *PathResolver) GetCurrentWorkingDir() string

GetCurrentWorkingDir returns the appropriate working directory for path resolution

func (*PathResolver) ResolveContainerToHost 

func (pr *PathResolver) ResolveContainerToHost(containerPath string) string

ResolveContainerToHost converts a container path to host path

func (*PathResolver) ResolveHostToContainer 

func (pr *PathResolver) ResolveHostToContainer(hostPath, serverName string) string

ResolveHostToContainer converts a host path to container path for a specific server

func (*PathResolver) ResolveWorkingDir 

func (pr *PathResolver) ResolveWorkingDir(workingDir string) string

ResolveWorkingDir resolves a working directory based on context

type ProcessMentionsRequest 

type ProcessMentionsRequest struct {
	Text         string `json:"text"`
	ExpandInline bool   `json:"expand_inline,omitempty"`
	TrackContext bool   `json:"track_context,omitempty"`
}

ProcessMentionsRequest represents a request to process @-mentions

type ProcessMentionsResponse 

type ProcessMentionsResponse struct {
	Success      bool                   `json:"success"`
	OriginalText string                 `json:"original_text"`
	ExpandedText string                 `json:"expanded_text,omitempty"`
	Mentions     []appcontext.Mention   `json:"mentions"`
	TotalTokens  int                    `json:"total_tokens"`
	Error        string                 `json:"error,omitempty"`
	Metadata     map[string]interface{} `json:"metadata,omitempty"`
}

ProcessMentionsResponse represents the response from processing mentions

type ReadFileRequest 

type ReadFileRequest struct {
	FilePath       string `json:"file_path"`
	StartLine      int    `json:"start_line,omitempty"`
	EndLine        int    `json:"end_line,omitempty"`
	IncludeContext bool   `json:"include_context,omitempty"`
	TrackInContext bool   `json:"track_in_context,omitempty"`
}

ReadFileRequest represents a request to read a file with context tracking

type ReadFileResponse 

type ReadFileResponse struct {
	Success   bool                   `json:"success"`
	FilePath  string                 `json:"file_path"`
	Content   string                 `json:"content"`
	Language  string                 `json:"language,omitempty"`
	LineCount int                    `json:"line_count"`
	Size      int64                  `json:"size"`
	Context   string                 `json:"context,omitempty"`
	Error     string                 `json:"error,omitempty"`
	Metadata  map[string]interface{} `json:"metadata,omitempty"`
}

ReadFileResponse represents the response from reading a file

type RelevantFile 

type RelevantFile struct {
	FilePath       string  `json:"file_path"`
	RelativePath   string  `json:"relative_path"`
	RelevanceScore float64 `json:"relevance_score"`
	Language       string  `json:"language,omitempty"`
	Size           int64   `json:"size"`
	ModTime        string  `json:"mod_time"`
	Reason         string  `json:"reason,omitempty"`
	Preview        string  `json:"preview,omitempty"`
	Context        string  `json:"context,omitempty"`
}

RelevantFile represents a file with relevance scoring

type SearchFilesRequest 

type SearchFilesRequest struct {
	Query          string   `json:"query"`
	Extensions     []string `json:"extensions,omitempty"`
	MaxResults     int      `json:"max_results,omitempty"`
	IncludeContent bool     `json:"include_content,omitempty"`
	FuzzySearch    bool     `json:"fuzzy_search,omitempty"`
}

SearchFilesRequest represents a request to search files

type SearchFilesResponse 

type SearchFilesResponse struct {
	Success  bool                   `json:"success"`
	Query    string                 `json:"query"`
	Results  []FileSearchResult     `json:"results"`
	Count    int                    `json:"count"`
	Error    string                 `json:"error,omitempty"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

SearchFilesResponse represents the response from searching files

type ServerInfo 

type ServerInfo struct {
	Name        string `json:"name"`
	Version     string `json:"version"`
	Description string `json:"description"`
	Tools       []Tool `json:"tools"`
}

ServerInfo represents information about an MCP server

type TermChat 

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

TermChat interface for bridging to existing implementations This is a temporary bridge - we'll eliminate this dependency later

type TodoItem 

type TodoItem struct {
	ID          string       `json:"id"`
	Content     string       `json:"content"`
	Status      TodoStatus   `json:"status"`
	Priority    TodoPriority `json:"priority"`
	CreatedAt   time.Time    `json:"created_at"`
	UpdatedAt   time.Time    `json:"updated_at"`
	CompletedAt *time.Time   `json:"completed_at,omitempty"`
}

type TodoList 

type TodoList struct {
	Items []TodoItem `json:"items"`
}

func (*TodoList) AddItem 

func (tl *TodoList) AddItem(content string, priority TodoPriority) string

func (*TodoList) ClearCompleted 

func (tl *TodoList) ClearCompleted() int

func (*TodoList) GetStats 

func (tl *TodoList) GetStats() map[string]interface{}

func (*TodoList) RemoveItem 

func (tl *TodoList) RemoveItem(id string) bool

func (*TodoList) UpdateItemStatus 

func (tl *TodoList) UpdateItemStatus(id string, status TodoStatus) bool

type TodoPriority 

type TodoPriority string
const (
	TodoPriorityLow    TodoPriority = "low"
	TodoPriorityMedium TodoPriority = "medium"
	TodoPriorityHigh   TodoPriority = "high"
	TodoPriorityUrgent TodoPriority = "urgent"
)

type TodoStatus 

type TodoStatus string

TODO types (migrated from chat package) 

const (
	TodoStatusPending    TodoStatus = "pending"
	TodoStatusInProgress TodoStatus = "in_progress"
	TodoStatusCompleted  TodoStatus = "completed"
	TodoStatusCancelled  TodoStatus = "cancelled"
)

type Tool 

type Tool struct {
	Name        string      `json:"name"`
	Description string      `json:"description"`
	InputSchema interface{} `json:"inputSchema"`
}

Tool represents an MCP tool

type ToolCallResult 

type ToolCallResult struct {
	ServerName string
	ToolName   string
	Arguments  map[string]interface{}
	Result     *ToolResult
	Error      error
}

ToolCallResult represents the result of calling an MCP tool

type ToolCallSummary 

type ToolCallSummary struct {
	Name     string        // Tool name
	Status   string        // ✓, ⚠, ✗
	Summary  string        // "Found 42 files", "Analyzed 156 lines"
	Duration time.Duration // How long the call took
}

ToolCallSummary represents a summary of a tool call for progress display

type ToolDefinition 

type ToolDefinition struct {
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	InputSchema map[string]interface{} `json:"inputSchema"`
}

ToolDefinition represents an MCP tool definition

type ToolHandler 

type ToolHandler func(ctx context.Context, params json.RawMessage) (interface{}, error)

ToolHandler represents a function that handles MCP tool calls

type ToolResult 

type ToolResult struct {
	Content []Content `json:"content"`
	IsError bool      `json:"isError,omitempty"`
}

ToolResult represents the result of a tool execution

type WorkflowStats 

type WorkflowStats struct {
	Total         int
	Succeeded     int
	Failed        int
	Running       int
	Pending       int
	AvgDuration   time.Duration
	LastExecution *time.Time
}

WorkflowStats represents calculated statistics for a specific workflow

type WorkspaceManager 

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

WorkspaceManager handles mounting and unmounting of workspace PVCs for chat agent access

func NewWorkspaceManager 

func NewWorkspaceManager(k8sClient kubernetes.Interface, namespace string, logger logr.Logger) *WorkspaceManager

NewWorkspaceManager creates a new workspace manager

func (*WorkspaceManager) CleanupExpiredMounts 

func (wm *WorkspaceManager) CleanupExpiredMounts()

CleanupExpiredMounts unmounts workspaces that haven't been accessed recently

func (*WorkspaceManager) GetMountPath 

func (wm *WorkspaceManager) GetMountPath(workflowName, executionID string) (string, bool)

GetMountPath returns the mount path for a workspace if it's mounted

func (*WorkspaceManager) ListMountedWorkspaces 

func (wm *WorkspaceManager) ListMountedWorkspaces() []MountInfo

ListMountedWorkspaces returns a list of currently mounted workspaces

func (*WorkspaceManager) MountWorkspacePVC 

func (wm *WorkspaceManager) MountWorkspacePVC(workflowName, executionID string) (string, error)

MountWorkspacePVC mounts a workspace PVC and returns the mount path

func (*WorkspaceManager) Shutdown 

func (wm *WorkspaceManager) Shutdown()

Shutdown unmounts all workspaces during server shutdown

func (*WorkspaceManager) UnmountWorkspacePVC 

func (wm *WorkspaceManager) UnmountWorkspacePVC(workflowName, executionID string) error

UnmountWorkspacePVC unmounts a workspace PVC

func (*WorkspaceManager) UpdateAccessTime 

func (wm *WorkspaceManager) UpdateAccessTime(workflowName, executionID string)

UpdateAccessTime updates the last access time for a mounted workspace

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.