Dependencies
- ant/ant/1.5.1 (available as org.apache.ant/ant/1.10.7)
- antlr/antlr/2.7.2
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- bsf/bsf/2.4.0 (available as org.apache.bsf/bsf-api/3.1)
- cglib/cglib-nodep/2.2 (available as cglib/cglib/3.3.0)
- com.beust/jcommander/1.47
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jnr/jffi/1.2.18
- com.github.jnr/jffi/1.2.18/native
- com.github.jnr/jnr-constants/0.9.11
- com.github.jnr/jnr-enxio/0.19
- com.github.jnr/jnr-netdb/1.1.6
- com.github.jnr/jnr-posix/3.0.45
- com.github.jnr/jnr-unixsocket/0.20
- com.github.jponge/lzma-java/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.headius/invokebinder/1.11
- com.headius/modulator/1.0
- com.headius/options/1.4
- com.jcraft/jsch/0.1.50
- com.jcraft/jsch.agentproxy.connector-factory/0.0.6
- com.jcraft/jsch.agentproxy.core/0.0.6
- com.jcraft/jsch.agentproxy.jsch/0.0.6
- com.jcraft/jsch.agentproxy.pageant/0.0.6
- com.jcraft/jsch.agentproxy.sshagent/0.0.6
- com.jcraft/jsch.agentproxy.usocket-jna/0.0.6
- com.jcraft/jsch.agentproxy.usocket-nc/0.0.6
- com.jcraft/jzlib/1.1.3
- com.martiansoftware/nailgun-server/0.9.1
- commons-codec/commons-codec/1.2
- commons-collections/commons-collections/3.1
- commons-httpclient/commons-httpclient/3.0
- commons-logging/commons-logging/1.2
- commons-net/commons-net/1.4.1
- commons-vfs/commons-vfs/1.0
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- com.thoughtworks.qdox/qdox/1.12.1
- com.thoughtworks.xstream/xstream/1.4.7
- dom4j/dom4j/1.6.1
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-auth-common/3.8.0
- io.vertx/vertx-auth-htdigest/3.8.0
- io.vertx/vertx-auth-jwt/3.8.0
- io.vertx/vertx-auth-oauth2/3.8.0
- io.vertx/vertx-bridge-common/3.8.0
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-codetrans/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- io.vertx/vertx-jwt/3.8.0
- io.vertx/vertx-web/3.8.0
- io.vertx/vertx-web-common/3.8.0
- java/11
- javax.servlet/servlet-api/2.5 (available as javax.servlet/javax.servlet-api/4.0.1)
- jaxen/jaxen/1.1-beta-6
- jaxme/jaxme-api/0.3
- jdom/jdom/1.0
- jline/jline/2.12
- joda-time/joda-time/2.9.9
- junit/junit/4.12
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- msv/relaxngDatatype/20030807
- msv/xsdlib/20030807
- net.java.dev.jna/jna/3.4.0
- net.java.dev.jna/platform/3.4.0
- net.jpountz.lz4/lz4/1.3.0
- net.sf.kxml/kxml2/2.3.0
- net.sf.kxml/kxml2-min/2.3.0
- org.apache.ant/ant/1.9.4
- org.apache.ant/ant-antlr/1.9.4
- org.apache.ant/ant-junit/1.9.4
- org.apache.ant/ant-launcher/1.9.4
- org.apache.ant/ant-nodeps/1.7.1
- org.apache.ant/ant-trax/1.7.1
- org.apache.felix/org.osgi.compendium/1.4.0
- org.apache.felix/org.osgi.core/1.4.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.ivy/ivy/2.4.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpg-jdk14/1.45
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk14/1.45
- org.bouncycastle/bcprov-jdk15on/1.54
- org.codehaus.gpars/gpars/1.2.1
- org.codehaus.groovy/groovy-all/2.4.7
- org.codehaus.jcsp/jcsp/1.1-rc5
- org.codehaus.jettison/jettison/1.2
- org.codehaus.jsr166-mirror/jsr166y/1.7.0
- org.codehaus.woodstox/wstx-asl/3.2.7
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.fusesource.jansi/jansi/1.11
- org.hamcrest/hamcrest-core/1.3
- org.hdrhistogram/HdrHistogram/2.1.10
- org.jboss.logging/jboss-logging-spi/2.1.2.GA
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.jboss.netty/netty/3.2.9.Final
- org.jdom/jdom/1.1.3
- org.jdom/jdom2/2.0.5
- org.joda/joda-convert/1.2
- org.jruby/dirgra/0.3
- org.jruby.jcodings/jcodings/1.0.41
- org.jruby.joni/joni/2.1.25
- org.jruby/jruby-core/9.2.4.0
- org.jruby/jruby-stdlib/9.2.4.0
- org.json/json/20080701
- org.multiverse/multiverse-core/0.7.0
- org.mvel/mvel2/2.3.1.Final
- org.scala-lang/scala-library/2.12.0
- org.slf4j/slf4j-api/1.7.21
- org.testng/testng/6.8.13
- org.yaml/snakeyaml/1.12
- oro/oro/2.0.8
- pull-parser/pull-parser/2
- saxpath/saxpath/1.0-FCS
- stax/stax/1.2.0
- stax/stax-api/1.0.1
- xalan/serializer/2.7.1
- xalan/xalan/2.7.1
- xerces/xercesImpl/2.10.0
- xerces/xmlParserAPIs/2.6.2
- xml-apis/xml-apis/1.3.04
- xmlpull/xmlpull/1.1.3.1
- xml-resolver/xml-resolver/1.2
- xom/xom/1.1
- xpp3/xpp3/1.1.3.3
Declarations
- examples
-
io
-
vertx
-
circuitbreaker
-
CircuitBreaker
- reset(): CircuitBreaker
- openHandler(Handler<Void>): CircuitBreaker
- fallback(Function<Throwable, Object>): CircuitBreaker
- create(String, Vertx, CircuitBreakerOptions): CircuitBreaker
- create(String, Vertx): CircuitBreaker
- close(): CircuitBreaker
- halfOpenHandler(Handler<Void>): CircuitBreaker
- closeHandler(Handler<Void>): CircuitBreaker
- executeWithFallback(Handler<Promise<Object>>, Function<Throwable, Object>): Future<Object>
- executeCommandWithFallback(Handler<Promise<Object>>, Function<Throwable, Object>, Handler<AsyncResult<Object>>): void
- execute(Handler<Promise<Object>>): Future<Object>
- executeCommand(Handler<Promise<Object>>, Handler<AsyncResult<Object>>): void
- executeAndReport(Promise<Object>, Handler<Promise<Object>>): CircuitBreaker
- executeAndReport(Future<Object>, Handler<Promise<Object>>): CircuitBreaker
- executeAndReportWithFallback(Promise<Object>, Handler<Promise<Object>>, Function<Throwable, Object>): CircuitBreaker
- executeAndReportWithFallback(Future<Object>, Handler<Promise<Object>>, Function<Throwable, Object>): CircuitBreaker
- open(): CircuitBreaker
- state(): CircuitBreakerState
- failureCount(): long
- name(): String
- retryPolicy(Function<Integer, Long>): CircuitBreaker
-
CircuitBreakerOptions
- timeout: long
- DEFAULT_TIMEOUT: long
- DEFAULT_MAX_FAILURES: int
- DEFAULT_FALLBACK_ON_FAILURE: boolean
- DEFAULT_RESET_TIMEOUT: long
- DEFAULT_NOTIFICATION_ADDRESS: String
- DEFAULT_NOTIFICATION_PERIOD: long
- DEFAULT_METRICS_ROLLING_WINDOW: long
- DEFAULT_METRICS_ROLLING_BUCKETS: int
- DEFAULT_MAX_RETRIES: int
- DEFAULT_FAILURES_ROLLING_WINDOW: int
- maxFailures: int
- fallbackOnFailure: boolean
- resetTimeout: long
- notificationAddress: String
- notificationPeriod: long
- maxRetries: int
- metricsRollingWindow: long
- metricsRollingBuckets: int
- failuresRollingWindow: long
- CircuitBreakerOptions(): void
- CircuitBreakerOptions(CircuitBreakerOptions): void
- CircuitBreakerOptions(JsonObject): void
- toJson(): JsonObject
- getMaxFailures(): int
- setMaxFailures(int): CircuitBreakerOptions
- getTimeout(): long
- setTimeout(long): CircuitBreakerOptions
- isFallbackOnFailure(): boolean
- setFallbackOnFailure(boolean): CircuitBreakerOptions
- getResetTimeout(): long
- setResetTimeout(long): CircuitBreakerOptions
- getNotificationAddress(): String
- setNotificationAddress(String): CircuitBreakerOptions
- getNotificationPeriod(): long
- setNotificationPeriod(long): CircuitBreakerOptions
- getMetricsRollingWindow(): long
- setMetricsRollingWindow(long): CircuitBreakerOptions
- getFailuresRollingWindow(): long
- setFailuresRollingWindow(long): CircuitBreakerOptions
- getMetricsRollingBuckets(): int
- setMetricsRollingBuckets(int): CircuitBreakerOptions
- getMaxRetries(): int
- setMaxRetries(int): CircuitBreakerOptions
- CircuitBreakerOptionsConverter
- CircuitBreakerState
- HystrixMetricHandler
- OpenCircuitException
- TimeoutException
-
impl
-
CircuitBreakerImpl
- NOOP: Handler<Void>
- vertx: Vertx
- options: CircuitBreakerOptions
- name: String
- periodicUpdateTask: long
- openHandler: Handler<Void>
- halfOpenHandler: Handler<Void>
- closeHandler: Handler<Void>
- fallback: Function
- state: CircuitBreakerState
- rollingFailures: RollingCounter
- passed: AtomicInteger
- metrics: CircuitBreakerMetrics
- retryPolicy: Function<Integer, Long>
- CircuitBreakerImpl(String, Vertx, CircuitBreakerOptions): void
- close(): CircuitBreaker
- openHandler(Handler<Void>): CircuitBreaker
- halfOpenHandler(Handler<Void>): CircuitBreaker
- closeHandler(Handler<Void>): CircuitBreaker
- fallback(Function<Throwable, Object>): CircuitBreaker
- reset(boolean): CircuitBreaker
- reset(): CircuitBreaker
- sendUpdateOnEventBus(): void
- open(): CircuitBreaker
- failureCount(): long
- state(): CircuitBreakerState
- attemptReset(): CircuitBreaker
- executeAndReportWithFallback(Promise<Object>, Handler<Promise<Object>>, Function<Throwable, Object>): CircuitBreaker
- retryFuture(Context, int, Handler<Promise<Object>>, Promise<Object>, Operation): Promise<Object>
- executeRetryWithTimeout(int, Handler<Void>): void
- invokeFallback(Throwable, Promise<Object>, Function<Throwable, Object>, Operation): void
- executeOperation(Context, Handler<Promise<Object>>, Promise<Object>, Operation): void
- executeWithFallback(Handler<Promise<Object>>, Function<Throwable, Object>): Future<Object>
- execute(Handler<Promise<Object>>): Future<Object>
- executeAndReport(Promise<Object>, Handler<Promise<Object>>): CircuitBreaker
- name(): String
- incrementFailures(): void
- getMetrics(): CircuitBreakerMetrics
- options(): CircuitBreakerOptions
- retryPolicy(Function<Integer, Long>): CircuitBreaker
- RollingCounter
-
CircuitBreakerMetrics
- RollingWindow
- circuitBreaker: CircuitBreakerImpl
- node: String
- circuitBreakerResetTimeout: long
- circuitBreakerTimeout: long
- rollingWindow: RollingWindow
- CircuitBreakerMetrics(Vertx, CircuitBreakerImpl, CircuitBreakerOptions): void
- evictOutdatedOperations(): void
- close(): void
-
Operation
- Operation(): void
- complete(): void
- begin: long
- end: long
- complete: boolean
- failed: boolean
- timeout: boolean
- exception: boolean
- fallbackFailed: boolean
- fallbackSucceed: boolean
- shortCircuited: boolean
- failed(): void
- timeout(): void
- error(): void
- fallbackFailed(): void
- fallbackSucceed(): void
- shortCircuited(): void
- durationInMs(): long
- enqueue(): Operation
- complete(Operation): void
- toJson(): JsonObject
- addSummary(JsonObject, Summary, String): void
- addLatency(JsonObject, Histogram, String): void
- HystrixMetricEventStream
-
CircuitBreakerImpl
-
CircuitBreaker
-
circuitbreaker
-
vertx