Class ReliabilityPolicyEvaluator

java.lang.Object
org.j7m.middleware.reliability.ReliabilityPolicyEvaluator
public final class ReliabilityPolicyEvaluator extends Object
Evaluates transport-neutral reliability policy for one invocation.

The evaluator is stateless and thread-safe. It does not perform durable storage, messaging, coordination, or consensus.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReliabilityPolicyEvaluator()
    Creates an evaluator with the default retry-safety resolver.
    ReliabilityPolicyEvaluator(RetrySafetyResolver retrySafetyResolver)
    Creates an evaluator.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.j7m.middleware.api.reliability.ReliabilityDecision
    backpressureRejected(org.j7m.middleware.api.reliability.BackpressurePolicy policy)
    Returns the decision for a backpressure rejection.
    org.j7m.middleware.api.reliability.ReliabilityDecision
    evaluateBeforeDispatch(Method method, org.j7m.middleware.api.reliability.InvocationReliabilityOptions options, long payloadBytes)
    Evaluates reliability policy before invocation dispatch.
    org.j7m.middleware.api.reliability.ReliabilityDecision
    evaluateResult(org.j7m.middleware.api.reliability.InvocationReliabilityOptions options, long resultBytes)
    Evaluates result-size limits after method execution.

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ReliabilityPolicyEvaluator

      public ReliabilityPolicyEvaluator()
      Creates an evaluator with the default retry-safety resolver.

    • ReliabilityPolicyEvaluator

      public ReliabilityPolicyEvaluator(RetrySafetyResolver retrySafetyResolver)
      Creates an evaluator.
      Parameters:
      retrySafetyResolver - retry-safety resolver

  • Method Details

    • evaluateBeforeDispatch

      public org.j7m.middleware.api.reliability.ReliabilityDecision evaluateBeforeDispatch(Method method, org.j7m.middleware.api.reliability.InvocationReliabilityOptions options, long payloadBytes)
      Evaluates reliability policy before invocation dispatch.
      Parameters:
      method - Java method
      options - reliability options
      payloadBytes - estimated payload bytes
      Returns:
      decision

    • evaluateResult

      public org.j7m.middleware.api.reliability.ReliabilityDecision evaluateResult(org.j7m.middleware.api.reliability.InvocationReliabilityOptions options, long resultBytes)
      Evaluates result-size limits after method execution.
      Parameters:
      options - reliability options
      resultBytes - estimated result bytes
      Returns:
      decision

    • backpressureRejected

      public org.j7m.middleware.api.reliability.ReliabilityDecision backpressureRejected(org.j7m.middleware.api.reliability.BackpressurePolicy policy)
      Returns the decision for a backpressure rejection.
      Parameters:
      policy - backpressure policy
      Returns:
      decision