site update: kestrel-2.3.2

api/main/api/index/index-e.html

@@ -24,6 +24,9 @@
     </div><div class="entry">
       <div class="name">ErrorResponse</div>
       <div class="occurrences"><a name="net.lag.kestrel" class="extype" href="../net/lag/kestrel/package.html">kestrel</a> </div>
+    </div><div class="entry">
+      <div class="name">expirationBackgroundProcess</div>
+      <div class="occurrences"><a name="net.lag.kestrel.Kestrel" class="extype" href="../net/lag/kestrel/Kestrel.html">Kestrel</a> </div>
     </div><div class="entry">
       <div class="name">expirationMsec</div>
       <div class="occurrences"><a name="net.lag.kestrel.thrift.Kestrel.put_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$put_args.html">put_args</a> </div>

api/main/api/index/index-t.html

@@ -87,6 +87,9 @@
     </div><div class="entry">
       <div class="name">toString</div>
       <div class="occurrences"><a name="net.lag.kestrel.Checkpoint" class="extype" href="../net/lag/kestrel/Checkpoint.html">Checkpoint</a> <a name="net.lag.kestrel.config.AliasConfig" class="extype" href="../net/lag/kestrel/config/AliasConfig.html">AliasConfig</a> <a name="net.lag.kestrel.config.QueueConfig" class="extype" href="../net/lag/kestrel/config/QueueConfig.html">QueueConfig</a> <a name="net.lag.kestrel.DeadlineWaitQueue.Waiter" class="extype" href="../net/lag/kestrel/DeadlineWaitQueue$Waiter.html">Waiter</a> <a name="net.lag.kestrel.JournalItem.Add" class="extype" href="../net/lag/kestrel/JournalItem$$Add.html">Add</a> <a name="net.lag.kestrel.JournalItem.ConfirmRemove" class="extype" href="../net/lag/kestrel/JournalItem$$ConfirmRemove.html">ConfirmRemove</a> <a name="net.lag.kestrel.JournalItem.Continue" class="extype" href="../net/lag/kestrel/JournalItem$$Continue.html">Continue</a> <a name="net.lag.kestrel.JournalItem.EndOfFile" class="extype" href="../net/lag/kestrel/JournalItem$$EndOfFile$.html">EndOfFile</a> <a name="net.lag.kestrel.JournalItem.Remove" class="extype" href="../net/lag/kestrel/JournalItem$$Remove$.html">Remove</a> <a name="net.lag.kestrel.JournalItem.RemoveTentative" class="extype" href="../net/lag/kestrel/JournalItem$$RemoveTentative.html">RemoveTentative</a> <a name="net.lag.kestrel.JournalItem.SavedXid" class="extype" href="../net/lag/kestrel/JournalItem$$SavedXid.html">SavedXid</a> <a name="net.lag.kestrel.JournalItem.Unremove" class="extype" href="../net/lag/kestrel/JournalItem$$Unremove.html">Unremove</a> <a name="net.lag.kestrel.PackRequest" class="extype" href="../net/lag/kestrel/PackRequest.html">PackRequest</a> <a name="net.lag.kestrel.PeriodicSyncFile.TimestampedPromise" class="extype" href="../net/lag/kestrel/PeriodicSyncFile$TimestampedPromise.html">TimestampedPromise</a> <a name="net.lag.kestrel.QItem" class="extype" href="../net/lag/kestrel/QItem.html">QItem</a> <a name="net.lag.kestrel.QueueTransaction" class="extype" href="../net/lag/kestrel/QueueTransaction.html">QueueTransaction</a> <a name="net.lag.kestrel.TextRequest" class="extype" href="../net/lag/kestrel/TextRequest.html">TextRequest</a> <a name="net.lag.kestrel.thrift.Item" class="extype" href="../net/lag/kestrel/thrift/Item.html">Item</a> <a name="net.lag.kestrel.thrift.Kestrel.abort_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$abort_args.html">abort_args</a> <a name="net.lag.kestrel.thrift.Kestrel.abort_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$abort_result.html">abort_result</a> <a name="net.lag.kestrel.thrift.Kestrel.confirm_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$confirm_args.html">confirm_args</a> <a name="net.lag.kestrel.thrift.Kestrel.confirm_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$confirm_result.html">confirm_result</a> <a name="net.lag.kestrel.thrift.Kestrel.deleteQueue_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$deleteQueue_args.html">deleteQueue_args</a> <a name="net.lag.kestrel.thrift.Kestrel.deleteQueue_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$deleteQueue_result.html">deleteQueue_result</a> <a name="net.lag.kestrel.thrift.Kestrel.flushAllQueues_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$flushAllQueues_args.html">flushAllQueues_args</a> <a name="net.lag.kestrel.thrift.Kestrel.flushAllQueues_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$flushAllQueues_result.html">flushAllQueues_result</a> <a name="net.lag.kestrel.thrift.Kestrel.flushQueue_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$flushQueue_args.html">flushQueue_args</a> <a name="net.lag.kestrel.thrift.Kestrel.flushQueue_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$flushQueue_result.html">flushQueue_result</a> <a name="net.lag.kestrel.thrift.Kestrel.get_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$get_args.html">get_args</a> <a name="net.lag.kestrel.thrift.Kestrel.get_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$get_result.html">get_result</a> <a name="net.lag.kestrel.thrift.Kestrel.getVersion_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$getVersion_args.html">getVersion_args</a> <a name="net.lag.kestrel.thrift.Kestrel.getVersion_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$getVersion_result.html">getVersion_result</a> <a name="net.lag.kestrel.thrift.Kestrel.peek_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$peek_args.html">peek_args</a> <a name="net.lag.kestrel.thrift.Kestrel.peek_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$peek_result.html">peek_result</a> <a name="net.lag.kestrel.thrift.Kestrel.put_args" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$put_args.html">put_args</a> <a name="net.lag.kestrel.thrift.Kestrel.put_result" class="extype" href="../net/lag/kestrel/thrift/Kestrel$$put_result.html">put_result</a> <a name="net.lag.kestrel.thrift.QueueInfo" class="extype" href="../net/lag/kestrel/thrift/QueueInfo.html">QueueInfo</a> </div>
