CircuitBreaker

sealed trait ServiceEvent extends AnyRef

An event that controls CircuitBreaker state.
case class ServiceFailed(logId: String, retry: Int, cause: Throwable) extends ServiceEvent with Product with Serializable

Sent by an event log to indicate that it failed to write an event batch.
Sent by an event log to indicate that it failed to write an event batch. The current retry count is given by the retry parameter.
This is also published on the event-stream when it opens the CircuitBreaker, i.e. when retry exceeds a configured limit.
case class ServiceInitialized(logId: String) extends ServiceEvent with Product with Serializable

Sent by an event log to indicate that it has been successfully initialized.
case class ServiceNormal(logId: String) extends ServiceEvent with Product with Serializable

Sent by an event log to indicate that it has successfully written an event batch.
Sent by an event log to indicate that it has successfully written an event batch.
This is also published on the event-stream when it closes the CircuitBreaker (after previous failures that opened the CircuitBreaker).

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
val Exception: EventLogUnavailableException

Default EventLogUnavailableException instance.
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )