FetchRequestPurgatory

Value Members

1. final def !=(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

2. final def !=(arg0: Any): Boolean

   Definition Classes

   Any

3. final def ##(): Int

   Definition Classes

   AnyRef → Any

4. final def ==(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

5. final def ==(arg0: Any): Boolean

   Definition Classes

   Any

6. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. def checkAndMaybeWatch(delayedRequest: DelayedFetch): Boolean

   Try to add the request for watch on all keys.

   Try to add the request for watch on all keys. Return true iff the request is satisfied and the satisfaction is done by the caller.

   Definition Classes

   RequestPurgatory

8. def checkSatisfied(delayedFetch: DelayedFetch): Boolean

   Check if a specified delayed fetch request is satisfied

   Check if a specified delayed fetch request is satisfied

   Definition Classes

   FetchRequestPurgatory → RequestPurgatory

9. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

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

    Definition Classes

    Logging

11. def debug(e: ⇒ Throwable): Any

    Definition Classes

    Logging

12. def debug(msg: ⇒ String): Unit

    Definition Classes

    Logging

13. def delayed(): Int

    Definition Classes

    RequestPurgatory

14. final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

15. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    Logging

17. def error(e: ⇒ Throwable): Any

    Definition Classes

    Logging

18. def error(msg: ⇒ String): Unit

    Definition Classes

    Logging

19. def expire(delayedFetch: DelayedFetch): Unit

    When a delayed fetch request expires just answer it with whatever data is present

    When a delayed fetch request expires just answer it with whatever data is present

    Definition Classes

    FetchRequestPurgatory → RequestPurgatory

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

    Definition Classes

    Logging

21. def fatal(e: ⇒ Throwable): Any

    Definition Classes

    Logging

22. def fatal(msg: ⇒ String): Unit

    Definition Classes

    Logging

23. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

24. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

25. def hashCode(): Int

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    Logging

27. def info(e: ⇒ Throwable): Any

    Definition Classes

    Logging

28. def info(msg: ⇒ String): Unit

    Definition Classes

    Logging

29. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

30. var logIdent: String

    Attributes

    protected

    Definition Classes

    Logging

31. lazy val logger: Logger

    Definition Classes

    Logging

32. val loggerName: String

    Definition Classes

    Logging

33. final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

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

    Definition Classes

    KafkaMetricsGroup

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

    Definition Classes

    KafkaMetricsGroup

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

    Definition Classes

    KafkaMetricsGroup

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

    Definition Classes

    KafkaMetricsGroup

38. final def notify(): Unit

    Definition Classes

    AnyRef

39. final def notifyAll(): Unit

    Definition Classes

    AnyRef

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

    Definition Classes

    KafkaMetricsGroup

41. def respond(delayedFetch: DelayedFetch): Unit

42. def shutdown(): Unit

    Shutdown the expire reaper thread

    Shutdown the expire reaper thread

    Definition Classes

    RequestPurgatory

43. def swallow(action: ⇒ Unit): Unit

    Definition Classes

    Logging

44. def swallowDebug(action: ⇒ Unit): Unit

    Definition Classes

    Logging

45. def swallowError(action: ⇒ Unit): Unit

    Definition Classes

    Logging

46. def swallowInfo(action: ⇒ Unit): Unit

    Definition Classes

    Logging

47. def swallowTrace(action: ⇒ Unit): Unit

    Definition Classes

    Logging

48. def swallowWarn(action: ⇒ Unit): Unit

    Definition Classes

    Logging

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

    Definition Classes

    AnyRef

50. def toString(): String

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    Logging

52. def trace(e: ⇒ Throwable): Any

    Definition Classes

    Logging

53. def trace(msg: ⇒ String): Unit

    Definition Classes

    Logging

54. def update(key: Any): Seq[DelayedFetch]

    Update any watchers and return a list of newly satisfied requests.

    Update any watchers and return a list of newly satisfied requests.

    Definition Classes

    RequestPurgatory

55. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

57. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    Logging

59. def warn(e: ⇒ Throwable): Any

    Definition Classes

    Logging

60. def warn(msg: ⇒ String): Unit

    Definition Classes

    Logging

61. def watched(): Int

    Definition Classes

    RequestPurgatory