Geesu

class Semaphore
  def self.get(name, options = {})
    # Create a new Redis connection specifically for the semaphore.
    # Treat a semaphore as stale if it's too old. We have to assume that processing was interrupted, so that we can try the same files again.
    Redis::Semaphore.new(name.to_sym,
      :redis => Aperture.redis,
      stale_client_timeout: options[:stale_client_timeout].try(:to_i) || 1.hour,
    )
  end
end

Geesu

Verifying that +geesu is my Bitcoin username. You can send me #bitcoin here: https://onename.io/geesu

Geesu

#!/bin/bash

echoerr() { echo "$@" 1>&2; }

FAIL=0

echoerr "Called"

`envdir /etc/wal-e.d/env /usr/local/bin/wal-e wal-push $1` & pid_1=$!

Geesu

Configuration

Slave

• Install WAL-E (Note: You will have to run sudo python setup.py install MULTIPLE times, probably like 10):

sudo apt-get install daemontools pv lzop

git clone https://github.com/wal-e/wal-e.git && cd wal-e && sudo python setup.py install

• Configure the environment for WAL-E (as root):

umask u=rwx,g=rx,o= mkdir -p /etc/wal-e.d/env echo "THEACCESSKEY" > /etc/wal-e.d/env/AWS_SECRET_ACCESS_KEY echo "THEKEYID" > /etc/wal-e.d/env/AWS_ACCESS_KEY_ID

Geesu

standby_mode = 'on' # enables stand-by (readonly) mode

# Connect to the master postgres server using the replicator user we created.
primary_conninfo = 'host=a port=5432 user=replicator password=password'

# Specifies a trigger file whose presence should cause streaming replication to
# end (i.e., failover).
trigger_file = '/tmp/pg_failover_trigger'

# Shell command to execute an archived segment of WAL file series. 

Geesu

#!/bin/bash

echoerr() { echo "$@" 1>&2; }

FAIL=0

`rsync -aq $1 postgres@b:/var/lib/postgresql/9.2/archive/$2` & pid_1=$! ; `rsync -aq $1 postgres@c:/var/lib/postgresql/9.2/archive/$2` & pid_2=$! ; `rsync -aq $1 postgres@d:/var/lib/postgresql/9.2/archive/$2` & pid_3=$!

echoerr "Spawned replication processes $pid_1 AND $pid_2 AND $pid_3"

Geesu

#!/bin/bash

FAIL=0

job_1 = `rsync -aq $1 postgres@server1:/var/lib/postgresql/9.2/archive/$2`
job_2 = `rsync -aq $1 postgres@server2:/var/lib/postgresql/9.2/archive/$2`

$job_1 & pid_1=$! ; $job_2 & pid_2=$!

echo "Spawned replication processes $pid_1 AND $pid_2"