Make sure to add NewBackupHandler in order to expose the otherwise private handler outside the package

Author: Dylan Terry

replication/backup.go

@@ -131,6 +131,12 @@ type BackupEventHandler struct {
 	filename string
 }
 
+func NewBackupEventHandler(handlerFunction func(filename string) (io.WriteCloser, error)) *BackupEventHandler {
+	return &BackupEventHandler{
+		handler: handlerFunction,
+	}
+}
+
 // HandleEvent processes a single event for the backup.
 func (h *BackupEventHandler) HandleEvent(e *BinlogEvent) error {
 	h.mutex.Lock()

replication/backup_test.go

@@ -72,11 +72,11 @@ func testBackup(t *testSyncerSuite, isSynchronous bool) {
 
 	if isSynchronous {
 		// Set up a BackupEventHandler for synchronous mode
-		backupHandler := &BackupEventHandler{
-			handler: func(filename string) (io.WriteCloser, error) {
+		backupHandler := NewBackupEventHandler(
+			func(filename string) (io.WriteCloser, error) {
 				return os.OpenFile(path.Join(binlogDir, filename), os.O_CREATE|os.O_WRONLY, 0644)
 			},
-		}
+		)
 		t.b.cfg.SynchronousEventHandler = backupHandler
 	} else {
 		// Ensure SynchronousEventHandler is nil for asynchronous mode