start new:
tmux
start new with session name:
tmux new -s myname
| func payloadHandler(w http.ResponseWriter, r *http.Request) { | |
| if r.Method != "POST" { | |
| w.WriteHeader(http.StatusMethodNotAllowed) | |
| return | |
| } | |
| // Read the body into a string for json decoding | |
| var content = &PayloadCollection{} | |
| err := json.NewDecoder(io.LimitReader(r.Body, MaxLength)).Decode(&content) |
| type Dispatcher struct { | |
| // A pool of workers channels that are registered with the dispatcher | |
| WorkerPool chan chan Job | |
| } | |
| func NewDispatcher(maxWorkers int) *Dispatcher { | |
| pool := make(chan chan Job, maxWorkers) | |
| return &Dispatcher{WorkerPool: pool} | |
| } |
| var ( | |
| MaxWorker = os.Getenv("MAX_WORKERS") | |
| MaxQueue = os.Getenv("MAX_QUEUE") | |
| ) | |
| // Job represents the job to be run | |
| type Job struct { | |
| Payload Payload | |
| } |
| #!/usr/bin/python | |
| import psycopg2 | |
| import psycopg2.extras | |
| from pyes import * | |
| import argparse | |
| import traceback | |
| import math | |
| def ResultIter(cursor, arraysize=100): | |
| # An iterator that uses fetchmany to keep memory usage down |
#Mac OS X