Function toxiproxy_start

test/pubsub-disruption/mzcompose.py:176–186

(c: Composition)

def toxiproxy_start(c: Composition) -> None:
    c.up("toxiproxy")
    c.testdrive(input=dedent("""
                $ http-request method=POST url=http://toxiproxy:8474/proxies content-type=application/json
                {
                   "name": "pubsub",
                   "listen": "0.0.0.0:6879",
                   "upstream": "materialized:6879",
                   "enabled": true
                }
                """))