failurewall-core


License

License

GroupId

GroupId

com.okumin
ArtifactId

ArtifactId

failurewall-core_3
Last Version

Last Version

0.4.0
Release Date

Release Date

Type

Type

jar
Description

Description

failurewall-core
failurewall-core
Project URL

Project URL

https://github.com/failurewall/failurewall
Project Organization

Project Organization

com.okumin
Source Code Management

Source Code Management

https://github.com/failurewall/failurewall

Download failurewall-core_3

How to add to project

<!-- https://jarcasting.com/artifacts/com.okumin/failurewall-core_3/ -->
<dependency>
    <groupId>com.okumin</groupId>
    <artifactId>failurewall-core_3</artifactId>
    <version>0.4.0</version>
</dependency>
// https://jarcasting.com/artifacts/com.okumin/failurewall-core_3/
implementation 'com.okumin:failurewall-core_3:0.4.0'
// https://jarcasting.com/artifacts/com.okumin/failurewall-core_3/
implementation ("com.okumin:failurewall-core_3:0.4.0")
'com.okumin:failurewall-core_3:jar:0.4.0'
<dependency org="com.okumin" name="failurewall-core_3" rev="0.4.0">
  <artifact name="failurewall-core_3" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.okumin', module='failurewall-core_3', version='0.4.0')
)
libraryDependencies += "com.okumin" % "failurewall-core_3" % "0.4.0"
[com.okumin/failurewall-core_3 "0.4.0"]

Dependencies

compile (1)

Group / Artifact Type Version
org.scala-lang : scala3-library_3 jar 3.0.0

test (2)

Group / Artifact Type Version
org.scalatest : scalatest-wordspec_3 jar 3.2.9
org.scalatestplus : scalacheck-1-15_3 jar 3.2.9.0

Project Modules

There are no modules declared in this project.

Failurewall

This is a library to protect applications against failures, and helpful in developing stable, responsive and resilient systems.

Failurewall is inspired by Hystrix and adapted for scala.concurrent.Future.

Getting Started

You should add the following dependency.

libraryDependencies += "com.okumin" %% "failurewall-core" % "0.4.0"

If you are using Akka 2.4, you can use failurewall-akka. failurewall-akka provides the following failurewalls.

  • circuit breaker
  • retry with backoff
  • timeout
libraryDependencies += "com.okumin" %% "failurewall-akka" % "0.4.0"

If you are using Akka 2.3, see also failurewall-akka23.

How to use

As a Proxy

Failurewall is simple to use, wrapping scala.concurrent.Future to be protected. Each failurewall has abilities to handle failures.

object HttpClient {
  def get(url: String): Future[Response] = ???
}

val wall: Failurewall[Response, Response] = ???
val response: Future[Response] = wall.call(HttpClient.get("http://okumin.com/"))

Composability

Failurewalls has their own ability, e.g. retrying, checking rate limits and throttling. Failurewall#compose makes Failurewalls decorate such features.

val wallSina: Failurewall[Int, String] = ???
val wallRose: Failurewall[Int, Int] = ???
val wallMaria: Failurewall[Double, Int] = ???

val walls: [Double, String] = wallSina compose wallRose compose wallMaria

Built-in walls(failurewall-core)

RetryFailurewall

Retries on temporary failures.

val wall = RetryFailurewall[Response](10, executionContext)
wall.call(Future.failed(new RuntimeException)) // retry 10 times

StdSemaphoreFailurewall

Keeps resource usage constant.

val wall = StdSemaphoreFailurewall[Response](10, executionContext)
val results = (1 to 100).map { _ =>
  // fails immediately while other 10 calls are running
  wall.call(doSomeOperation())
}

StopwatchFailurewall

Measures the execution time.

val wall = StopwatchFailurewall[Response](executionContext)
wall.call(doSomeOperation()) // returns Future[(Try[Response], FiniteDuration)]

Built-in walls(failurewall-akka)

AkkaCircuitBreakerFailurewall

Prevents a failure from leading to cascading other failures.

// has a little complicated constructor
val wall: AkkaCircuitBreakerFailurewall[Response] = ???
val results = (1 to 100).map { _ =>
  // fail-fast after failure times exceeds the threshold
  wall.call(Future {
    throw new RuntimeException
  })
}

AkkaRetryFailurewall

Retries with backoff on temporary failures.

val backoffStrategy = ExponentialBackoffStrategy(
  minBackoff = 100.millis,
  maxBackoff = 10.seconds,
  multiplier = 2.0
)
val wall = AkkaRetryFailurewall[Response](
  10,
  backoffStrategy,
  akkaScheduler,
  executionContext
)
// retry 10 times with exponential backoff
wall.call(Future.failed(new RuntimeException))

AkkaTimeoutFailurewall

Times out when it takes some duration.

val wall = AkkaTimeoutFailurewall[String](5.seconds, akkaScheduler, executionContext) {
  logger.error("Timed out.")
}
// fails with FailurewallException
wall.call(Future {
  Thread.sleep(10000)
  "mofu"
})
com.okumin

Failurewall

I'm gonna destroy failures.

Versions

Version
0.4.0