How to use toxics method of org.testcontainers.containers.ToxiproxyContainer class

Best Testcontainers-java code snippet using org.testcontainers.containers.ToxiproxyContainer.toxics

Source:SmartRouterSystemTest.java

...241        return containers.has("result") ? 242               containers.getJSONObject("result").getJSONObject("kie-containers").getJSONArray("kie-container").length() : 0;243    }244    private void removeAllToxics(ToxiproxyContainer.ContainerProxy proxy) throws IOException {245        for (Toxic t : proxy.toxics().getAll()) {246            t.remove();247        }248    }249    250    251    private static Stream<Arguments> provideToxics() {252        ToxicSupplier<Toxic, IOException> limitData1 = () -> proxy1.toxics().limitData("limitData", DOWNSTREAM, 5);253        ToxicSupplier<Toxic, IOException> resetPeer1 = () -> proxy1.toxics().resetPeer("resetPeer", DOWNSTREAM, 0);254        ToxicSupplier<Toxic, IOException> timeout1 = () -> proxy1.toxics().timeout("timeout", DOWNSTREAM, getRandomTimeout(0,3000));255        256        ToxicSupplier<Toxic, IOException> limitData3 = () -> proxy3.toxics().limitData("limitData", DOWNSTREAM, 5);257        ToxicSupplier<Toxic, IOException> resetPeer3 = () -> proxy3.toxics().resetPeer("resetPeer", DOWNSTREAM, 0);258        ToxicSupplier<Toxic, IOException> timeout3 = () -> proxy3.toxics().timeout("timeout", DOWNSTREAM, getRandomTimeout(2000,5000));259        260        return Stream.of(Arguments.of(limitData1, null),261                         Arguments.of(resetPeer1, null),262                         Arguments.of(timeout1, null),263                         Arguments.of(null, limitData3),264                         Arguments.of(null, resetPeer3),265                         Arguments.of(null, timeout3),266                         Arguments.of(limitData1, limitData3),267                         Arguments.of(limitData1, resetPeer3),268                         Arguments.of(limitData1, timeout3),269                         Arguments.of(resetPeer1, limitData3),270                         Arguments.of(resetPeer1, resetPeer3),271                         Arguments.of(resetPeer1, timeout3),272                         Arguments.of(timeout1, limitData3),273                         Arguments.of(timeout1, resetPeer3),274                         Arguments.of(timeout1, timeout3),275                         Arguments.of(null, null));276    }277    278    public static int getRandomTimeout(int min, int max) {279        Random random = new Random();280        int timeout = random.ints(min, max).findFirst().getAsInt();281        logger.debug("random timeout is {} ms", timeout);282        return timeout;283    }284    285    @ParameterizedTest286    @MethodSource("provideToxics")287    void shouldUpdateRoutingTableWhenDisconnectedAndReconnected(ToxicSupplier<Toxic, IOException> toxic1, 288                                                                ToxicSupplier<Toxic, IOException> toxic3) throws Exception {289        logger.debug("*** Cut Connection ***");290        291        cutConnection(toxic1, toxic3);292        293        logger.debug("*** Reestablish Connection ***");294        removeAllToxics(proxy1);295        removeAllToxics(proxy3);296        297        await().atMost(ONE_MINUTE).untilAsserted(() -> assertThat(readNumberOfContainers()).isEqualTo(2));298        299        await().atMost(ONE_MINUTE).until(() -> assertServersInRoutingTable(URL_NODE1, URL_NODE3));300    }301    @ParameterizedTest302    @MethodSource("provideToxics")303    void shouldStopPollingWhenReconnectionLimitIsReached(ToxicSupplier<Toxic, IOException> toxic1, 304                                                         ToxicSupplier<Toxic, IOException> toxic3) throws Exception {305        306        logger.debug("*** Cut Connection ***");307        TestFixture fixture = cutConnection(toxic1, toxic3);308        309        if (!fixture.exercisedToxics.isEmpty()) {310            logger.debug("*** Waiting for max_reach ***");311            consumerSmartRouter.waitUntil(frame -> frame.getUtf8String().contains(REACHED_ATTEMPTS_LIMIT), 312                50, TimeUnit.SECONDS, 2-fixture.expectedContainers+reachedLimitCounter);313        }314        315        logger.debug("*** Reestablish Connection ***");316        removeAllToxics(proxy1);317        removeAllToxics(proxy3);318        319        await().atMost(ONE_MINUTE).untilAsserted(() -> assertThat(readNumberOfContainers()).isEqualTo(fixture.expectedContainers));320        321        await().atMost(ONE_MINUTE).until(() -> assertServersInRoutingTable(fixture.expectedServers[1], fixture.expectedServers[3]));322    }323    private TestFixture cutConnection(ToxicSupplier<Toxic, IOException> toxic1, ToxicSupplier<Toxic, IOException> toxic3)324            throws IOException {325        TestFixture fixture = getTestFixture(toxic1, toxic3);326        327        logger.debug("Exercising with toxics:{}", fixture.exercisedToxics);328        logger.debug("expectedContainers:{} and expectedServer1:{} and expectedServer3:{}", 329                      fixture.expectedContainers, fixture.expectedServers[1], fixture.expectedServers[3]);330        331        await().atMost(ONE_MINUTE).untilAsserted(() -> assertThat(readNumberOfContainers()).isEqualTo(fixture.expectedContainers));332        333        final String expected1 = fixture.expectedServers[1];334        final String expected3 = fixture.expectedServers[3];335        336        await().atMost(ONE_MINUTE).until(() -> assertServersInRoutingTable(expected1, expected3));337        338        return fixture;339    }340    341    private TestFixture getTestFixture(ToxicSupplier<Toxic, IOException> toxic1, ToxicSupplier<Toxic, IOException> toxic3) throws IOException {...

Source:EdgeTestBase.java

...74                log.info("Cutting connection on {} image.", img.getName());75                CompletableFuture.runAsync(() -> {76                    try {77                        log.info("Adding CUT_CONNECTION_DOWNSTREAM toxic");78                        img.proxy.toxics().limitData("CUT_CONNECTION_DOWNSTREAM", ToxicDirection.DOWNSTREAM, 0L);79                        log.info("Adding CUT_CONNECTION_UPSTREAM toxic");80                        img.proxy.toxics().limitData("CUT_CONNECTION_UPSTREAM", ToxicDirection.UPSTREAM, 0L);81                    } catch (IOException e) {82                        log.error("Could not add Toxic, ", e);83                        throw new CompletionException(e);84                    }85                }).get(TIMEOUT_IT, TimeUnit.MILLISECONDS);86                img.isCurrentlyCut.set(true);87            } else if (!cut && img.isCurrentlyCut.get()) {88                log.info("Uncutting connection on {} image.", img.getName());89                removeWithTimeout(img.proxy.toxics().get("CUT_CONNECTION_DOWNSTREAM"), 0);90                removeWithTimeout(img.proxy.toxics().get("CUT_CONNECTION_UPSTREAM"), 0);91                img.isCurrentlyCut.set(false);92            } else {93                log.info("{} Image is already in the desired state.", img.getName());94            }95        } catch (IOException | InterruptedException | TimeoutException | ExecutionException e) {96            throw new RuntimeException("Could not control proxy", e);97        }98    }99    public static void removeWithTimeout (Toxic toxic, int counter) throws InterruptedException, TimeoutException, ExecutionException {100        try {101            CompletableFuture.runAsync(() -> {102                try {103                    toxic.remove();104                } catch (IOException e) {...

Source:PulsarContainerTest.java

...42        pulsar.stop();43        network.close();44    }45    protected void testPulsarFunctionality(String pulsarBrokerUrl) throws Exception {46        pulsarProxy.toxics()47                .latency("latencyDownstream", ToxicDirection.DOWNSTREAM, 1_100)48                .setJitter(150);49        pulsarProxy.toxics()50                .latency("latencyUpstream", ToxicDirection.UPSTREAM, 2_100)51                .setJitter(200);52        @Cleanup53        final PulsarClient client = PulsarClient.builder()54                .serviceUrl(pulsarBrokerUrl)55                .build();56        @Cleanup57        final Consumer<String> consumer = client.newConsumer(Schema.STRING)58                .topic(TEST_TOPIC)59                .subscriptionName("test-subs")60                .subscribe();61        @Cleanup62        final Producer<String> producer = client.newProducer(Schema.STRING)63                .topic(TEST_TOPIC)...

toxics

Using AI Code Generation

1package org.testcontainers.containers;2import com.github.dockerjava.api.DockerClient;3import com.github.dockerjava.api.command.CreateContainerCmd;4import com.github.dockerjava.api.command.CreateContainerResponse;5import com.github.dockerjava.api.command.ExecCreateCmdResponse;6import com.github.dockerjava.api.command.InspectContainerResponse;7import com.github.dockerjava.api.command.InspectExecResponse;8import com.github.dockerjava.api.model.Container;9import com.github.dockerjava.api.model.ExposedPort;10import com.github.dockerjava.api.model.Link;11import com.github.dockerjava.api.model.Ports.Binding;12import com.github.dockerjava.api.model.Ports.Binding;13import com.github.dockerjava.api.model.Ports;14import com.github.dockerjava.core.command.ExecStartResultCallback;15import com.github

toxics

Using AI Code Generation

1import org.junit.Test;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.ToxiproxyContainer;4import org.testcontainers.containers.output.Slf4jLogConsumer;5import org.testcontainers.containers.wait.strategy.Wait;6import org.testcontainers.utility.DockerImageName;7import org.testcontainers.utility.MountableFile;8import java.io.IOException;9import static org.junit.Assert.*;10public class 1 {11    public void testToxiproxy() throws IOException {12        ToxiproxyContainer toxiproxy = new ToxiproxyContainer(DockerImageName.parse("shopify/toxiproxy:2.1.4"));13        toxiproxy.start();14        GenericContainer webServer = new GenericContainer(DockerImageName.parse("httpd:2.4.39-alpine"))15                .withExposedPorts(80)16                .withCopyFileToContainer(MountableFile.forClasspathResource("index.html"), "/usr/local/apache2/htdocs/index.html")17                .waitingFor(Wait.forHttp("/").forStatusCode(200));18        webServer.start();19        GenericContainer webClient = new GenericContainer(DockerImageName.parse("alpine:3.12.1"))20                .withLogConsumer(new Slf4jLogConsumer(org.slf4j.LoggerFactory.getLogger("webClient")))21                .withNetwork(toxiproxy.getNetwork())22                .withNetworkAliases("webserver")23                .withEnv("http_proxy", toxiproxy.getProxy(webServer, 80).getListenAddress());24        webClient.start();25        toxiproxy.getProxy(webServer, 80).toxics().latency("latency", ToxiproxyContainer.ToxicDirection.DOWNSTREAM, 10000);26        Thread.sleep(60000);27        toxiproxy.stop();28    }29}30The testToxiproxy() method creates a toxiproxy container, a web server container, and a web client container. The web server container is exposed

toxics

Using AI Code Generation

1import org.testcontainers.containers.ToxiproxyContainer;2import org.testcontainers.containers.ToxiproxyContainer.ContainerProxy;3import org.testcontainers.containers.ToxiproxyContainer.ToxicDirection;4import org.testcontainers.containers.ToxiproxyContainer.ToxicList;5import org.testcontainers.containers.ToxiproxyContainer.ToxicProxy;6public class ToxiproxyContainerTest {7    public static void main(String[] args) {8        ToxiproxyContainer toxiproxyContainer = new ToxiproxyContainer()9                .withProxy("http", 8080, 8081)10                .withProxy("https", 8082, 8083);11        toxiproxyContainer.start();12        ContainerProxy containerProxy = toxiproxyContainer.getProxy("http");13        ToxicProxy toxicProxy = containerProxy.toxics();14        ToxicList toxicList = toxicProxy.list();15        toxicList.getToxics();16        toxicProxy.latency("latency", ToxicDirection.DOWNSTREAM, 1000);17        toxicProxy.bandwidth("bandwidth", ToxicDirection.DOWNSTREAM, 1000);18        toxicProxy.slowClose("slow_close", ToxicDirection.DOWNSTREAM, 1000);19        toxicProxy.timeout("timeout", ToxicDirection.DOWNSTREAM, 1000);20        toxicProxy.slicer("slicer", ToxicDirection.DOWNSTREAM, 1000, 1000, 1000);21        toxicProxy.limitData("limit_data", ToxicDirection.DOWNSTREAM, 1000);22        toxicProxy.shuffle("shuffle", ToxicDirection.DOWNSTREAM);

toxics

Using AI Code Generation

1package org.testcontainers.containers;2import com.github.dockerjava.api.model.ContainerNetwork;3import com.github.dockerjava.api.model.Network.Ipam;4import com.github.dockerjava.api.model.Network.Ipam.Config;5import com.github.dockerjava.api.model.Network.Ipam.Config.Builder;6import org.testcontainers.containers.wait.strategy.Wait;7import org.testcontainers.utility.Base58;8import org.testcontainers.utility.DockerImageName;9import java.util.Collections;10import java.util.HashMap;11import java.util.Map;12import java.util.Map.Entry;

toxics

Using AI Code Generation

1import java.io.IOException;2import java.util.concurrent.TimeoutException;3import org.testcontainers.containers.ToxiproxyContainer;4import org.testcontainers.containers.ToxiproxyContainer.ContainerProxy;5import org.testcontainers.containers.ToxiproxyContainer.ToxicDirection;6import org.testcontainers.containers.ToxiproxyContainer.ToxicList;7import org.testcontainers.containers.ToxiproxyContainer.ToxicType;8public class 1 {9    public static void main(String[] args) throws IOException, TimeoutException {10        ToxiproxyContainer toxiproxy = new ToxiproxyContainer();11        toxiproxy.start();12        ContainerProxy proxy = toxiproxy.getProxy(toxiproxy.getContainerIpAddress(), 6379);13        ToxicList toxicList = proxy.toxics().list();14        toxicList.add(ToxicType.SLOW_CLOSE, ToxicDirection.DOWNSTREAM, 10000, 0);15        System.out.println(toxicList);16    }17}18ToxicList{toxics=[SlowCloseToxic{attributes=SlowCloseToxicAttributes{rate=10000, d

toxics

Using AI Code Generation

1ToxiproxyContainer toxiproxy = new ToxiproxyContainer();2toxiproxy.start();3Proxy proxy = toxiproxy.getProxy(container, 8080);4Latency latency = proxy.addLatency(ToxiproxyContainer.ToxicDirection.DOWNSTREAM, 1000);5latency.remove();6proxy.stop();7toxiproxy.stop();8Network network = Network.newNetwork();9ToxiproxyContainer toxiproxy = new ToxiproxyContainer();10toxiproxy.start();11Proxy proxy = toxiproxy.getProxy(container, 8080);12Latency latency = proxy.addLatency(ToxiproxyContainer.ToxicDirection.DOWNSTREAM, 1000);13latency.remove();14proxy.stop();15toxiproxy.stop();16network.close();17ToxiproxyContainer toxiproxy = new ToxiproxyContainer();18toxiproxy.start();19Proxy proxy = toxiproxy.getProxy(container, 8080);20Latency latency = proxy.addLatency(ToxiproxyContainer.ToxicDirection.DOWNSTREAM, 1000);21latency.remove();22proxy.stop();23toxiproxy.stop();24ToxiproxyContainer toxiproxy = new ToxiproxyContainer();25toxiproxy.start();26Proxy proxy = toxiproxy.getProxy(container, 8080);27Latency latency = proxy.addLatency(ToxiproxyContainer.ToxicDirection.DOWNSTREAM, 1000);28latency.remove();29proxy.stop();30toxiproxy.stop();

toxics

Using AI Code Generation

1package org.testcontainers.containers;2import org.testcontainers.containers.ToxiproxyContainer.ContainerProxy;3public class toxics {4    public static void main(String[] args) throws Exception {5        try (ToxiproxyContainer toxiproxy = new ToxiproxyContainer()) {6            toxiproxy.start();7            ContainerProxy proxy = toxiproxy.getProxy(toxiproxy.getContainerIpAddress(), toxiproxy.getProxyPort(80));8            proxy.toxics().latency("latency", ToxicDirection.DOWNSTREAM, 10000);9        }10    }11}12package org.testcontainers.containers;13import org.testcontainers.containers.ToxiproxyContainer.ContainerProxy;14public class toxics {15    public static void main(String[] args) throws Exception {16        try (ToxiproxyContainer toxiproxy = new ToxiproxyContainer()) {17            toxiproxy.start();18            ContainerProxy proxy = toxiproxy.getProxy(toxiproxy.getContainerIpAddress(), toxiproxy.getProxyPort(80));19            proxy.toxics().latency("latency", ToxicDirection.DOWNSTREAM, 10000);20        }21    }22}23package org.testcontainers.containers;24import org.testcontainers.containers.ToxiproxyContainer.ContainerProxy;25public class toxics {26    public static void main(String[] args) throws Exception {27        try (ToxiproxyContainer toxiproxy = new ToxiproxyContainer()) {28            toxiproxy.start();29            ContainerProxy proxy = toxiproxy.getProxy(toxiproxy.getContainerIpAddress(), toxiproxy.getProxyPort(80));30            proxy.toxics().latency("latency", ToxicDirection.DOWNSTREAM, 10000);31        }32    }33}34package org.testcontainers.containers;35import org.testcontainers.containers.ToxiproxyContainer.ContainerProxy;36public class toxics {

toxics

Using AI Code Generation

1import org.testcontainers.containers.ToxiproxyContainer;2import org.testcontainers.utility.DockerImageName;3public class TestToxiproxy {4    public static void main(String[] args) throws Exception {5        try (ToxiproxyContainer toxiproxy = new ToxiproxyContainer(DockerImageName.parse("shopify/toxiproxy:2.1.4"))) {6            toxiproxy.start();7            ToxiproxyContainer.ContainerProxy proxy = toxiproxy.getProxy(toxiproxy.getContainerIpAddress(),8                    toxiproxy.getProxyPort());9            proxy.toxics().latency("latency", ToxiproxyContainer.ToxicDirection.DOWNSTREAM, 10000, 1000);10        }11    }12}

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.