# Path: tensor/utils.py
# def fork(executable, args=(), env={}, path=None, timeout=3600):
#     """fork
#     Provides a deferred wrapper function with a timeout function
# 
#     :param executable: Executable
#     :type executable: str.
#     :param args: Tupple of arguments
#     :type args: tupple.
#     :param env: Environment dictionary
#     :type env: dict.
#     :param timeout: Kill the child process if timeout is exceeded
#     :type timeout: int.
#     """
#     d = defer.Deferred()
#     p = ProcessProtocol(d, timeout)
#     reactor.spawnProcess(p, executable, (executable,)+tuple(args), env, path)
#     return d
# 
# Path: tensor/protocol/ssh.py
# class FakeLog(object):
# class SSHCommandProtocol(protocol.Protocol):
# class SSHClient(object):
#     def msg(self, *a):
#     def callWithLogger(self, *a, **kw):
#     def connectionMade(self):
#     def dataReceived(self, data):
#     def extReceived(self, code, data):
#     def connectionLost(self, reason):
#     def __init__(self, hostname, username, port, password=None,
#                  knownhosts=None):
#     def verifyHostKey(self, ui, hostname, ip, key):
#         def gotHasKey(result):
#     def addKeyFile(self, kfile, password=None):
#     def addKeyString(self, kstring, password=None):
#     def _get_endpoint(self):
#     def connect(self):
#         def connected(protocol):
#     def fork(self, command, args=(), env={}, path=None, timeout=3600):
#         def finished(result):
#         def connected(connection):


import hashlib
import re
import time
import socket
    from exceptions import NotImplementedError
from twisted.internet import task, defer
from twisted.python import log
from tensor.utils import fork
from tensor.protocol import ssh
        """Deferred which sets up the output
        """
        pass

    def eventsReceived(self):
        """Receives a list of events and processes them

        Arguments:
        events -- list of `tensor.objects.Event`
        """
        pass

    def stop(self):
        """Called when the service shuts down
        """
        pass

class Source(object):
    """Source parent class

    Sources can inherit this object which provides a number of
    utility methods.

    :param config: Dictionary config for this queue (usually read from the
             yaml configuration)
    :param queueBack: A callback method to recieve a list of Event objects
    :param tensor: A TensorService object for interacting with the queue manager
    """

    sync = False

# Path: tensor/utils.py
# def fork(executable, args=(), env={}, path=None, timeout=3600):
#     """fork
#     Provides a deferred wrapper function with a timeout function
# 
#     :param executable: Executable
#     :type executable: str.
#     :param args: Tupple of arguments
#     :type args: tupple.
#     :param env: Environment dictionary
#     :type env: dict.
#     :param timeout: Kill the child process if timeout is exceeded
#     :type timeout: int.
#     """
#     d = defer.Deferred()
#     p = ProcessProtocol(d, timeout)
#     reactor.spawnProcess(p, executable, (executable,)+tuple(args), env, path)
#     return d
# 
# Path: tensor/protocol/ssh.py
# class FakeLog(object):
# class SSHCommandProtocol(protocol.Protocol):
# class SSHClient(object):
#     def msg(self, *a):
#     def callWithLogger(self, *a, **kw):
#     def connectionMade(self):
#     def dataReceived(self, data):
#     def extReceived(self, code, data):
#     def connectionLost(self, reason):
#     def __init__(self, hostname, username, port, password=None,
#                  knownhosts=None):
#     def verifyHostKey(self, ui, hostname, ip, key):
#         def gotHasKey(result):
#     def addKeyFile(self, kfile, password=None):
#     def addKeyString(self, kstring, password=None):
#     def _get_endpoint(self):
#     def connect(self):
#         def connected(protocol):
#     def fork(self, command, args=(), env={}, path=None, timeout=3600):
#         def finished(result):
#         def connected(connection):


# Path: tensor/objects.py
import hashlib
import re
import time
import socket
    from exceptions import NotImplementedError
from twisted.internet import task, defer
from twisted.python import log
from tensor.utils import fork
from tensor.protocol import ssh

        """Deferred which sets up the output
        """
        pass

    def eventsReceived(self):
        """Receives a list of events and processes them

        Arguments:
        events -- list of `tensor.objects.Event`
        """
        pass

    def stop(self):
        """Called when the service shuts down
        """
        pass

class Source(object):
    """Source parent class

    Sources can inherit this object which provides a number of
    utility methods.

    :param config: Dictionary config for this queue (usually read from the
             yaml configuration)
    :param queueBack: A callback method to recieve a list of Event objects
    :param tensor: A TensorService object for interacting with the queue manager
    """

    sync = False

    ssh = False