How to use timePhase method of org.testcontainers.couchbase.CouchbaseContainer class

Best Testcontainers-java code snippet using org.testcontainers.couchbase.CouchbaseContainer.timePhase

Source:CouchbaseContainer.java

...211    }212    @Override213    protected void containerIsStarting(final InspectContainerResponse containerInfo) {214        logger().debug("Couchbase container is starting, performing configuration.");215        timePhase("waitUntilNodeIsOnline", this::waitUntilNodeIsOnline);216        timePhase("initializeIsEnterprise", this::initializeIsEnterprise);217        timePhase("renameNode", this::renameNode);218        timePhase("initializeServices", this::initializeServices);219        timePhase("configureAdminUser", this::configureAdminUser);220        timePhase("configureExternalPorts", this::configureExternalPorts);221        if (enabledServices.contains(CouchbaseService.INDEX)) {222            timePhase("configureIndexer", this::configureIndexer);223        }224    }225    @Override226    protected void containerIsStarted(InspectContainerResponse containerInfo) {227        timePhase("createBuckets", this::createBuckets);228        logger().info("Couchbase container is ready! UI available at http://{}:{}", getHost(), getMappedPort(MGMT_PORT));229    }230    /**231     * Before we can start configuring the host, we need to wait until the cluster manager is listening.232     */233    private void waitUntilNodeIsOnline() {234        new HttpWaitStrategy()235            .forPort(MGMT_PORT)236            .forPath("/pools")237            .forStatusCode(200)238            .waitUntilReady(this);239    }240    /**241     * Fetches edition (enterprise or community) of started container.242     */243    private void initializeIsEnterprise() {244        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/pools", "GET", null, true);245        try {246            isEnterprise = MAPPER.readTree(response.body().string()).get("isEnterprise").asBoolean();247        } catch (IOException e) {248            throw new IllegalStateException("Couchbase /pools did not return valid JSON");249        }250        if (!isEnterprise && enabledServices.contains(CouchbaseService.ANALYTICS)) {251            throw new IllegalStateException("The Analytics Service is only supported with the Enterprise version");252        }253    }254    /**255     * Rebinds/renames the internal hostname.256     * <p>257     * To make sure the internal hostname is different from the external (alternate) address and the SDK can pick it258     * up automatically, we bind the internal hostname to the internal IP address.259     */260    private void renameNode() {261        logger().debug("Renaming Couchbase Node from localhost to {}", getHost());262        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/node/controller/rename", "POST", new FormBody.Builder()263            .add("hostname", getInternalIpAddress())264            .build(), false265        );266        checkSuccessfulResponse(response, "Could not rename couchbase node");267    }268    /**269     * Initializes services based on the configured enabled services.270     */271    private void initializeServices() {272        logger().debug("Initializing couchbase services on host: {}", enabledServices);273        final String services = enabledServices274            .stream()275            .map(CouchbaseService::getIdentifier)276            .collect(Collectors.joining(","));277        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/node/controller/setupServices", "POST", new FormBody.Builder()278            .add("services", services)279            .build(), false280        );281        checkSuccessfulResponse(response, "Could not enable couchbase services");282    }283    /**284     * Configures the admin user on the couchbase node.285     * <p>286     * After this stage, all subsequent API calls need to have the basic auth header set.287     */288    private void configureAdminUser() {289        logger().debug("Configuring couchbase admin user with username: \"{}\"", username);290        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/settings/web", "POST", new FormBody.Builder()291            .add("username", username)292            .add("password", password)293            .add("port", Integer.toString(MGMT_PORT))294            .build(), false);295        checkSuccessfulResponse(response, "Could not configure couchbase admin user");296    }297    /**298     * Configures the external ports for SDK access.299     * <p>300     * Since the internal ports are not accessible from outside the container, this code configures the "external"301     * hostname and services to align with the mapped ports. The SDK will pick it up and then automatically connect302     * to those ports. Note that for all services non-ssl and ssl ports are configured.303     */304    private void configureExternalPorts() {305        logger().debug("Mapping external ports to the alternate address configuration");306        final FormBody.Builder builder = new FormBody.Builder();307        builder.add("hostname", getHost());308        builder.add("mgmt", Integer.toString(getMappedPort(MGMT_PORT)));309        builder.add("mgmtSSL", Integer.toString(getMappedPort(MGMT_SSL_PORT)));310        if (enabledServices.contains(CouchbaseService.KV)) {311            builder.add("kv", Integer.toString(getMappedPort(KV_PORT)));312            builder.add("kvSSL", Integer.toString(getMappedPort(KV_SSL_PORT)));313            builder.add("capi", Integer.toString(getMappedPort(VIEW_PORT)));314            builder.add("capiSSL", Integer.toString(getMappedPort(VIEW_SSL_PORT)));315        }316        if (enabledServices.contains(CouchbaseService.QUERY)) {317            builder.add("n1ql", Integer.toString(getMappedPort(QUERY_PORT)));318            builder.add("n1qlSSL", Integer.toString(getMappedPort(QUERY_SSL_PORT)));319        }320        if (enabledServices.contains(CouchbaseService.SEARCH)) {321            builder.add("fts", Integer.toString(getMappedPort(SEARCH_PORT)));322            builder.add("ftsSSL", Integer.toString(getMappedPort(SEARCH_SSL_PORT)));323        }324        if (enabledServices.contains(CouchbaseService.ANALYTICS)) {325            builder.add("cbas", Integer.toString(getMappedPort(ANALYTICS_PORT)));326            builder.add("cbasSSL", Integer.toString(getMappedPort(ANALYTICS_SSL_PORT)));327        }328        @Cleanup Response response = doHttpRequest(329            MGMT_PORT,330            "/node/controller/setupAlternateAddresses/external",331            "PUT",332            builder.build(),333            true334        );335        checkSuccessfulResponse(response, "Could not configure external ports");336    }337    /**338     * Configures the indexer service so that indexes can be created later on the bucket.339     */340    private void configureIndexer() {341        logger().debug("Configuring the indexer service");342        @Cleanup Response response = doHttpRequest(MGMT_PORT, "/settings/indexes", "POST", new FormBody.Builder()343            .add("storageMode", isEnterprise ? "memory_optimized" : "forestdb")344            .build(), true345        );346        checkSuccessfulResponse(response, "Could not configure the indexing service");347    }348    /**349     * Based on the user-configured bucket definitions, creating buckets and corresponding indexes if needed.350     */351    private void createBuckets() {352        logger().debug("Creating {} buckets (and corresponding indexes).", buckets.size());353        for (BucketDefinition bucket : buckets) {354            logger().debug("Creating bucket \"{}\"", bucket.getName());355            @Cleanup Response response = doHttpRequest(MGMT_PORT, "/pools/default/buckets", "POST", new FormBody.Builder()356                .add("name", bucket.getName())357                .add("ramQuotaMB", Integer.toString(bucket.getQuota()))358                .add("flushEnabled", bucket.hasFlushEnabled() ? "1" : "0")359                .build(), true);360            checkSuccessfulResponse(response, "Could not create bucket " + bucket.getName());361            timePhase("createBucket:" + bucket.getName() + ":waitForAllServicesEnabled", () ->362                new HttpWaitStrategy()363                .forPath("/pools/default/b/" + bucket.getName())364                .forPort(MGMT_PORT)365                .withBasicCredentials(username, password)366                .forStatusCode(200)367                .forResponsePredicate(new AllServicesEnabledPredicate())368                .waitUntilReady(this)369            );370            if (enabledServices.contains(CouchbaseService.QUERY)) {371                // If the query service is enabled, make sure that we only proceed if the query engine also372                // knows about the bucket in its metadata configuration.373                timePhase(374                    "createBucket:" + bucket.getName() + ":queryKeyspacePresent",375                    () -> Unreliables.retryUntilTrue(1, TimeUnit.MINUTES, () -> {376                        @Cleanup Response queryResponse = doHttpRequest(QUERY_PORT, "/query/service", "POST", new FormBody.Builder()377                            .add("statement", "SELECT COUNT(*) > 0 as present FROM system:keyspaces WHERE name = \"" + bucket.getName() + "\"")378                            .build(), true);379                        String body = queryResponse.body() != null ? queryResponse.body().string() : null;380                        checkSuccessfulResponse(queryResponse, "Could not poll query service state for bucket: " + bucket.getName());381                        return Optional.of(MAPPER.readTree(body))382                            .map(n -> n.at("/results/0/present"))383                            .map(JsonNode::asBoolean)384                            .orElse(false);385                }));386            }387            if (bucket.hasPrimaryIndex()) {388                if (enabledServices.contains(CouchbaseService.QUERY)) {389                    @Cleanup Response queryResponse = doHttpRequest(QUERY_PORT, "/query/service", "POST", new FormBody.Builder()390                        .add("statement", "CREATE PRIMARY INDEX on `" + bucket.getName() + "`")391                        .build(), true);392                    try {393                        checkSuccessfulResponse(queryResponse, "Could not create primary index for bucket " + bucket.getName());394                    } catch (IllegalStateException ex) {395                        // potentially ignore the error, the index will be eventually built.396                        if (!ex.getMessage().contains("Index creation will be retried in background")) {397                            throw ex;398                        }399                    }400                    timePhase(401                        "createBucket:" + bucket.getName() + ":primaryIndexOnline",402                        () ->  Unreliables.retryUntilTrue(1, TimeUnit.MINUTES, () -> {403                            @Cleanup Response stateResponse = doHttpRequest(QUERY_PORT, "/query/service", "POST", new FormBody.Builder()404                                .add("statement", "SELECT count(*) > 0 AS online FROM system:indexes where keyspace_id = \"" + bucket.getName() + "\" and is_primary = true and state = \"online\"")405                                .build(), true);406                            String body = stateResponse.body() != null ? stateResponse.body().string() : null;407                            checkSuccessfulResponse(stateResponse, "Could not poll primary index state for bucket: " + bucket.getName());408                            return Optional.of(MAPPER.readTree(body))409                                .map(n -> n.at("/results/0/online"))410                                .map(JsonNode::asBoolean)411                                .orElse(false);412                    }));413                } else {414                    logger().info("Primary index creation for bucket {} ignored, since QUERY service is not present.", bucket.getName());415                }416            }417        }418    }419    /**420     * Helper method to extract the internal IP address based on the network configuration.421     */422    private String getInternalIpAddress() {423        return getContainerInfo().getNetworkSettings().getNetworks().values().stream()424            .findFirst()425            .map(ContainerNetwork::getIpAddress)426            .orElseThrow(() -> new IllegalStateException("No network available to extract the internal IP from!"));427    }428    /**429     * Helper method to check if the response is successful and release the body if needed.430     *431     * @param response the response to check.432     * @param message the message that should be part of the exception of not successful.433     */434    private void checkSuccessfulResponse(final Response response, final String message) {435        if (!response.isSuccessful()) {436            String body = null;437            if (response.body() != null) {438                try {439                    body = response.body().string();440                } catch (IOException e) {441                    logger().debug("Unable to read body of response: {}", response, e);442                }443            }444            throw new IllegalStateException(message + ": " + response + ", body=" + (body == null ? "<null>" : body));445        }446    }447    /**448     * Checks if already running and if so raises an exception to prevent too-late setters.449     */450    private void checkNotRunning() {451        if (isRunning()) {452            throw new IllegalStateException("Setter can only be called before the container is running");453        }454    }455    /**456     * Helper method to perform a request against a couchbase server HTTP endpoint.457     *458     * @param port the (unmapped) original port that should be used.459     * @param path the relative http path.460     * @param method the http method to use.461     * @param body if present, will be part of the payload.462     * @param auth if authentication with the admin user and password should be used.463     * @return the response of the request.464     */465    private Response doHttpRequest(final int port, final String path, final String method, final RequestBody body,466                                   final boolean auth) {467        try {468            Request.Builder requestBuilder = new Request.Builder()469                .url("http://" + getHost() + ":" + getMappedPort(port) + path);470            if (auth) {471                requestBuilder = requestBuilder.header("Authorization", Credentials.basic(username, password));472            }473            if (body == null) {474                requestBuilder = requestBuilder.get();475            } else {476                requestBuilder = requestBuilder.method(method, body);477            }478            return HTTP_CLIENT.newCall(requestBuilder.build()).execute();479        } catch (Exception ex) {480            throw new RuntimeException("Could not perform request against couchbase HTTP endpoint ", ex);481        }482    }483    /**484     * Helper method which times an individual phase and logs it for debugging and optimization purposes.485     *486     * @param name the name of the phase.487     * @param toTime the runnable that should be timed.488     */489    private void timePhase(final String name, final Runnable toTime) {490        long start = System.nanoTime();491        toTime.run();492        long end = System.nanoTime();493        logger().debug("Phase {} took {}ms", name, TimeUnit.NANOSECONDS.toMillis(end - start));494    }495    /**496     * In addition to getting a 200, we need to make sure that all services we need are enabled and available on497     * the bucket.498     * <p>499     *  Fixes the issue observed in https://github.com/testcontainers/testcontainers-java/issues/2993500     */501    private class AllServicesEnabledPredicate implements Predicate<String> {502        @Override503        public boolean test(final String rawConfig) {...

timePhase

Using AI Code Generation

1import org.testcontainers.containers.output.Slf4jLogConsumer;2import org.testcontainers.containers.wait.strategy.Wait;3import org.testcontainers.couchbase.CouchbaseContainer;4import org.testcontainers.images.builder.ImageFromDockerfile;5import org.testcontainers.utility.DockerImageName;6import org.testcontainers.utility.MountableFile;7import org.testcontainers.containers.GenericContainer;8import org.testcontainers.containers.output.OutputFrame;9import org.testcontainers.containers.output.ToStringConsumer;10import org.testcontainers.containers.output.WaitingConsumer;11import org.testcontainers.containers.output.Slf4jLogConsumer;12import java.time.Duration;13import java.util.concurrent.TimeUnit;14import java.util.function.Consumer;15import static org.junit.Assert.assertTrue;16public class CouchbaseTest {17    static final String COUCHBASE_IMAGE = "couchbase/server";18    static final String COUCHBASE_VERSION = "6.6.2";19    static final DockerImageName COUCHBASE_DOCKER_IMAGE_NAME = DockerImageName.parse(COUCHBASE_IMAGE).withTag(COUCHBASE_VERSION);20    static final int COUCHBASE_PORT = 8091;21    static final String COUCHBASE_ADMIN_USER = "Administrator";22    static final String COUCHBASE_ADMIN_PASSWORD = "password";23    static final String COUCHBASE_BUCKET = "default";24    static final String COUCHBASE_BUCKET_PASSWORD = "password";25    static final String COUCHBASE_DOCKER_FILE = "Dockerfile";26    static final String COUCHBASE_DOCKER_CONTEXT = "src/test/resources/couchbase/";27    static final String COUCHBASE_DOCKERFILE_PATH = COUCHBASE_DOCKER_CONTEXT + COUCHBASE_DOCKER_FILE;28    static final int COUCHBASE_CONTAINER_STARTUP_TIMEOUT = 30;29    static final int COUCHBASE_CONTAINER_STOP_TIMEOUT = 30;30    static final String COUCHBASE_CONTAINER_NAME = "couchbase";31    static final String COUCHBASE_CONTAINER_LOG_PATH = "/opt/couchbase/var/lib/couchbase/logs";32    static final String COUCHBASE_CONTAINER_LOG_FILE = "couchbase.log";33    static final String COUCHBASE_CONTAINER_LOG_FILE_PATH = COUCHBASE_CONTAINER_LOG_PATH + "/" + COUCHBASE_CONTAINER_LOG_FILE;34    static final String COUCHBASE_CONTAINER_LOG_FILE_HOST_PATH = "target/logs/couchbase.log";

timePhase

Using AI Code Generation

1CouchbaseContainer couchbase = new CouchbaseContainer()2    .withNewBucket(DefaultBucketSettings.builder().name("default").quota(100).build())3    .withNewBucket(DefaultBucketSettings.builder().name("test").quota(100).build())4    .withTimePhase(2, TimeUnit.DAYS);5CouchbaseContainer couchbase = new CouchbaseContainer()6    .withNewBucket(DefaultBucketSettings.builder().name("default").quota(100).build())7    .withNewBucket(DefaultBucketSettings.builder().name("test").quota(100).build())8    .withTimePhase(Duration.ofDays(2));9CouchbaseContainer couchbase = new CouchbaseContainer()10    .withNewBucket(DefaultBucketSettings.builder().name("default").quota(100).build())11    .withNewBucket(DefaultBucketSettings.builder().name("test").quota(100).build())12    .withTimePhase(2);13CouchbaseContainer couchbase = new CouchbaseContainer()14    .withNewBucket(DefaultBucketSettings.builder().name("default").quota(100).build())15    .withNewBucket(DefaultBucketSettings.builder().name("test").quota(100).build())16    .withTimePhase(2, TimeUnit.DAYS);17CouchbaseContainer couchbase = new CouchbaseContainer()18    .withNewBucket(DefaultBucketSettings.builder().name("default").quota(100).build())19    .withNewBucket(DefaultBucketSettings.builder().name("test").quota(100).build())20    .withTimePhase(Duration.ofDays(2));21CouchbaseContainer couchbase = new CouchbaseContainer()22    .withNewBucket(DefaultBucketSettings.builder().name("default").quota(100).build())23    .withNewBucket(DefaultBucketSettings.builder().name("test").quota(100).build())24    .withTimePhase(2);

timePhase

Using AI Code Generation

1CouchbaseContainer couchbase = new CouchbaseContainer()2    .withTimePhase(CouchbaseContainer.TimePhase.INIT, Duration.ofSeconds(10))3    .withTimePhase(CouchbaseContainer.TimePhase.CREATE, Duration.ofSeconds(10))4    .withTimePhase(CouchbaseContainer.TimePhase.START, Duration.ofSeconds(10))5    .withTimePhase(CouchbaseContainer.TimePhase.WARMUP, Duration.ofSeconds(10));6@Language("JSON")7String json = "{" +8    "}";9String id = UUID.randomUUID().toString();10couchbase.getBucket().defaultCollection().insert(id, json);11String message = couchbase.getBucket().defaultCollection().get(id).contentAsObject().getString("message");12couchbase.getBucket().defaultCollection().upsert(id, json);13couchbase.getBucket().defaultCollection().remove(id);14String query = "SELECT * FROM `default` WHERE `message` = 'Hello World'";15N1qlQueryResult result = couchbase.getBucket().query(N1qlQuery.simple(query));16couchbase.stop();17CouchbaseContainer couchbase = new CouchbaseContainer()18    .withTimePhase(CouchbaseContainer.TimePhase.INIT, Duration.ofSeconds(10))19    .withTimePhase(CouchbaseContainer.TimePhase.CREATE, Duration.ofSeconds(10))20    .withTimePhase(CouchbaseContainer.TimePhase.START, Duration.ofSeconds(10))21    .withTimePhase(CouchbaseContainer.TimePhase.WARMUP, Duration.ofSeconds(10));22@Language("JSON")23String json = "{" +24    "}";25String id = UUID.randomUUID().toString();26couchbase.getBucket().defaultCollection().insert(id, json);27String message = couchbase.getBucket().defaultCollection().get(id).contentAsObject().getString("message");28couchbase.getBucket().defaultCollection().upsert(id, json);29couchbase.getBucket().defaultCollection().remove(id);

timePhase

Using AI Code Generation

1CouchbaseContainer<?> couchbase = new CouchbaseContainer<>(CB_VERSION)2    .withClusterAdmin("Administrator", "password")3    .withNewBucket(DefaultBucketSettings.builder()4        .enableFlush(true)5        .name("default")6        .quota(100)7        .build());8couchbase.start();9ElasticsearchContainer elasticsearch = new ElasticsearchContainer(ES_VERSION);10elasticsearch.start();11GenericContainer<?> container = new GenericContainer<>("alpine:latest")12    .withCommand("sleep", "60");13container.start();14WaitStrategy waitStrategy = new HttpWaitStrategy()15    .forPath("/health")16    .forStatusCode(200)17    .forResponsePredicate(response -> response.contains("UP"));18GenericContainer<?> container = new GenericContainer<>("alpine:latest")19    .withCommand("sleep", "60")20    .waitingFor(waitStrategy);21container.start();22WaitStrategy waitStrategy = new HttpWaitStrategy()23    .forPath("/health")24    .forStatusCode(200)25    .forResponsePredicate(response -> response.contains("UP"));26GenericContainer<?> container = new GenericContainer<>("alpine:latest")27    .withCommand("sleep", "60")28    .waitingFor(waitStrategy);29container.start();30WaitStrategy waitStrategy = new HttpWaitStrategy()31    .forPath("/health")32    .forStatusCode(200)33    .forResponsePredicate(response -> response.contains("UP"));34GenericContainer<?> container = new GenericContainer<>("alpine:latest")35    .withCommand("sleep", "60")36    .waitingFor(waitStrategy);37container.start();

timePhase

Using AI Code Generation

1import org.testcontainers.containers.CouchbaseContainer2def couchbase = new CouchbaseContainer("couchbase/server:latest")3couchbase.start()4def couchbaseContainer = couchbase.getCouchbaseContainer()5def timePhase = couchbaseContainer.timePhase("my phase") {6}7def couchbase = new CouchbaseContainer("couchbase/server:latest")8couchbase.start()9def couchbaseContainer = couchbase.getCouchbaseContainer()10def timePhase = couchbaseContainer.timePhase("my phase") {11}12def couchbase = new CouchbaseContainer("couchbase/server:latest")13couchbase.start()14def couchbaseContainer = couchbase.getCouchbaseContainer()15def timePhase = couchbaseContainer.timePhase("my phase") {16}17def couchbase = new CouchbaseContainer("couchbase/server:latest")18couchbase.start()19def couchbaseContainer = couchbase.getCouchbaseContainer()20def timePhase = couchbaseContainer.timePhase("my phase") {21}22def couchbase = new CouchbaseContainer("couchbase/server:latest")23couchbase.start()24def couchbaseContainer = couchbase.getCouchbaseContainer()25def timePhase = couchbaseContainer.timePhase("my phase") {26}27def couchbase = new CouchbaseContainer("couchbase/server:latest")28couchbase.start()29def couchbaseContainer = couchbase.getCouchbaseContainer()30def timePhase = couchbaseContainer.timePhase("my phase") {31}32def couchbase = new CouchbaseContainer("couchbase/server:latest")33couchbase.start()34def couchbaseContainer = couchbase.getCouchbaseContainer()35def timePhase = couchbaseContainer.timePhase("my phase") {

timePhase

Using AI Code Generation

1    public void testTimePhase() {2        CouchbaseContainer couchbase = new CouchbaseContainer().withTimePhase("2010-11-12T13:14:15.123Z");3        couchbase.start();4        couchbase.stop();5    }6    public void testTimeTravel() {7        CouchbaseContainer couchbase = new CouchbaseContainer().withTimeTravel("2010-11-12T13:14:15.123Z");8        couchbase.start();9        couchbase.stop();10    }11}

timePhase

Using AI Code Generation

1        def couchbase = new CouchbaseContainer()2                .withClusterUsername("Administrator")3                .withClusterPassword("password")4                .withNewBucket(DefaultBucketSettings.builder()5                        .enableFlush(true)6                        .name("default")7                        .quota(100)8                        .build())9                .waitingFor(Wait.forLogMessage(".*is now ready to accept connections.*", 1))10                .waitingFor(Wait.forHttp("/pools/default").forStatusCode(200))11                .waitingFor(Wait.forListeningPort())12                .withStartupAttempts(3)13                .withStartupTimeout(Duration.ofSeconds(30))14                .withCreateContainerCmdModifier(it -> it.withName("couchbase"))15                .withCreateContainerCmdModifier(it -> it.withHostName("couchbase"))16                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_MEMORY_QUOTA", "1024"))17                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_INDEX_MEMORY_QUOTA", "1024"))18                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_EVENTING_MEMORY_QUOTA", "1024"))19                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_FTS_MEMORY_QUOTA", "1024"))20                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_ANALYTICS_MEMORY_QUOTA", "1024"))21                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_CBAS_MEMORY_QUOTA", "1024"))22                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_AUTO_REPROVISION", "true"))23                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_AUTO_FAILOVER_TIMEOUT", "30"))24                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_AUTO_FAILOVER_MAX_RETRIES", "1"))25                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_AUTO_FAILOVER_SERVER_GROUP", "0"))26                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_AUTO_FAILOVER_ON_DATA_DISK_ISSUES", "true"))27                .withCreateContainerCmdModifier(it -> it.withEnv("COUCHBASE_AUTO_FAILOVER_ON_DATA_DISK_ISSUES_PERIOD",

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.