Skip to content

Instantly share code, notes, and snippets.

package sharding
import (
"sync"
"github.com/golang/groupcache/consistenthash"
"gopkg.in/redis.v1"
)
const replicas = 100
func copyHeader(dst, src http.Header) {
for k, vv := range src {
for _, v := range vv {
dst.Add(k, v)
}
}
}
func cloneReq(req *http.Request) *http.Request {
outreq := new(http.Request)
import (
"net/http"
)
func init() {
http.Handle("/", proxyHandler)
}
func proxyHandler(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Access-Control-Allow-Origin", "*")
(.*):(\d*):in '(.*)'
@vmihailenco
vmihailenco / httptest.go
Created September 18, 2012 08:45
httptest.go
package httptest
import (
"bytes"
"io"
"net/http"
"appengine"
)
package gaetesting
import (
"net/http"
"time"
"myapp/context"
"myapp/testlib"
"launchpad.net/gocheck"
@vmihailenco
vmihailenco / bench2.go
Created August 31, 2012 08:34
bench2.go
package main
import (
"bytes"
"flag"
"fmt"
"log"
"net"
"os"
"runtime"
@vmihailenco
vmihailenco / redisbench.go
Created August 30, 2012 14:07
redisbench.go
package main
import (
"bytes"
"flag"
"fmt"
"net"
"sync/atomic"
"time"
)
processor : 0
vendor_id : GenuineIntel
cpu family : 6
model : 2
model name : QEMU Virtual CPU version 0.14.1
stepping : 3
cpu MHz : 2400.012
cache size : 4096 KB
fpu : yes
fpu_exception : yes
@vmihailenco
vmihailenco / redis_proxy.go
Created July 31, 2012 08:27
redis_proxy.go
package main
import (
"net"
"runtime"
)
func proxy(conn net.Conn) {
buf := make([]byte, 1000)