fix(ryul): test by overriding reaper endpoint

reaper.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"math/rand"
 	"net"
+	"os"
 	"strings"
 	"sync"
 	"time"
@@ -197,7 +198,7 @@ func reuseOrCreateReaper(ctx context.Context, sessionID string, provider ReaperP
 // reuseReaperContainer constructs a Reaper from an already running reaper
 // DockerContainer.
 func reuseReaperContainer(ctx context.Context, sessionID string, provider ReaperProvider, reaperContainer *DockerContainer) (*Reaper, error) {
-	endpoint, err := reaperContainer.PortEndpoint(ctx, "8080", "")
+	endpoint, err := reaperEndpoint(ctx, reaperContainer)
 	if err != nil {
 		return nil, err
 	}
@@ -218,6 +219,14 @@ func reuseReaperContainer(ctx context.Context, sessionID string, provider Reaper
 	}, nil
 }
 
+func reaperEndpoint(ctx context.Context, c Container) (string, error) {
+	if _, exists := os.LookupEnv("TESTCONTAINERS_RYUK_ENDPOINT_OVERRIDE_BY_NAME"); exists {
+		return net.JoinHostPort(reaperContainerNameFromSessionID(c.SessionID()), "8080"), nil
+	}
+
+	return c.PortEndpoint(ctx, "8080", "")
+}
+
 // newReaper creates a Reaper with a sessionID to identify containers and a
 // provider to use. Do not call this directly, use reuseOrCreateReaper instead.
 func newReaper(ctx context.Context, sessionID string, provider ReaperProvider) (*Reaper, error) {
@@ -313,7 +322,7 @@ func newReaper(ctx context.Context, sessionID string, provider ReaperProvider) (
 	}
 	reaper.container = c
 
-	endpoint, err := c.PortEndpoint(ctx, "8080", "")
+	endpoint, err := reaperEndpoint(ctx, c)
 	if err != nil {
 		return nil, err
 	}