Skip to content

Instantly share code, notes, and snippets.

#!/bin/sh
set -e
while ! [ -f all.sh ] && [ "$PWD" != "/" ]
do cd ..
done
[ -f clean.sh ] &&
./clean.sh
#!/bin/sh
set -e
while ! [ -f all.sh ]
do cd ..
done
[ -f clean.sh ] &&
./clean.sh
diff --git c/pgsql.go i/pgsql.go
index b924d16..6425d3a 100644
--- c/pgsql.go
+++ i/pgsql.go
@@ -189,6 +189,20 @@ func (r *Result) Clear() {
}
}
+type Notify struct {
+ Name string
package main
import (
"github.com/jbarham/pgsql.go"
"time"
"fmt"
)
func mustAcquire(pool *pgsql.Pool) *pgsql.Conn {
cn, err := pool.Acquire()

Clustering Doozer

Overview

A Doozer cluster is one or more doozerd processes interconnected with one another, where all the participants are performing consensus. Each member of a cluster is referred to as a cal. CAL stands for "Coordinator, Acceptor, and Learner" as defined by Paxos.

CALs can propose changes to the state of the system (or mutations) through

Clustering Doozer

Overview

A Doozer cluster is one or more doozerd processes interconnected with one another, where all the participants are performing consensus. Each member of a cluster is refered to as a cal. CAL stands for "Coordinator, Acceptor, and Learner" as defined by Paxos.

CALs can propose changes to the state of the system (or mutations) through

baddr="127.0.0.1:9000"
doozerd -l $baddr > boot.log 2>&1 & # The boot cluster
sleep 1
doozerd -b "doozer:?ca=$baddr" -l 127.0.0.1:8001 -w 127.0.0.1:8081 &
doozerd -b "doozer:?ca=$baddr" -l 127.0.0.1:8002 -w 127.0.0.1:8082 &
doozerd -b "doozer:?ca=$baddr" -l 127.0.0.1:8003 -w 127.0.0.1:8083 &
diff --git i/src/pkg/server/msg.proto w/src/pkg/server/msg.proto
index cd21130..d85f3a6 100644
--- i/src/pkg/server/msg.proto
+++ w/src/pkg/server/msg.proto
@@ -14,6 +14,7 @@ message Request {
WALK = 9;
GETDIR = 14;
STAT = 16;
+ AUTH = 99;
}
require 'rubygems'
require 'eventmachine'
require 'fraggle'
EM.run do
c = Fraggle.connect
paths = []
req = c.walk("/**", 1)
.DS_Store