rectalogic

cureatr:PRIMARY> use test
cureatr:PRIMARY> db.foo.createIndex({prefix: 1, unique: 1}, {unique: true})
cureatr:PRIMARY> db.foo.createIndex({prefix : 1, nonunique: 1})

cureatr:PRIMARY> db.foo.explain().find({prefix: "a", nonunique: /^a/i})
{
    "queryPlanner" : {
        "plannerVersion" : 1,
        "namespace" : "test.foo",
        "indexFilterSet" : false,

rectalogic

sh-session hiliting

user@vpn$ dd if=/dev/random count=32 bs=1 2>/dev/null | base64
N/5y0EkgCFevc9uvJv1GsMG14BwbknCERoyJKZatoh0=
user@vpn$ dd if=/dev/random count=32 bs=1 2>/dev/null | base64
eb3W4WYXuHsnc0KVzg65G3XFQUD/I69/pYqFCYb5+iQ=

console hiliting

rectalogic

    pipeline = [
        {
            "$match": {
                "$and": query
            }
        },
        {"$group": {"_id": "$user_id", "user_id": {"$sum": 1}}}
    ]

rectalogic

import socket
import threading
from StringIO import StringIO
import paramiko

HOST, PORT = 'localhost', 2222
HOSTKEY = """
-----BEGIN EC PRIVATE KEY-----
MHcCAQEEINnMNKzog0Cbnun+EKuFu4kcpc0iKJALw5LkC1E1x+9EoAoGCCqGSM49
AwEHoUQDQgAEt11fabDR77CPL/1OUfayQ/m3C1uRI/039pBmYagk4zQ4Mxwow6L6

rectalogic

import signal
import Queue

def handler(signum, frame):
    q.put(None)

signal.signal(signal.SIGTERM, handler)
signal.signal(signal.SIGINT, handler)

q = Queue.Queue()

rectalogic

import signal
import Queue

def handler(signum, frame):
    global shutdown
    # Don't log here, not reentrant
    shutdown = True

signal.signal(signal.SIGTERM, handler)
signal.signal(signal.SIGINT, handler)

rectalogic

import threading
import socket
import Queue

def accept():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind(("", 65021))
    s.listen(5)
    s.accept()

rectalogic

bounds_w = 100
bounds_h = 100
im_w, im_h = im.size

scales = (bounds_w / im_w, bounds_h / im_h)

if scale_type == "meet":
    scale = min(scales)
elif scale_type == "fill":
    scale = max(scales)

rectalogic

class Enum(object):
    def __init__(self, **kwargs):
        self._values = set()
        for k, v in kwargs.items():
            setattr(self, k, v)
            self._values.add(v)

    def validate(self, values):
        return set(values).issubset(self._values)

rectalogic

from abc import ABCMeta

class ListLike:
    __metaclass__ = ABCMeta

ListLike.register(list)
ListLike.register(tuple)
ListLike.register(_FieldSequence)

>>> isinstance([], ListLike)