Index

A

Ack (class in swimprotocol.packet) ack_gossip() (swimprotocol.members.Members method) add() (swimprotocol.shuffle.WeakShuffle method) add_arguments() (swimprotocol.config.BaseConfig class method) (swimprotocol.udp.config.UdpConfig class method)

Address (class in swimprotocol.address) AddressParser (class in swimprotocol.address) ALL (swimprotocol.status.Status attribute) all_statuses() (swimprotocol.status.Status class method) apply() (swimprotocol.members.Members method) AVAILABLE (swimprotocol.status.Status attribute)

B

BaseConfig (class in swimprotocol.config) BaseProtocol (class in swimprotocol.udp.protocol)

bind_host (swimprotocol.udp.UdpTransport property) bind_port (swimprotocol.udp.UdpTransport property)

C

CallbackPoll (class in swimprotocol.listener) check() (swimprotocol.worker.Worker method) choice() (swimprotocol.shuffle.Shuffle method) (swimprotocol.shuffle.WeakShuffle method) clock (swimprotocol.members.Member property)

config_type (swimprotocol.transport.Transport attribute) (swimprotocol.udp.UdpTransport attribute) ConfigError ConfigT_co (class in swimprotocol.config) connection_lost() (swimprotocol.udp.protocol.TcpProtocol method)

D

DaemonTask (class in swimprotocol.tasks) data_received() (swimprotocol.udp.protocol.TcpProtocol method) datagram_received() (swimprotocol.udp.protocol.UdpProtocol method)

demo digest (swimprotocol.sign.Signature attribute) discard() (swimprotocol.shuffle.WeakShuffle method) disseminate() (swimprotocol.worker.Worker method)

F

find() (swimprotocol.members.Members method)

from_args() (swimprotocol.config.BaseConfig class method)

G

get() (swimprotocol.address.Address class method) (swimprotocol.members.Members method) get_gossip() (swimprotocol.members.Members method)

get_status() (swimprotocol.members.Members method) Gossip (class in swimprotocol.packet) GossipAck (class in swimprotocol.packet)

H

handle_packet() (swimprotocol.udp.protocol.BaseProtocol method)

L

Listener (class in swimprotocol.listener) ListenerCallback (in module swimprotocol.listener)

load_transport() (in module swimprotocol.transport) local (swimprotocol.members.Members property) local member

M

member Member (class in swimprotocol.members) Members (class in swimprotocol.members) MemberSnapshot (class in swimprotocol.members) metadata (swimprotocol.members.Member property) METADATA_UNKNOWN (swimprotocol.members.Member attribute) module swimprotocol swimprotocol.address swimprotocol.config swimprotocol.listener swimprotocol.members swimprotocol.packet swimprotocol.shuffle swimprotocol.sign swimprotocol.status swimprotocol.tasks swimprotocol.transport swimprotocol.udp swimprotocol.udp.config swimprotocol.udp.pack swimprotocol.udp.protocol swimprotocol.udp.send swimprotocol.worker

N

name (swimprotocol.status.Status property) node

non_local (swimprotocol.members.Members property) notify() (swimprotocol.listener.Listener method)

O

OFFLINE (swimprotocol.status.Status attribute)

on_notify() (swimprotocol.listener.Listener method) ONLINE (swimprotocol.status.Status attribute)

P

pack() (swimprotocol.udp.pack.UdpPack method)

packet

ack

gossip

P

packet

packet

ping

ping-req

P

Packet (class in swimprotocol.packet) parse_args() (swimprotocol.config.BaseConfig class method) (swimprotocol.udp.config.UdpConfig class method) peer member

Ping (class in swimprotocol.packet) PingReq (class in swimprotocol.packet) poll() (swimprotocol.listener.Listener method) previous (swimprotocol.members.Member property)

R

recv_queue (swimprotocol.worker.Worker property) run() (swimprotocol.listener.CallbackPoll method) (swimprotocol.tasks.DaemonTask method) (swimprotocol.udp.send.UdpSend method) (swimprotocol.worker.Worker method)

run_dissemination() (swimprotocol.worker.Worker method) run_failure_detection() (swimprotocol.worker.Worker method) run_subtask() (swimprotocol.tasks.TaskOwner method)

S

salt (swimprotocol.sign.Signature attribute) send_queue (swimprotocol.worker.Worker property) sequence clock Shuffle (class in swimprotocol.shuffle)

sign() (swimprotocol.sign.Signatures method) Signature (class in swimprotocol.sign) Signatures (class in swimprotocol.sign) signatures (swimprotocol.config.BaseConfig property) Source (class in swimprotocol.packet)

status

offline

online

S

status

status

suspect

S

Status (class in swimprotocol.status) status (swimprotocol.members.Member property) status_time (swimprotocol.members.Member property) SUSPECT (swimprotocol.status.Status attribute) SWIM swimprotocol module swimprotocol.address module swimprotocol.config module swimprotocol.listener module swimprotocol.members module swimprotocol.packet module swimprotocol.shuffle module

swimprotocol.sign module swimprotocol.status module swimprotocol.tasks module swimprotocol.transport module swimprotocol.udp module swimprotocol.udp.config module swimprotocol.udp.pack module swimprotocol.udp.protocol module swimprotocol.udp.send module swimprotocol.worker module

T

TaskOwner (class in swimprotocol.tasks) TaskT (class in swimprotocol.tasks) TcpProtocol (class in swimprotocol.udp.protocol) TransientConfigError

transition() (swimprotocol.status.Status method) transport Transport (class in swimprotocol.transport) TransportT (class in swimprotocol.transport)

U

UdpConfig (class in swimprotocol.udp.config) UdpPack (class in swimprotocol.udp.pack) UdpProtocol (class in swimprotocol.udp.protocol) UdpSend (class in swimprotocol.udp.send)

UdpTransport (class in swimprotocol.udp) UNAVAILABLE (swimprotocol.status.Status attribute) unpack() (swimprotocol.udp.pack.UdpPack method) update() (swimprotocol.members.Members method)

V

verify() (swimprotocol.sign.Signatures method)

W

WeakShuffle (class in swimprotocol.shuffle)

Worker (class in swimprotocol.worker)