duct.protocol

duct.protocol.elasticsearch

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

Bases: object

Twisted ElasticSearch API

duct.protocol.icmp

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

Bases: object

ICMP Echo packet encoder and decoder

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

Bases: twisted.internet.protocol.DatagramProtocol

ICMP Ping implementation

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

Bases: twisted.internet.udp.Port

Raw socket listener for ICMP

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

Bases: object

IP header decoder

duct.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.

duct.protocol.imap4

duct.protocol.opentdsb

class duct.protocol.opentsdb.OpenTSDBClient(url='http://localhost:4242', user=None, password=None)[source]

Bases: object

Twisted ElasticSearch API

duct.protocol.riemann

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

Bases: twisted.internet.protocol.ReconnectingClientFactory

A reconnecting client factory which creates RiemannProtocol instances

class duct.protocol.riemann.RiemannProtocol[source]

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

Riemann protobuf protocol

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

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

UDP datagram protocol for Riemann

duct.protocol.ssh

duct.protocol.sflow

duct.protocol.sflow.server

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

Bases: twisted.internet.protocol.DatagramProtocol

DatagramReceiver for sFlow packets

duct.protocol.sflow.protocol