discovery

type ConnectionStatus struct {
	Connected     bool      `json:"connected"`
	LastConnected time.Time `json:"lastConnected"`
	ErrorCount    int       `json:"errorCount"`
	LastError     string    `json:"lastError"`
}

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

type K8sServiceDiscovery struct {
	Client    kubernetes.Interface // Public for testing
	Namespace string               // Public for testing
	Logger    *logging.Logger      // Public for testing
	// contains filtered or unexported fields
}

type MCPConnection struct {
	Name            string
	Endpoint        string
	Protocol        string
	Port            int32
	Capabilities    []string
	Status          string
	LastSeen        time.Time
	HTTPConnection  *MCPHTTPConnection
	SSEConnection   *MCPSSEConnection
	StdioConnection *MCPSTDIOConnection
	LastUsed        time.Time
	ErrorCount      int
	// contains filtered or unexported fields
}

type MCPHTTPConnection struct {
	BaseURL  string
	Client   *http.Client
	LastUsed time.Time
}

type MCPSSEConnection struct {
	BaseURL  string
	Client   *http.Client
	LastUsed time.Time
}

type MCPSTDIOConnection struct {
	Process  *http.Client // Placeholder
	LastUsed time.Time
}

type ServiceDiscoveryEvent struct {
	Type    string          `json:"type"` // "ADDED", "MODIFIED", "DELETED"
	Service ServiceEndpoint `json:"service"`
}

type ServiceDiscoveryHandler interface {
	OnServiceAdded(endpoint ServiceEndpoint)
	OnServiceModified(endpoint ServiceEndpoint)
	OnServiceDeleted(serviceName, namespace string)
}

type ServiceEndpoint struct {
	Name           string            `json:"name"`
	Namespace      string            `json:"namespace"`
	URL            string            `json:"url"`
	Endpoint       string            `json:"endpoint"` // For compatibility with tests
	Protocol       string            `json:"protocol"`
	Port           int32             `json:"port"`
	Capabilities   []string          `json:"capabilities"`
	Labels         map[string]string `json:"labels"`
	LastDiscovered time.Time         `json:"lastDiscovered"`
	HealthStatus   string            `json:"healthStatus"`
	ServiceType    string            `json:"serviceType"`
}