kafka

utils

package utils

Visibility
  1. Public
  2. All

Type Members

  1. class ByteBoundedBlockingQueue[E] extends Iterable[E]

    A blocking queue that have size limits on both number of elements and number of bytes.

  2. class DelayedItem extends Delayed with Logging

  3. class DoublyLinkedList[T] extends AnyRef

    A simple doubly linked list util to allow O(1) remove.

  4. class DoublyLinkedListNode[T] extends AnyRef

    Simple doubly LinkedList node

  5. class FileLock extends Logging

    A file lock a la flock/funlock

  6. abstract class IteratorTemplate[T] extends Iterator[T] with Iterator[T]

    Transliteration of the iterator template in google collections.

  7. class KafkaScheduler extends Scheduler with Logging

    A scheduler based on java.

  8. trait Logging extends AnyRef

  9. final class NetworkClientBlockingOps extends AnyVal

    Provides extension methods for NetworkClient that are useful for implementing blocking behaviour.

  10. class Pool[K, V] extends Iterable[(K, V)]

  11. trait Scheduler extends AnyRef

    A scheduler for running jobs

  12. abstract class ShutdownableThread extends Thread with Logging

  13. class State extends AnyRef

  14. class Throttler extends Logging with KafkaMetricsGroup

    A class to measure and throttle the rate of some process.

  15. trait Time extends AnyRef

    A mockable interface for time functions

  16. class VerifiableProperties extends Logging

  17. class ZKCheckedEphemeral extends Logging

    Creates an ephemeral znode checking the session owner in the case of conflict.

  18. class ZKConfig extends AnyRef

  19. class ZKGroupDirs extends AnyRef

  20. class ZKGroupTopicDirs extends ZKGroupDirs

  21. class ZkUtils extends Logging

  22. class immutable extends Annotation with StaticAnnotation

    Indicates that the annotated class is immutable

  23. class nonthreadsafe extends Annotation with StaticAnnotation

    Indicates that the annotated class is not threadsafe

  24. class threadsafe extends Annotation with StaticAnnotation

    Indicates that the annotated class is meant to be threadsafe.

Value Members

  1. object CommandLineUtils extends Logging

    Helper functions for dealing with command line utilities

  2. object CoreUtils extends Logging

    General helper functions!

  3. object DONE extends State

  4. object FAILED extends State

  5. object Json extends Logging

    A wrapper that synchronizes JSON in scala, which is not threadsafe.

  6. object Log4jController

  7. object Mx4jLoader extends Logging

    If mx4j-tools is in the classpath call maybeLoad to load the HTTP interface of mx4j.

  8. object NOT_READY extends State

  9. object NetworkClientBlockingOps

  10. object Os

  11. object READY extends State

  12. object ReplicationUtils extends Logging

  13. object SystemTime extends Time

    The normal system implementation of time functions

  14. object Throttler

  15. object Time

    Some common constants

  16. object ToolsUtils

  17. object ZkPath

  18. object ZkUtils

  19. package timer

Ungrouped