net.lag.kestrel.config

QueueBuilder

class QueueBuilder extends Config[QueueConfig]

Linear Supertypes
Config[QueueConfig], () ⇒ QueueConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. QueueBuilder
  2. Config
  3. Function0
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new QueueBuilder ()

Value Members

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

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

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

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def apply (): QueueConfig

    Definition Classes
    QueueBuilder → Function0
  7. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  8. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  9. def computed [A] (f: ⇒ A): Required[A]

    Definition Classes
    Config
  10. var defaultJournalSize : StorageUnit

    If the queue is empty, truncate the journal when it reaches this size.

  11. var discardOldWhenFull : Boolean

    If this is false, when a queue is full, clients attempting to add another item will get an error.

    If this is false, when a queue is full, clients attempting to add another item will get an error. No new items will be accepted. If this is true, old items will be discarded to make room for the new one. This settting has no effect unless at least one of maxItems or maxSize is set.

  12. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  13. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  14. var expireToQueue : Option[String]

    Name of a queue to add expired items to.

    Name of a queue to add expired items to. If set, expired items are added to the requested queue as if by a SET command. This can be used to implement special processing for expired items, or to implement a simple "delayed processing" queue.

  15. var fanoutOnly : Boolean

    If true, don't actually store any items in this queue.

    If true, don't actually store any items in this queue. Only deliver them to fanout client queues.

  16. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  17. implicit def fromOption [A] (item: Option[A]): A

    Attributes
    implicit
    Definition Classes
    Config
  18. implicit def fromRequired [A] (req: Required[A]): A

    Attributes
    implicit
    Definition Classes
    Config
  19. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  20. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  21. implicit def intoList [A] (item: A): List[A]

    Attributes
    implicit
    Definition Classes
    Config
  22. implicit def intoOption [A] (item: A): Option[A]

    Attributes
    implicit
    Definition Classes
    Config
  23. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  24. var keepJournal : Boolean

    If false, don't keep a journal file for this queue.

    If false, don't keep a journal file for this queue. When kestrel exits, any remaining contents in the queue will be lost.

  25. var maxAge : Option[Duration]

    Expiration time for items on this queue.

    Expiration time for items on this queue. Any item that has been sitting on the queue longer than this duration will be discarded. Clients may also attach an expiration time when adding items to a queue, but if the expiration time is longer than maxAge, max_Age will be used instead.

  26. var maxExpireSweep : Int

    Maximum number of expired items to move into the expireToQueue at once.

  27. var maxItemSize : StorageUnit

    Set a hard limit on the number of bytes a single queued item can contain.

    Set a hard limit on the number of bytes a single queued item can contain. An add request for an item larger than this will be rejected.

  28. var maxItems : Int

    Set a hard limit on the number of items this queue can hold.

    Set a hard limit on the number of items this queue can hold. When the queue is full, discardOldWhenFull dictates the behavior when a client attempts to add another item.

  29. var maxJournalSize : StorageUnit

    If the queue fits entirely in memory (see maxMemorySize) and the journal files get larger than this, rebuild the journal.

  30. var maxMemorySize : StorageUnit

    Keep only this much of the queue in memory.

    Keep only this much of the queue in memory. The journal will be used to store backlogged items, and they'll be read back into memory as the queue is drained. This setting is a release valve to keep a backed-up queue from consuming all memory.

  31. var maxQueueAge : Option[Duration]

    Expiration time for the queue itself.

    Expiration time for the queue itself. If the queue is empty and older than this value then we should delete it.

  32. var maxSize : StorageUnit

    Set a hard limit on the number of bytes (of data in queued items) this queue can hold.

    Set a hard limit on the number of bytes (of data in queued items) this queue can hold. When the queue is full, discardOldWhenFull dictates the behavior when a client attempts to add another item.

  33. lazy val memoized : QueueConfig

    Definition Classes
    Config
  34. def missingValues : Seq[String]

    Definition Classes
    Config
  35. var name : String

    Name of the queue being configured.

  36. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  37. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  38. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  39. def optional [A] : Option[A]

    Definition Classes
    Config
  40. def required [A] (default: ⇒ A): Required[A]

    Definition Classes
    Config
  41. def required [A] : Required[A]

    Definition Classes
    Config
  42. def specified [A] (value: A): Specified[A]

    Definition Classes
    Config
  43. var syncJournal : Duration

    How often to sync the journal file.

    How often to sync the journal file. To sync after every write, set this to 0.milliseconds. To never sync, set it to Duration.MaxValue. Syncing the journal will reduce the maximum throughput of the server in exchange for a lower chance of losing data.

  44. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  45. implicit def toSpecified [A] (value: ⇒ A): Specified[A]

    Attributes
    implicit
    Definition Classes
    Config
  46. implicit def toSpecifiedOption [A] (value: ⇒ A): Specified[Some[A]]

    Attributes
    implicit
    Definition Classes
    Config
  47. def toString (): String

    Definition Classes
    Function0 → AnyRef → Any
  48. def validate (): Unit

    Definition Classes
    Config
  49. def wait (): Unit

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from Config[QueueConfig]

Inherited from () ⇒ QueueConfig

Inherited from AnyRef

Inherited from Any