+    </div><div class="entry">
+      <div class="name">totalCanceledTransactions</div>
+      <div class="occurrences"><a name="net.lag.kestrel.PersistentQueue" class="extype" href="../net/lag/kestrel/PersistentQueue.html">PersistentQueue</a> </div>
     </div><div class="entry">
       <div class="name">totalDiscarded</div>
       <div class="occurrences"><a name="net.lag.kestrel.PersistentQueue" class="extype" href="../net/lag/kestrel/PersistentQueue.html">PersistentQueue</a> </div>
@@ -96,6 +99,9 @@
     </div><div class="entry">
       <div class="name">totalFlushes</div>
       <div class="occurrences"><a name="net.lag.kestrel.PersistentQueue" class="extype" href="../net/lag/kestrel/PersistentQueue.html">PersistentQueue</a> </div>
+    </div><div class="entry">
+      <div class="name">totalTransactions</div>
+      <div class="occurrences"><a name="net.lag.kestrel.PersistentQueue" class="extype" href="../net/lag/kestrel/PersistentQueue.html">PersistentQueue</a> </div>
     </div><div class="entry">
       <div class="name">trigger</div>
       <div class="occurrences"><a name="net.lag.kestrel.DeadlineWaitQueue" class="extype" href="../net/lag/kestrel/DeadlineWaitQueue.html">DeadlineWaitQueue</a> </div>

api/main/api/net/lag/kestrel/Kestrel.html

@@ -178,6 +178,17 @@ <h4 class="signature">
       </span>
       </h4>
       <div class="fullcomment"><dl class="attributes block"> <dt>Definition Classes</dt><dd>AnyRef → Any</dd></dl></div>
+    </li><li visbl="pub" name="net.lag.kestrel.Kestrel#expirationBackgroundProcess" data-isabs="false">
+      <a id="expirationBackgroundProcess:Option[PeriodicBackgroundProcess]"></a>
+      <h4 class="signature">
+      <span class="kind">var</span>
+      <span class="symbol"> 
+        <span class="name">expirationBackgroundProcess</span>
+
+        <span class="result">: <span name="scala.Option" class="extype">Option</span>[<span name="com.twitter.ostrich.admin.PeriodicBackgroundProcess" class="extype">PeriodicBackgroundProcess</span>]</span>
+      </span>
+      </h4>
+
     </li><li visbl="prt" name="scala.AnyRef#finalize" data-isabs="false">
       <a id="finalize():Unit"></a>
       <h4 class="signature">

api/main/api/net/lag/kestrel/PersistentQueue.html

@@ -490,7 +490,7 @@ <h4 class="signature">
       </span>
       </h4>
       <p class="shortcomment cmt">Check if this Queue is eligible for expiration by way of it being empty
-and it's age being greater than or equal to maxQueueAge
+and its age being greater than or equal to maxQueueAge
 </p>
     </li><li visbl="pub" name="net.lag.kestrel.PersistentQueue#journalSize" data-isabs="false">
       <a id="journalSize:Long"></a>
@@ -771,6 +771,17 @@ <h4 class="signature">
       </span>
       </h4>
       <div class="fullcomment"><dl class="attributes block"> <dt>Definition Classes</dt><dd>AnyRef → Any</dd></dl></div>
+    </li><li visbl="pub" name="net.lag.kestrel.PersistentQueue#totalCanceledTransactions" data-isabs="false">
+      <a id="totalCanceledTransactions:Counter"></a>
+      <h4 class="signature">
+      <span class="kind">val</span>
+      <span class="symbol"> 
+        <span class="name">totalCanceledTransactions</span>
+
+        <span class="result">: <span name="com.twitter.ostrich.stats.Counter" class="extype">Counter</span></span>
+      </span>
+      </h4>
+
     </li><li visbl="pub" name="net.lag.kestrel.PersistentQueue#totalDiscarded" data-isabs="false">
       <a id="totalDiscarded:Counter"></a>
       <h4 class="signature">
