davebshow

davebshow

import uuid
from tornado.concurrent import Future
from tornado.websocket import websocket_connect


class GremlinResponseStream:
    def __init__(self, conn):
        self._conn = conn

    @asyncio.coroutine

davebshow

def df_edge_traversal(g):
    """
    Based on networkx dfs_edges
    """
    visited = set()
    start = g.nodes()[0]
    stack = [(start, iter(g[start]))]
    while stack:
        parent, children = stack[-1]
        try:

davebshow

match path=(t:tweet {tid: '665496205854687232'})-[:REPLIES_TO|RETWEETS|TWEETS*1..4]-(:tweet) return filter(x in nodes(path) where exists(x.tid))

davebshow

import asyncio
import collections
import json
import uuid

import aiohttp


Message = collections.namedtuple(
    "Message",

davebshow

import asyncio
import datetime

from pytz import utc

from tornado.platform.asyncio import AsyncIOMainLoop

from mogwai import properties
from mogwai.connection import setup, close_global_pool
from mogwai.models import Vertex, Edge, V

davebshow

"""
Simple client for the JSONRPC Server
"""
import asyncio
from pulsar.apps import rpc


proxy = rpc.JsonProxy("http://localhost:8060")

davebshow

"""
This example demonstrates how to use Pulsar actors to create
nodes with Goblin. This is the basic concept on which other Pulsar/Goblin
apps would be based, but it may be better to use Pulsar's higher
level Application class interface...
Based on:
https://github.com/quantmind/pulsar/blob/master/examples/snippets/greeter.py
"""
import asyncio
import pulsar

davebshow

import asyncio
import pulsar
from pulsar.apps import ws, wsgi


class Echo(ws.WS):

    def on_bytes(self, websocket, msg):
        websocket._loop.call_soon(
            pulsar.ensure_future, self._call(websocket, msg))

davebshow

import asyncio
import datetime

from pytz import utc

from tornado.platform.asyncio import AsyncIOMainLoop

from goblin import properties
from goblin.connection import setup, tear_down
from goblin.models import Vertex, Edge, V