Failover test

gistfile1.py

import _pylibmc, pylibmc
from time import time, sleep

mc = pylibmc.Client(["127.0.0.1:11211", "127.0.0.1:11212"])
mc.behaviors.update({"remove_failed": 2,
                     "ketama": True,
                     "ketama_hash": True,
                     "_retry_timeout": 2})

print "libmemcached", _pylibmc.libmemcached_version
__import__("pprint").pprint(mc.behaviors)

t0 = time()
td = lambda: "%03.02f" % (time() - t0)

while True:
    sleep(5)
    try:
        print td(), "set =>",
        print mc.set("foo", "bar")
        sleep(0.125)

        print td(), "get =>",
        print mc.get("foo")
        sleep(0.125)
    except pylibmc.Error as e:
        print "failed", type(e), e
        sleep(0.125)