I hereby claim:
- I am rybit on github.
- I am rybit (https://keybase.io/rybit) on keybase.
- I have a public key ASBHvfdHJq_uscOtNO0IXp_-cdm7VCDryxx1p2-53c635wo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
package main | |
import ( | |
"errors" | |
"fmt" | |
"os" | |
"reflect" | |
"strconv" | |
"strings" |
package main | |
import ( | |
"bufio" | |
"fmt" | |
"log" | |
"math" | |
"os" | |
"sort" | |
"strconv" |
package main | |
import ( | |
"context" | |
"crypto/tls" | |
"fmt" | |
"log" | |
"net/http" | |
"os" | |
"os/signal" |
package main | |
import ( | |
"compress/gzip" | |
"encoding/json" | |
"flag" | |
"fmt" | |
"io" | |
"log" | |
"os" |
# stdlib | |
from collections import defaultdict | |
from urlparse import urlparse | |
import re | |
# 3rd party | |
import requests | |
# project | |
from checks import AgentCheck |
I hereby claim:
To claim this, I am signing this object:
package main | |
import ( | |
"crypto/hmac" | |
"crypto/sha256" | |
"encoding/base64" | |
"encoding/json" | |
"errors" | |
"fmt" | |
"hash" |
ryan@rabbitmq-aws-jfk-1:~$ sudo rabbitmq-server start | |
RabbitMQ 3.6.9. Copyright (C) 2007-2016 Pivotal Software, Inc. | |
## ## Licensed under the MPL. See http://www.rabbitmq.com/ | |
## ## | |
########## Logs: /var/log/rabbitmq/rabbitmq-aws-jfk-1.log | |
###### ## /var/log/rabbitmq/rabbitmq-aws-jfk-1-sasl.log | |
########## | |
Starting broker... |
func StartWorkerPoolWithTimedShutdown(batchSize, numWorkers int, endpoint string) (chan<- string, chan time.Duration) { | |
externalShutdown := make(chan time.Duration) | |
work := make(chan string) | |
// use a sync.WaitGroup to ensure that we wait for all of the workers to Finished | |
wg := new(sync.WaitGroup) | |
// use a context with a cancel method to signal internally to shutdown the worker | |
ctx, cancel := context.WithCancel(context.Background()) |