DelayedOperationPurgatory

Instance Constructors

new DelayedOperationPurgatory(purgatoryName: String, brokerId: Int = 0, purgeInterval: Int = 1000)

Value Members

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
final def asInstanceOf[T0]: T0

Definition Classes
Any
def checkAndComplete(key: Any): Int

Check if some some delayed operations can be completed with the given watch key, and if yes complete them.
Check if some some delayed operations can be completed with the given watch key, and if yes complete them.
returns
the number of completed operations during this process
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def debug(e: ⇒ Throwable): Any

Definition Classes
Logging
def debug(msg: ⇒ String): Unit

Definition Classes
Logging
def delayed(): Int

Return the number of delayed operations in the expiry queue
final def eq(arg0: AnyRef): Boolean

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

Definition Classes
AnyRef → Any
def error(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def error(e: ⇒ Throwable): Any

Definition Classes
Logging
def error(msg: ⇒ String): Unit

Definition Classes
Logging
def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def fatal(e: ⇒ Throwable): Any

Definition Classes
Logging
def fatal(msg: ⇒ String): Unit

Definition Classes
Logging
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
def info(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def info(e: ⇒ Throwable): Any

Definition Classes
Logging
def info(msg: ⇒ String): Unit

Definition Classes
Logging
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var logIdent: String

Attributes
protected
Definition Classes
Logging
lazy val logger: Logger

Definition Classes
Logging
val loggerName: String

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

Definition Classes
AnyRef
def newGauge[T](name: String, metric: Gauge[T], tags: Map[String, String] = Map.empty): Gauge[T]

Definition Classes
KafkaMetricsGroup
def newHistogram(name: String, biased: Boolean = true, tags: Map[String, String] = Map.empty): Histogram

Definition Classes
KafkaMetricsGroup
def newMeter(name: String, eventType: String, timeUnit: TimeUnit, tags: Map[String, String] = Map.empty): Meter

Definition Classes
KafkaMetricsGroup
def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit, tags: Map[String, String] = Map.empty): Timer

Definition Classes
KafkaMetricsGroup
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def removeMetric(name: String, tags: Map[String, String] = Map.empty): Unit

Definition Classes
KafkaMetricsGroup
def shutdown(): Unit

Shutdown the expire reaper thread
def swallow(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowDebug(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowError(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowInfo(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowTrace(action: ⇒ Unit): Unit

Definition Classes
Logging
def swallowWarn(action: ⇒ Unit): Unit

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

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def trace(e: ⇒ Throwable): Any

Definition Classes
Logging
def trace(msg: ⇒ String): Unit

Definition Classes
Logging
def tryCompleteElseWatch(operation: T, watchKeys: Seq[Any]): Boolean

Check if the operation can be completed, if not watch it based on the given watch keys
Check if the operation can be completed, if not watch it based on the given watch keys
Note that a delayed operation can be watched on multiple keys. It is possible that an operation is completed after it has been added to the watch list for some, but not all of the keys. In this case, the operation is considered completed and won't be added to the watch list of the remaining keys. The expiration reaper thread will remove this operation from any watcher list in which the operation exists.
operation
the delayed operation to be checked
watchKeys
keys for bookkeeping the operation
returns
true iff the delayed operations can be completed by the caller
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( ... )
def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

Definition Classes
Logging
def warn(e: ⇒ Throwable): Any

Definition Classes
Logging
def warn(msg: ⇒ String): Unit

Definition Classes
Logging
def watched(): Int

Return the total size of watch lists the purgatory.
Return the total size of watch lists the purgatory. Since an operation may be watched on multiple lists, and some of its watched entries may still be in the watch lists even when it has been completed, this number may be larger than the number of real operations watched

Related Doc: package server

class DelayedOperationPurgatory[T <: DelayedOperation] extends Logging with KafkaMetricsGroup

Instance Constructors

new DelayedOperationPurgatory(purgatoryName: String, brokerId: Int = 0, purgeInterval: Int = 1000)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def checkAndComplete(key: Any): Int

def clone(): AnyRef

def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

def debug(e: ⇒ Throwable): Any

def debug(msg: ⇒ String): Unit

def delayed(): Int

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def error(msg: ⇒ String, e: ⇒ Throwable): Unit

def error(e: ⇒ Throwable): Any

def error(msg: ⇒ String): Unit

def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

def fatal(e: ⇒ Throwable): Any

def fatal(msg: ⇒ String): Unit

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

def info(msg: ⇒ String, e: ⇒ Throwable): Unit

def info(e: ⇒ Throwable): Any

def info(msg: ⇒ String): Unit

final def isInstanceOf[T0]: Boolean

var logIdent: String

lazy val logger: Logger

val loggerName: String

final def ne(arg0: AnyRef): Boolean

def newGauge[T](name: String, metric: Gauge[T], tags: Map[String, String] = Map.empty): Gauge[T]

def newHistogram(name: String, biased: Boolean = true, tags: Map[String, String] = Map.empty): Histogram

def newMeter(name: String, eventType: String, timeUnit: TimeUnit, tags: Map[String, String] = Map.empty): Meter

def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit, tags: Map[String, String] = Map.empty): Timer

final def notify(): Unit

final def notifyAll(): Unit

def removeMetric(name: String, tags: Map[String, String] = Map.empty): Unit

def shutdown(): Unit

def swallow(action: ⇒ Unit): Unit

def swallowDebug(action: ⇒ Unit): Unit

def swallowError(action: ⇒ Unit): Unit

def swallowInfo(action: ⇒ Unit): Unit

def swallowTrace(action: ⇒ Unit): Unit

def swallowWarn(action: ⇒ Unit): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

def trace(e: ⇒ Throwable): Any

def trace(msg: ⇒ String): Unit

def tryCompleteElseWatch(operation: T, watchKeys: Seq[Any]): Boolean

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

def warn(e: ⇒ Throwable): Any

def warn(msg: ⇒ String): Unit

def watched(): Int

Inherited from KafkaMetricsGroup

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped