cwestin

// make sure we're using the right db; this is the same as "use aggdb;" in shell
db = db.getSiblingDB("aggdb");

// simple projection
var p1 = db.runCommand(
{ aggregate : "article", pipeline : [
    { $project : {
	tags : 1,
	pageViews : 1
    }}

db.go

package dropbox

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"net/url"
	"strconv"

jboner

Latency Comparison Numbers (~2012)
----------------------------------
L1 cache reference                           0.5 ns
Branch mispredict                            5   ns
L2 cache reference                           7   ns                      14x L1 cache
Mutex lock/unlock                           25   ns
Main memory reference                      100   ns                      20x L2 cache, 200x L1 cache
Compress 1K bytes with Zippy             3,000   ns        3 us
Send 1K bytes over 1 Gbps network       10,000   ns       10 us
Read 4K randomly from SSD*             150,000   ns      150 us          ~1GB/sec SSD

artisonian

eventsource
go-eventsource
client/client

adharris

package main

import (
	"database/sql"
	"errors"
	"fmt"
	_ "github.com/bmizerany/pq"
	"os"
	"regexp"
	"strings"

KartikTalwar

The fastest remote directory rsync over ssh archival I can muster (40MB/s over 1gb NICs)

This creates an archive that does the following:

rsync (Everyone seems to like -z, but it is much slower for me)

• a: archive mode - rescursive, preserves owner, preserves permissions, preserves modification times, preserves group, copies symlinks as symlinks, preserves device files.
• H: preserves hard-links
• A: preserves ACLs

minikomi

package main

import (
        "encoding/json"
        "fmt"
        "github.com/gorilla/sessions"
        "io/ioutil"
        "log"
        "net/http"
        "net/url"

metakeule

package main

import "fmt"

type Foo struct{}
func (f *Foo) Method() {
  fmt.Println("Method")
}

type Funcs []func(*Foo)

grafov

package main

import (
	"code.google.com/p/go.net/websocket"
	//"github.com/garyburd/go-websocket/websocket"
	//"github.com/zhangpeihao/gowebsocket"
	"net/http"
	"net/rpc"
	"net/rpc/jsonrpc"
)

maliqq

package protocol

import (
	"fmt"
	"log"
)

// pubsub
type Broker struct {
	Send map[string]*chan *Message