tensor.protocol

tensor.protocol.elasticsearch

class tensor.protocol.elasticsearch.ElasticSearch(url='http://localhost:9200', user=None, password=None, index='tensor-%Y.%m.%d')[source]

Bases: object

Twisted ElasticSearch API

tensor.protocol.icmp

class tensor.protocol.icmp.EchoPacket(seq=0, id=None, data=None, packet=None)[source]

Bases: object

ICMP Echo packet encoder and decoder

class tensor.protocol.icmp.ICMPPing(d, dst, count, inter=0.2, maxwait=1000, size=64)[source]

Bases: twisted.internet.protocol.DatagramProtocol

ICMP Ping implementation

class tensor.protocol.icmp.ICMPPort(port, proto, interface='', maxPacketSize=8192, reactor=None)[source]

Bases: twisted.internet.udp.Port

Raw socket listener for ICMP

class tensor.protocol.icmp.IP(packet)[source]

Bases: object

IP header decoder

tensor.protocol.icmp.ping(dst, count, inter=0.2, maxwait=1000, size=64)[source]

Sends ICMP echo requests to destination dst count times. Returns a deferred which fires when responses are finished.

tensor.protocol.riemann

class tensor.protocol.riemann.RiemannClientFactory(hosts, failover=False)[source]

Bases: twisted.internet.protocol.ReconnectingClientFactory

A reconnecting client factory which creates RiemannProtocol instances

class tensor.protocol.riemann.RiemannProtocol[source]

Bases: twisted.protocols.basic.Int32StringReceiver, tensor.protocol.riemann.RiemannProtobufMixin

Riemann protobuf protocol

class tensor.protocol.riemann.RiemannUDP(host, port)[source]

Bases: twisted.internet.protocol.DatagramProtocol, tensor.protocol.riemann.RiemannProtobufMixin

UDP datagram protocol for Riemann

tensor.protocol.ssh

tensor.protocol.sflow

tensor.protocol.sflow.server

class tensor.protocol.sflow.server.DatagramReceiver[source]

Bases: twisted.internet.protocol.DatagramProtocol

DatagramReceiver for sFlow packets

tensor.protocol.sflow.protocol