Versions in this module Expand all Collapse all v1 v1.17.0 Jul 12, 2026 Changes in this version + const APIKeyID + const BaseDuration + const DefaultAPIPath + const ExportFileName + const GracefulTimeout + const MCPVersion + const MaxValueLen + const NextMCPVersion + const OpenAPIVersion + const PingSemLimit + const SSERetryTime + const StateFileName + const StateFilePath + const SwaggerUIHTML + func GenerateAPIKey() string + func GenerateID() string + func GenerateMID() string + func HTTPError(w http.ResponseWriter, message string, statusCode int) + func SetCorsHeaders(w http.ResponseWriter) + func WriteJSON(w http.ResponseWriter, statusCode int, data any) + type Instance struct + Alias string + Config string + ID string + Meta Meta + Mode int32 + Ping int32 + Pool int32 + Restart bool + Status string + TCPRX uint64 + TCPS int32 + TCPTX uint64 + Type string + UDPRX uint64 + UDPS int32 + UDPTX uint64 + URL string + type InstanceEvent struct + Instance *Instance + Logs string + Time time.Time + Type string + type InstanceLogWriter struct + CheckPoint *regexp.Regexp + Instance *Instance + InstanceID string + Master *Master + Target io.Writer + func NewInstanceLogWriter(instanceID string, instance *Instance, target io.Writer, master *Master) *InstanceLogWriter + func (w *InstanceLogWriter) Write(p []byte) (n int, err error) + type MCPRequest struct + ID any + JSONRPC string + Method string + Params json.RawMessage + type MCPResponse struct + Error ... + ID any + JSONRPC string + Result any + type MCPToolCallParams struct + Arguments map[string]any + Name string + type Master struct + Alias string + CrtPath string + Hostname string + Instances sync.Map + KeyPath string + LogLevel string + MID string + MTLSConfig *tls.Config + MasterURL *url.URL + NotifyChannel chan *InstanceEvent + PeriodicDone chan struct{} + Prefix string + Server *http.Server + StartTime time.Time + StateMu sync.Mutex + StatePath string + Subscribers sync.Map + TCPingSem chan struct{} + Version string + func NewMaster(parsedURL *url.URL, tlsCode string, tlsConfig *tls.Config, ...) (*Master, error) + func (m *Master) EnhanceURL(instanceURL string, instanceType string) string + func (m *Master) FindInstance(id string) (*Instance, bool) + func (m *Master) GenerateConfigURL(instance *Instance) string + func (m *Master) GenerateOpenAPISpec() string + func (m *Master) GetMasterInfo() map[string]any + func (m *Master) HandleDeleteInstance(w http.ResponseWriter, id string, instance *Instance) + func (m *Master) HandleGetInstance(w http.ResponseWriter, instance *Instance) + func (m *Master) HandleInfo(w http.ResponseWriter, r *http.Request) + func (m *Master) HandleInstanceDetail(w http.ResponseWriter, r *http.Request) + func (m *Master) HandleInstances(w http.ResponseWriter, r *http.Request) + func (m *Master) HandleMCP(w http.ResponseWriter, r *http.Request) + func (m *Master) HandleMCPInitialize(w http.ResponseWriter, req MCPRequest) + func (m *Master) HandleMCPToolsCall(w http.ResponseWriter, req MCPRequest) + func (m *Master) HandleMCPToolsList(w http.ResponseWriter, req MCPRequest) + func (m *Master) HandleOpenAPISpec(w http.ResponseWriter, r *http.Request) + func (m *Master) HandlePatchInstance(w http.ResponseWriter, r *http.Request, id string, instance *Instance) + func (m *Master) HandlePutInstance(w http.ResponseWriter, r *http.Request, id string, instance *Instance) + func (m *Master) HandleSSE(w http.ResponseWriter, r *http.Request) + func (m *Master) HandleSwaggerUI(w http.ResponseWriter, r *http.Request) + func (m *Master) HandleTCPing(w http.ResponseWriter, r *http.Request) + func (m *Master) LoadState() + func (m *Master) MasterShutdown(ctx context.Context) error + func (m *Master) MonitorInstance(instance *Instance, cmd *exec.Cmd) + func (m *Master) PerformPeriodicBackup() + func (m *Master) PerformPeriodicCleanup() + func (m *Master) PerformPeriodicRestart() + func (m *Master) PerformTCPing(target string) *TCPingResult + func (m *Master) ProcessInstanceAction(instance *Instance, action string) + func (m *Master) ReGenerateAPIKey(instance *Instance) + func (m *Master) Run() + func (m *Master) SaveState() error + func (m *Master) SaveStateToPath(filePath string) error + func (m *Master) SendSSEEvent(eventType string, instance *Instance, logs ...string) + func (m *Master) SetInstanceURL(instance *Instance, updates map[string]string) error + func (m *Master) ShutdownSSEConnections() + func (m *Master) StartEventDispatcher() + func (m *Master) StartInstance(instance *Instance) + func (m *Master) StartPeriodicTasks() + func (m *Master) StopInstance(instance *Instance) + func (m *Master) WriteMCPError(w http.ResponseWriter, id any, code int, message string, data any) + func (m *Master) WriteMCPResponse(w http.ResponseWriter, id any, result any) + type Meta struct + Peer Peer + Tags map[string]string + type Peer struct + Alias string + SID string + Type string + type SystemInfo struct + CPU int + DiskR uint64 + DiskW uint64 + MemTotal uint64 + MemUsed uint64 + NetRX uint64 + NetTX uint64 + SwapTotal uint64 + SwapUsed uint64 + SysUp uint64 + func GetLinuxSysInfo() SystemInfo + type TCPingResult struct + Connected bool + Error *string + Latency int64 + Target string