utils

class DelayedItem[T] extends Delayed

class IteratorTemplate[T] extends Iterator[T] with Iterator[T]

Transliteration of the iterator template in google collections.

class KafkaScheduler extends AnyRef

A scheduler for running jobs in the background TODO: ScheduledThreadPoolExecutor notriously swallows exceptions

class MockTime extends Time

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

trait Range extends AnyRef

A generic range value with a start and end

class SnapshotStats extends AnyRef

class State extends AnyRef

class Throttler extends AnyRef

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

trait Time extends AnyRef

A mockable interface for time functions

class ZKConfig extends AnyRef

class ZKGroupDirs extends AnyRef

class ZKGroupTopicDirs extends ZKGroupDirs

class immutable extends Annotation with StaticAnnotation

Indicates that the annotated class is immutable

class nonthreadsafe extends Annotation with StaticAnnotation

Indicates that the annotated class is not threadsafe

class threadsafe extends Annotation with StaticAnnotation

Indicates that the annotated class is meant to be threadsafe.

object DONE extends State

object FAILED extends State

object Mx4jLoader extends AnyRef

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

object NOT_READY extends State

object READY extends State

object SystemTime extends Time

The normal system implementation of time functions

object Throttler extends AnyRef

object Time extends AnyRef

Some common constants

object UpdateOffsetsInZK extends AnyRef

A utility that updates the offset of every broker partition to the offset of latest log segment file, in ZK.

object Utils extends AnyRef

Helper functions!

object ZKStringSerializer extends ZkSerializer

object ZkUtils extends AnyRef