typos

Author: smarunich

management/k8s.go

@@ -1091,51 +1091,6 @@ func (k *K8sClient) UpdateConfigMap(namespace, configMapName string, data map[st
 }
 // Missing Gateway API operations
 
-// DeleteHTTPRoute deletes an HTTPRoute
-func (k *K8sClient) DeleteHTTPRoute(namespace, routeName string) error {
-	ctx := context.Background()
-	
-	err := k.dynamicClient.Resource(HTTPRouteGVR).Namespace(namespace).Delete(ctx, routeName, metav1.DeleteOptions{})
-	if err != nil {
-		k.logError("DeleteHTTPRoute", err)
-		return fmt.Errorf("failed to delete HTTPRoute: %w", err)
-	}
-	
-	return nil
-}
-
-// DeleteAIGatewayRoute deletes an AIGatewayRoute
-func (k *K8sClient) DeleteAIGatewayRoute(namespace, routeName string) error {
-	ctx := context.Background()
-	
-	err := k.dynamicClient.Resource(AIGatewayRouteGVR).Namespace(namespace).Delete(ctx, routeName, metav1.DeleteOptions{})
-	if err != nil {
-		k.logError("DeleteAIGatewayRoute", err)
-		return fmt.Errorf("failed to delete AIGatewayRoute: %w", err)
-	}
-	
-	return nil
-}
-
-// DeletePublishedModelMetadata deletes published model metadata
-func (k *K8sClient) DeletePublishedModelMetadata(namespace, modelName string) error {
-	ctx := context.Background()
-	
-	configMapName := fmt.Sprintf("published-model-metadata-%s", modelName)
-	
-	err := k.clientset.CoreV1().ConfigMaps(namespace).Delete(ctx, configMapName, metav1.DeleteOptions{})
-	if err != nil {
-		k.logError("DeletePublishedModelMetadata", err)
-		return fmt.Errorf("failed to delete published model metadata: %w", err)
-	}
-	
-	return nil
-}
-
-// Helper function to generate unique key IDs
-func generateKeyID() string {
-	return uuid.New().String()
-}
 
 // Helper function to check if error is resource not found
 func IsResourceNotFoundError(err error) bool {

management/publishing.go

@@ -1203,89 +1203,3 @@ func (s *PublishingService) cleanupPublishedModelMetadata(namespace, modelName s
 	}
 }
 
-func (s *PublishingService) logPublishingEvent(user *User, modelName, namespace, action string) {
-	// Create audit log entry
-	logEntry := map[string]interface{}{
-		"timestamp": time.Now().Format(time.RFC3339),
-		"action":    action,
-		"modelName": modelName,
-		"namespace": namespace,
-		"user": map[string]interface{}{
-			"tenant":  user.Tenant,
-			"name":    user.Name,
-			"subject": user.Subject,
-			"isAdmin": user.IsAdmin,
-		},
-	}
-	
-	// Store audit log as ConfigMap
-	auditLogName := fmt.Sprintf("publishing-audit-%s", time.Now().Format("2006-01-02"))
-	
-	// Try to get existing audit log for today
-	existingLog, err := s.k8sClient.GetConfigMap(namespace, auditLogName)
-	if err != nil {
-		// Create new audit log
-		auditData := map[string]interface{}{
-			"entries": []interface{}{logEntry},
-		}
-		s.k8sClient.CreateConfigMap(namespace, auditLogName, auditData)
-	} else {
-		// Append to existing audit log
-		if entries, ok := existingLog["entries"].([]interface{}); ok {
-			entries = append(entries, logEntry)
-			existingLog["entries"] = entries
-			s.k8sClient.UpdateConfigMap(namespace, auditLogName, existingLog)
-		}
-	}
-	
-	// Also log to application logs
-	log.Printf("Publishing event: %s - User: %s (%s) - Model: %s/%s", action, user.Name, user.Tenant, namespace, modelName)
-}
-
-// Cleanup methods
-func (s *PublishingService) cleanupAPIKey(namespace, modelName string) {
-	// Delete API key secret
-	secretName := fmt.Sprintf("published-model-apikey-%s", modelName)
-	
-	if err := s.k8sClient.DeleteAPIKeySecret(namespace, secretName); err != nil {
-		log.Printf("Failed to cleanup API key secret %s/%s: %v", namespace, secretName, err)
-	}
-}
-
-func (s *PublishingService) cleanupGatewayConfiguration(namespace, modelName string) {
-	// Delete HTTPRoute and AIGatewayRoute
-	routeName := fmt.Sprintf("published-model-%s-%s", namespace, modelName)
-	
-	// Delete HTTPRoute
-	if err := s.k8sClient.DeleteHTTPRoute("envoy-gateway-system", routeName); err != nil {
-		log.Printf("Failed to cleanup HTTPRoute %s: %v", routeName, err)
-	}
-	
-	// Delete AIGatewayRoute
-	if err := s.k8sClient.DeleteAIGatewayRoute("envoy-gateway-system", routeName); err != nil {
-		log.Printf("Failed to cleanup AIGatewayRoute %s: %v", routeName, err)
-	}
-}
-
-func (s *PublishingService) cleanupRateLimitingPolicy(namespace, modelName string) {
-	// Delete BackendTrafficPolicy
-	policyName := fmt.Sprintf("published-model-rate-limit-%s-%s", namespace, modelName)
-	
-	if err := s.k8sClient.DeleteBackendTrafficPolicy("envoy-gateway-system", policyName); err != nil {
-		log.Printf("Failed to cleanup BackendTrafficPolicy %s: %v", policyName, err)
-	}
-}
-
-func (s *PublishingService) cleanupPublishedModelMetadata(namespace, modelName string) {
-	// Delete published model metadata ConfigMap
-	metadataName := fmt.Sprintf("published-model-metadata-%s", modelName)
-	
-	if err := s.k8sClient.DeletePublishedModelMetadata(namespace, metadataName); err != nil {
-		log.Printf("Failed to cleanup published model metadata %s/%s: %v", namespace, metadataName, err)
-	}
-}
-
-// Utility functions
-func generateKeyID() string {
-	return uuid.New().String()
-}