final class Open extends State
State of the CircuitBreaker in which the circuit breaker rejects all tasks with an ExecutionRejectedException.
Contract:
- all tasks fail fast with
ExecutionRejectedException - after the configured
resetTimeout, the circuit breaker enters a HalfOpen state, allowing one task to go through for testing the connection
- Source
- CircuitBreaker.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- Open
- State
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- def equals(other: Any): Boolean
- Definition Classes
- Open → AnyRef → Any
- val expiresAt: Timestamp
The timestamp in milliseconds since the epoch, specifying when the
Openstate is to transition to HalfOpen.The timestamp in milliseconds since the epoch, specifying when the
Openstate is to transition to HalfOpen.It is calculated as:
startedAt + resetTimeout.toMillis - def hashCode(): Int
- Definition Classes
- Open → AnyRef → Any
- val resetTimeout: FiniteDuration
- val startedAt: Timestamp
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
Atomictypes, as alternative tojava.util.concurrent.atomicmonix.catnap exposes pure abstractions built on top of the Cats-Effect type classes:
monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observablepattern:Observableimplementationsmonix.tail exposes Iterant for purely functional pull based streaming:
BatchandBatchCursor, the alternatives to Scala'sIterableandIteratorrespectively that we are using within Iterant's encodingYou can control evaluation with type you choose - be it Task, Coeval, cats.effect.IO or your own as long as you provide correct cats-effect or cats typeclass instance.