CircuitBreaker

Object Hierarchy:

Description:

    var created = CircuitBreaker.of ("payments");
    if (created.isError ()) {
        return;
    }
    var breaker = created.unwrap ();

    var configured = breaker.withFailureThreshold (3);
    if (configured.isError ()) {
        return;
    }
    configured = breaker.withOpenTimeout (Duration.ofSeconds (10));
    if (configured.isError ()) {
        return;
    }

    Result<string, string> result = breaker.call<string> (() => {
        string? payload = fetch_from_remote ();
        if (payload == null) {
            return Result.error<string, string> ("remote returned empty payload");
        }
        return Result.ok<string, string> (payload);
    });

Content:

Static methods:

• public static Result<CircuitBreaker,Error> of (string name)
  Creates a circuit breaker.

Methods:

• public Result<T,string> call<T> (owned CircuitFunc<T> fn)
  Executes callback through circuit breaker.
• public int failureCount ()
  Returns recent failure count in CLOSED state.
• public string name ()
  Returns breaker name.
• public CircuitBreaker onStateChange (owned StateChangeCallback fn)
  Registers state change callback.
• public void recordFailure ()
  Records one failure.
• public void recordSuccess ()
  Records one success.
• public void reset ()
  Resets breaker state and counters.
• public CircuitState state ()
  Returns current state.
• public Result<CircuitBreaker,Error> withFailureThreshold (int n)
  Sets consecutive failure threshold.
• public Result<CircuitBreaker,Error> withOpenTimeout (Duration timeout)
  Sets OPEN-state timeout.
• public Result<CircuitBreaker,Error> withSuccessThreshold (int n)
  Sets success threshold needed to close from HALF_OPEN.

Inherited Members: