Did I find the right examples for you? yes no

All Samples(14)  |  Call(8)  |  Derive(0)  |  Import(6)

src/g/a/gaffer-0.5.2/gaffer/httpclient/process.py   gaffer(Download)
from ..util import (is_ssl, parse_ssl_options, parse_signal_value)
from .websocket import IOChannel
from .util import make_uri
 
class Process(object):
        # build connection url
        if stream is None:
            url = make_uri(self.server.uri, '/%s/channel' % self.pid,
                mode=mode)
        else:
            url = make_uri(self.server.uri, '/%s/channel/%s' % (self.pid,

src/g/a/gaffer-HEAD/gaffer/httpclient/process.py   gaffer(Download)
from ..util import (is_ssl, parse_ssl_options, parse_signal_value)
from .websocket import IOChannel
from .util import make_uri
 
class Process(object):
        # build connection url
        if stream is None:
            url = make_uri(self.server.uri, '/%s/channel' % self.pid,
                mode=mode)
        else:
            url = make_uri(self.server.uri, '/%s/channel/%s' % (self.pid,

src/g/a/gaffer-0.5.2/gaffer/httpclient/server.py   gaffer(Download)
from .process import Process
from .job import Job
from .util import make_uri
from .websocket import GafferSocket
 
    def socket(self, heartbeat=None):
        """ return a direct websocket connection to gaffer """
        url0 =  make_uri(self.uri, '/channel/websocket')
        url = "ws%s" % url0.split("http", 1)[1]
 

src/g/a/gaffer-HEAD/gaffer/httpclient/server.py   gaffer(Download)
from .process import Process
from .job import Job
from .util import make_uri
from .websocket import GafferSocket
 
    def socket(self, heartbeat=None):
        """ return a direct websocket connection to gaffer """
        url0 =  make_uri(self.uri, '/channel/websocket')
        url = "ws%s" % url0.split("http", 1)[1]
 

src/g/a/gaffer-0.5.2/gaffer/httpclient/base.py   gaffer(Download)
 
from ..tornado_pyuv import IOLoop
from .util import make_uri
 
class GafferNotFound(Exception):
    def request(self, method, path, headers=None, body=None, **params):
        headers = headers or {}
        headers.update({"Accept": "application/json"})
        url = make_uri(self.uri, path, **params)
        method = method.upper()

src/g/a/gaffer-HEAD/gaffer/httpclient/base.py   gaffer(Download)
 
from ..tornado_pyuv import IOLoop
from .util import make_uri
 
class GafferNotFound(Exception):
    def request(self, method, path, headers=None, body=None, **params):
        headers = headers or {}
        headers.update({"Accept": "application/json"})
        url = make_uri(self.uri, path, **params)
        method = method.upper()