Skip to content

Instantly share code, notes, and snippets.

@ksauzz

ksauzz/gizzard_memo.rst

Created March 5, 2012 13:06
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save ksauzz/1978239 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save ksauzz/1978239 to your computer and use it in GitHub Desktop.
Download ZIP
Gizzard memo
Raw
gizzard_memo.rst

gizzard memo

flush command remove all error jobs with no operation.

def flush(): Unit = {
  while (remove(false).isDefined) { }
}

// remove(Boolean) is dequeue command.

JobConsumer code

com.twitter.gizzard.scheduler.JobScheduler

  • queue - normal job queue
  • errorQueue - job
  • badQueue - job exceeded errorLimit
  • jitterRate - リトライインターバルへ与えるゆらぎ（０だとstrobeIntervalの間隔でリトライ）
  • errorRetryDelay - errorQueueでの最低残留時間

kestrelのexpireを利用してJobをedgesへコピーしている https://github.com/twitter/gizzard/commit/8bbdd24bcfed6b253fbe2154eb7b07aa26f0ae63

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment