tensor/outputs/riemann.py
def createClient(self):
        """Create a UDP connection to Riemann"""
        server = self.config.get('server', '127.0.0.1')
        port = self.config.get('port', 5555)

        def connect(ip):
            self.protocol = riemann.RiemannUDP(ip, port)
            self.endpoint = reactor.listenUDP(0, self.protocol)

        d = reactor.resolve(server)
        d.addCallback(connect)
        return d
def createClient(self):
        """Create a UDP connection to Riemann"""
        server = self.config.get('server', '127.0.0.1')
        port = self.config.get('port', 5555)

        def connect(ip):
            self.protocol = riemann.RiemannUDP(ip, port)
            self.endpoint = reactor.listenUDP(0, self.protocol)

        d = reactor.resolve(server)
        d.addCallback(connect)
        return d
def createClient ( self ) : server = self . config . get ( 'server' , '127.0.0.1' ) port = self . config . get ( 'port' , 5555 ) def connect ( ip ) : self . protocol = riemann . RiemannUDP ( ip , port ) self . endpoint = reactor . listenUDP ( 0 , self . protocol ) d = reactor . resolve ( server ) d . addCallback ( connect ) return d
Create a UDP connection to Riemann
Create a UDP connection to Riemann