\n \n \n \n \n\n
\n \n \n \n
MERB_ROOT<\/span>=<\/span>'/home/deploy/repos/twitter/current'<\/span><\/div> <\/div>def<\/span> generic_monitoring<\/span>(<\/span>w<\/span>,<\/span> options<\/span> =<\/span> {})<\/span><\/div>  w<\/span>.<\/span>start_if<\/span> do<\/span> |<\/span>start<\/span>|<\/span><\/div>    start<\/span>.<\/span>condition<\/span>(<\/span>:process_running<\/span>)<\/span> do<\/span> |<\/span>c<\/span>|<\/span><\/div>      c<\/span>.<\/span>interval<\/span> =<\/span> 10<\/span>.<\/span>seconds<\/span><\/div>      c<\/span>.<\/span>running<\/span> =<\/span> false<\/span><\/div>    end<\/span><\/div>  end<\/span><\/div>  <\/div>  w<\/span>.<\/span>restart_if<\/span> do<\/span> |<\/span>restart<\/span>|<\/span><\/div>    restart<\/span>.<\/span>condition<\/span>(<\/span>:memory_usage<\/span>)<\/span> do<\/span> |<\/span>c<\/span>|<\/span><\/div>      c<\/span>.<\/span>above<\/span> =<\/span> options<\/span>[<\/span>:memory_limit<\/span>]<\/span><\/div>      c<\/span>.<\/span>times<\/span> =<\/span> [<\/span>3<\/span>,<\/span> 5<\/span>]<\/span> # 3 out of 5 intervals<\/span><\/div>    end<\/span><\/div>  <\/div>    restart<\/span>.<\/span>condition<\/span>(<\/span>:cpu_usage<\/span>)<\/span> do<\/span> |<\/span>c<\/span>|<\/span><\/div>      c<\/span>.<\/span>above<\/span> =<\/span> options<\/span>[<\/span>:cpu_limit<\/span>]<\/span><\/div>      c<\/span>.<\/span>times<\/span> =<\/span> 5<\/span><\/div>    end<\/span><\/div>  end<\/span><\/div>  <\/div>  w<\/span>.<\/span>lifecycle<\/span> do<\/span> |<\/span>on<\/span>|<\/span><\/div>    on<\/span>.<\/span>condition<\/span>(<\/span>:flapping<\/span>)<\/span> do<\/span> |<\/span>c<\/span>|<\/span><\/div>      c<\/span>.<\/span>to_state<\/span> =<\/span> [<\/span>:start<\/span>,<\/span> :restart<\/span>]<\/span><\/div>      c<\/span>.<\/span>times<\/span> =<\/span> 5<\/span><\/div>      c<\/span>.<\/span>within<\/span> =<\/span> 5<\/span>.<\/span>minute<\/span><\/div>      c<\/span>.<\/span>transition<\/span> =<\/span> :unmonitored<\/span><\/div>      c<\/span>.<\/span>retry_in<\/span> =<\/span> 10<\/span>.<\/span>minutes<\/span><\/div>      c<\/span>.<\/span>retry_times<\/span> =<\/span> 5<\/span><\/div>      c<\/span>.<\/span>retry_within<\/span> =<\/span> 2<\/span>.<\/span>hours<\/span><\/div>    end<\/span><\/div>  end<\/span><\/div>end<\/span><\/div> <\/div>God<\/span>.<\/span>watch<\/span> do<\/span> |<\/span>w<\/span>|<\/span><\/div>  w<\/span>.<\/span>name<\/span> =<\/span> "consumer"<\/span><\/div>  w<\/span>.<\/span>interval<\/span> =<\/span> 60<\/span>.<\/span>seconds<\/span><\/div>  w<\/span>.<\/span>group<\/span> =<\/span> "twitter"<\/span><\/div>  w<\/span>.<\/span>start<\/span> =<\/span>  "/bin/bash -c 'cd <\/span>#{<\/span>MERB_ROOT<\/span>}<\/span>; ruby lib/daemons/starling_daemon_ctl.rb start'"<\/span><\/div> <\/div>  w<\/span>.<\/span>restart<\/span> =<\/span> "/bin/bash -c 'cd <\/span>#{<\/span>MERB_ROOT<\/span>}<\/span>; ruby  lib/daemons/starling_daemon_ctl.rb restart'"<\/span><\/div>  w<\/span>.<\/span>stop<\/span> =<\/span> "/bin/bash -c 'cd <\/span>#{<\/span>MERB_ROOT<\/span>}<\/span>; ruby  lib/daemons/starling_daemon_ctl.rb stop'"<\/span><\/div>  <\/div>  w<\/span>.<\/span>start_grace<\/span> =<\/span> 60<\/span>.<\/span>seconds<\/span><\/div>  w<\/span>.<\/span>restart_grace<\/span> =<\/span> 60<\/span>.<\/span>seconds<\/span><\/div>  w<\/span>.<\/span>pid_file<\/span> =<\/span> "<\/span>#{<\/span>MERB_ROOT<\/span>}<\/span>/log/consumer.pid"<\/span><\/div>  <\/div>  w<\/span>.<\/span>behavior<\/span>(<\/span>:clean_pid_file<\/span>)<\/span><\/div>  generic_monitoring<\/span>(<\/span>w<\/span>,<\/span> :cpu_limit<\/span> =><\/span> 70<\/span>.<\/span>percent<\/span>,<\/span> :memory_limit<\/span> =><\/span> 18<\/span>.<\/span>megabytes<\/span>)<\/span><\/div>end<\/span><\/div>  <\/div><\/pre><\/div>\n          \n        <\/div>\n\n        \n          view raw<\/a>\n          god.rb<\/a>\n          This Gist<\/a> brought to you by GitHub<\/a>.\n        <\/div>\n      <\/div>\n    \n  \n<\/div>\n')