Skip to content

Instantly share code, notes, and snippets.

View patrickmcguire's full-sized avatar

Patrick McGuire patrickmcguire

View GitHub Profile
1524865607.137354 "lrange" "sidekiq:queue:default" "2003" "2052"
1524865607.137651 "lrange" "sidekiq:queue:default" "3103" "3152"
1524865607.138266 "lrange" "sidekiq:queue:default" "10230" "10279"
1524865607.139222 "llen" "sidekiq:queue:default"
1524865607.139582 "lrange" "sidekiq:queue:default" "11833" "11882"
1524865607.139956 "llen" "sidekiq:queue:default"
1524865607.140247 "lrange" "sidekiq:queue:default" "10080" "10129"
1524865607.140613 "llen" "sidekiq:queue:default"
1524865607.140937 "llen" "sidekiq:queue:default"
1524865607.141833 "lrange" "sidekiq:queue:default" "10533" "10582"
Sidekiq::Queue.new.select do |job|
(job.args[0]["job_class"] == "OurSpecialClass") &&
(job.args[0]["arguments"][0]["_aj_globalid"] == "gid://our_id") &&
(job.args[0]["arguments"][1] == event_type)
end.any?
Sidekiq::Queue.new(:hook_event).select do |job|
(job.args[0]["job_class"] == "OurSpecialClass") &&
(job.args[0]["arguments"][0]["_aj_globalid"] == "gid://our_id") &&
(job.args[0]["arguments"][1] == event_type)
end.any?
bodyReader := bytes.NewReader(payload)
err = backoff.Retry(func() error {
resp, err := http.Post(c.BaseEndpoint+"/v1/set", "application/json", bodyReader)
if err != nil {
return err
}
defer resp.Body.Close()
response := map[string]interface{}{}
err = backoff.Retry(func() error {
bodyReader := bytes.NewReader(payload)
resp, err := http.Post(c.BaseEndpoint+"/v1/set", "application/json", bodyReader)
if err != nil {
return err
}
defer resp.Body.Close()
response := map[string]interface{}{}
dec := json.NewDecoder(resp.Body)
@patrickmcguire
patrickmcguire / gist:6142069
Created August 2, 2013 18:12
pink noise on os x
sox -t sw -r 44100 -c 2 /dev/zero -t coreaudio synth pinknoise vol -9 dB band -n 800 1200 fade q 5 30:00 10