endpoint randomisation stopped

canned/elasticsearch.go

@@ -23,7 +23,7 @@ func NewElasticSearch(ctx context.Context) (*ElasticSearch, error) {
 	_ = os.Setenv("TC_HOST", "localhost")
 	req := testcontainers.ContainerRequest{
 		Image: getEnvString("ES_CONTAINER_IMAGE", "docker.elastic.co/elasticsearch/elasticsearch-oss:7.0.0"),
-		//Image: getEnvString("ES_CONTAINER_IMAGE", "157529275398.dkr.ecr.ap-south-1.amazonaws.com/ci-libraries/docker.elastic.co/elasticsearch/elasticsearch:6.4.2"),
+		//Image: getEnvString("ES_CONTAINER_IMAGE", "elasticsearch:7.0.0"),
 		Env: map[string]string{
 			"discovery.type":    "single-node",
 			"network.host":      "0.0.0.0",
@@ -46,16 +46,16 @@ func NewElasticSearch(ctx context.Context) (*ElasticSearch, error) {
 	}
 	host, _ := container.Host(ctx)
 	port, _ := container.MappedPort(ctx, "9200")
-	port2, _ := container.MappedPort(ctx, "9300")
-	endpoint, err := container.Endpoint(ctx, "")
-	endpoint = fmt.Sprintf("http://%s", endpoint)
+	//port2, _ := container.MappedPort(ctx, "9300")
+	//endpoint, err := container.Endpoint(ctx, "")
+	endpoint := fmt.Sprintf("http://%s:%s", host, port.Port())
 
 	if err != nil {
 		return nil, err
 	}
 
 	client, err := elasticsearch.NewClient(elasticsearch.Config{
-		Addresses:            []string{endpoint, fmt.Sprintf("http://%s:%s", host, port2.Port())},
+		Addresses:            []string{endpoint}, //, fmt.Sprintf("http://%s:%s", host, port2.Port())},
 		EnableRetryOnTimeout: true,
 	})
 	if err != nil {