remove unused fault injector mock

Author: ndyakov

.gitignore

@@ -9,6 +9,7 @@ coverage.txt
 **/coverage.txt
 .vscode
 tmp/*
+*.test
 
 # maintenanceNotifications upgrade documentation (temporary)
 maintenanceNotifications/docs/

maintnotifications/e2e/cmd/fault-injector-server/main.go

@@ -0,0 +1,21 @@
+// Package e2e provides end-to-end testing scenarios for the maintenance notifications system.
+//
+// This package contains comprehensive test scenarios that validate the maintenance notifications
+// functionality in realistic environments. The tests are designed to work with Redis Enterprise
+// clusters and require specific environment configuration.
+//
+// Environment Variables:
+//   - E2E_SCENARIO_TESTS: Set to "true" to enable scenario tests
+//   - REDIS_ENDPOINTS_CONFIG_PATH: Path to endpoints configuration file
+//   - FAULT_INJECTION_API_URL: URL for fault injection API (optional)
+//
+// Test Scenarios:
+//   - Basic Push Notifications: Core functionality testing
+//   - Endpoint Types: Different endpoint resolution strategies
+//   - Timeout Configurations: Various timeout strategies
+//   - TLS Configurations: Different TLS setups
+//   - Stress Testing: Extreme load and concurrent operations
+//
+// Note: Maintenance notifications are currently supported only in standalone Redis clients.
+// Cluster clients (ClusterClient, FailoverClient, etc.) do not yet support this functionality.
+package e2e

maintnotifications/e2e/doc.go

@@ -2,7 +2,7 @@ package maintnotifications
 
 import (
 	"context"
-	"fmt"
+	"errors"
 	"net"
 	"sync"
 	"sync/atomic"
@@ -261,7 +261,7 @@ func (hwm *handoffWorkerManager) queueHandoff(conn *pool.Conn) error {
 		if internal.LogLevel.InfoOrAbove() {
 			internal.Logger.Printf(context.Background(), logs.ConnectionNotMarkedForHandoff(conn.GetID()))
 		}
-		return fmt.Errorf(logs.ConnectionNotMarkedForHandoffError(conn.GetID()))
+		return errors.New(logs.ConnectionNotMarkedForHandoffError(conn.GetID()))
 	}
 
 	// Create handoff request with atomically retrieved data

maintnotifications/handoff_worker.go

@@ -2,6 +2,7 @@ package maintnotifications
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"net"
 	"sync"
@@ -123,7 +124,7 @@ func (hm *Manager) setupPushNotifications() error {
 	// Register handlers for all upgrade notifications with the client's processor
 	for _, notificationType := range maintenanceNotificationTypes {
 		if err := processor.RegisterHandler(notificationType, handler, true); err != nil {
-			return fmt.Errorf(logs.FailedToRegisterHandler(notificationType, err))
+			return errors.New(logs.FailedToRegisterHandler(notificationType, err))
 		}
 	}
 

maintnotifications/manager.go

@@ -2,7 +2,7 @@ package maintnotifications
 
 import (
 	"context"
-	"fmt"
+	"errors"
 	"time"
 
 	"github.com/redis/go-redis/v9/internal"
@@ -154,7 +154,7 @@ func (snh *NotificationHandler) markConnForHandoff(conn *pool.Conn, newEndpoint
 		// Track the operation (ignore errors since this is optional)
 		_ = snh.operationsManager.TrackMovingOperationWithConnID(context.Background(), newEndpoint, deadline, seqID, connID)
 	} else {
-		return fmt.Errorf(logs.ManagerNotInitialized())
+		return errors.New(logs.ManagerNotInitialized())
 	}
 	return nil
 }