@@ -804,6 +815,17 @@ <h4 class="signature">
       </span>
       </h4>
 
+    </li><li visbl="pub" name="net.lag.kestrel.PersistentQueue#totalTransactions" data-isabs="false">
+      <a id="totalTransactions:Counter"></a>
+      <h4 class="signature">
+      <span class="kind">val</span>
+      <span class="symbol"> 
+        <span class="name">totalTransactions</span>
+
+        <span class="result">: <span name="com.twitter.ostrich.stats.Counter" class="extype">Counter</span></span>
+      </span>
+      </h4>
+
     </li><li visbl="pub" name="net.lag.kestrel.PersistentQueue#unremove" data-isabs="false">
       <a id="unremove(Int):Unit"></a>
       <h4 class="signature">

docs/guide.html

@@ -253,6 +253,12 @@ <h2>Fanout Queues</h2>
 Existing items are not copied over. A fanout queue can be deleted to stop it
 from receiving new items.</p>
 
+<p><code>fanoutOnly</code> may be set to true if the queue in question will only serve write
+point for fanout queues.  No journal file will be kept for the parent, only
+for the child queues.  This saves the overhead of writing to the parent and
+removes the need to empty it.  Note that setting `fanoutOnly` to true and
+having no fanouts for the queue effectively makes it a black hole.</p>
+
 <h2>Queue Aliases</h2>
 
 <p>Queue aliases are somewhat similar to fanout queues, but without a required
@@ -476,6 +482,8 @@ <h2>Server stats</h2>
 <li><code>waiters</code> - number of clients waiting for an item from this queue (using
 <code>GET/t</code>)</li>
 <li><code>open_transactions</code> - items read with <code>/open</code> but not yet confirmed</li>
+<li><code>transactions<code> - number of transactional get requests (irrespective of whether an item was read or not)</li>
+<li><code>canceled_transactions</code> - number of transactional get requests canceled (for any reason)</li>
 <li><code>total_flushes</code> - total number of times this queue has been flushed</li>
 <li><code>age_msec</code> - age of the last item read from the queue/li>
 <li><code>create_time</code> - the time that the queue was created (in milliseconds since epoch)/li>

docs/guide.md

@@ -182,6 +182,11 @@ is created, and it will start receiving new items written to the parent queue.
 Existing items are not copied over. A fanout queue can be deleted to stop it
 from receiving new items.
 
+`fanoutOnly` may be set to true if the queue in question will only serve write
+point for fanout queues.  No journal file will be kept for the parent, only
+for the child queues.  This saves the overhead of writing to the parent and
+removes the need to empty it.  Note that setting `fanoutOnly` to true and
+having no fanouts for the queue effectively makes it a black hole.
 
 Queue Aliases
 -------------
@@ -416,6 +421,10 @@ For each queue, the following stats are also reported:
 - `waiters` - number of clients waiting for an item from this queue (using
   `GET/t`)
 - `open_transactions` - items read with `/open` but not yet confirmed
+- `transactions` - number of transactional get requests (irrespective of whether an
+  item was read or not)
+- `canceled_transactions` - number of transactional get requests canceled (for any
+  reason)
 - `total_flushes` - total number of times this queue has been flushed
 - `age_msec` - age of the last item read from the queue
 - `create_time` - the time that the queue was created (in milliseconds since epoch)

index.html

@@ -103,6 +103,7 @@ <h2>Features</h2>
 <h2>News</h2>
 
 <ul>
+<li><p><strong>23 Aug 2012</strong> - <em>kestrel 2.3.2 released</em></p></li>
 <li><p><strong>16 Jul 2012</strong> - <em>kestrel 2.3.1 released</em></p></li>
 <li><p><strong>11 May 2012</strong> - <em>kestrel 2.2.0 released</em></p></li>
 <li><p><strong>12 Jan 2012</strong> - <em>kestrel 2.1.5 released</em></p></li>
@@ -125,6 +126,7 @@ <h2>Further Reading</h2>
 <h2>Downloads</h2>
 
 <ul>
+<li><p><a href="download/kestrel-2.3.2.zip">kestrel 2.3.2</a></p></li>
 <li><p><a href="download/kestrel-2.3.1.zip">kestrel 2.3.1</a></p></li>
 <li><p><a href="download/kestrel-2.2.0.zip">kestrel 2.2.0</a></p></li>
 <li><p><a href="download/kestrel-2.1.5.zip">kestrel 2.1.5</a></p></li>

index.md

@@ -25,6 +25,8 @@ For more information, check out the [readme](readme.html).
 News
 ----
 
+- **23 Aug 2012** - *kestrel 2.3.2 released*
+
 - **16 Jul 2012** - *kestrel 2.3.1 released*
 
 - **11 May 2012** - *kestrel 2.2.0 released*
@@ -55,6 +57,8 @@ Further Reading
 Downloads
 ---------
 
+- [kestrel 2.3.2](download/kestrel-2.3.2.zip)
+
 - [kestrel 2.3.1](download/kestrel-2.3.1.zip)
 
 - [kestrel 2.2.0](download/kestrel-2.2.0.zip)