Index

_

_uuid (p2p0mq.peer_store.PeerStore attribute)

A

add_all_library_concerns() (p2p0mq.concerns.manager.ConcernsManager method) add_concern() (p2p0mq.concerns.manager.ConcernsManager method) add_peer() (p2p0mq.peer_store.PeerStore method)

app (p2p0mq.concerns.base.Concern attribute) AskAroundConcern (class in p2p0mq.concerns.ask_around) auth_thread (p2p0mq.security.SecurityManager attribute)

B

BaseError

C

cert_file_by_uuid() (p2p0mq.security.SecurityManager method) cert_key_by_uuid() (p2p0mq.security.SecurityManager method) cert_pair_check_gen() (p2p0mq.security.SecurityManager method) command_id (p2p0mq.concerns.base.Concern attribute) compose_ask_around_message() (p2p0mq.concerns.ask_around.AskAroundConcern method) compose_heart_beat_request() (p2p0mq.concerns.heart_beat.HeartBeatConcern method) Concern (class in p2p0mq.concerns.base) concerns (p2p0mq.concerns.manager.ConcernsManager attribute) concerns_started (p2p0mq.concerns.manager.ConcernsManager attribute) ConcernsManager (class in p2p0mq.concerns.manager)

config (in module p2p0mq.app.local_peer.LocalPeer) connect_peer() (p2p0mq.concerns.connector.ConnectorConcern method) connect_peers() (p2p0mq.app.client.Sender method) connecting_peer() (p2p0mq.concerns.connector.ConnectorConcern method) ConnectorConcern (class in p2p0mq.concerns.connector) create() (p2p0mq.app.client.Sender method) (p2p0mq.app.server.Receiver method) create_meta_table() (p2p0mq.peer_store.PeerStore method) create_peers_table() (p2p0mq.peer_store.PeerStore method) create_reply() (p2p0mq.message.Message method)

D

daemon (in module p2p0mq.app.local_peer.LocalPeer) db_created (p2p0mq.peer_store.PeerStore attribute)

db_file_path (p2p0mq.peer_store.PeerStore attribute) declare_no_connection() (p2p0mq.concerns.connector.ConnectorConcern method) default_route (p2p0mq.router.Router attribute)

E

encode() (p2p0mq.message.Message method) enqueue() (p2p0mq.app.client.Sender method) (p2p0mq.app.server.Receiver method) enqueue_all() (p2p0mq.app.client.Sender method) enqueue_fast() (p2p0mq.app.client.Sender method) enqueue_medium() (p2p0mq.app.client.Sender method) enqueue_slow() (p2p0mq.app.client.Sender method) exchange_certificates() (p2p0mq.security.SecurityManager method)

execute() (p2p0mq.app.client.Sender method) (p2p0mq.app.server.Receiver method) (p2p0mq.concerns.base.Concern method) (p2p0mq.concerns.connector.ConnectorConcern method) (p2p0mq.concerns.heart_beat.HeartBeatConcern method) execute_concerns() (p2p0mq.concerns.manager.ConcernsManager method) execute_queue() (p2p0mq.app.client.Sender method) expired_peer() (p2p0mq.concerns.heart_beat.HeartBeatConcern method)

H

HeartBeatConcern (class in p2p0mq.concerns.heart_beat)

I

ident (in module p2p0mq.app.local_peer.LocalPeer)

M

Message (class in p2p0mq.message) message_dropped() (p2p0mq.concerns.base.Concern method) (p2p0mq.concerns.connector.ConnectorConcern method)

message_sent() (p2p0mq.concerns.base.Concern method) (p2p0mq.concerns.connector.ConnectorConcern method) MessageValidationError MissingCertificateError (class in p2p0mq.errors)

N

name (in module p2p0mq.app.local_peer.LocalPeer), [1] (p2p0mq.concerns.base.Concern attribute)

next_peer_db_sync_time (p2p0mq.peer_store.PeerStore attribute) no_encryption (p2p0mq.security.SecurityManager attribute)

P

p2p0mq.app.client (module) p2p0mq.app.local_peer.LocalPeer (module) p2p0mq.app.server (module) p2p0mq.concerns.ask_around (module) p2p0mq.concerns.base (module) p2p0mq.concerns.connector (module) p2p0mq.concerns.heart_beat (module) p2p0mq.concerns.manager (module) p2p0mq.constants (module) p2p0mq.errors (module) p2p0mq.message (module) p2p0mq.peer_store (module) p2p0mq.router (module) p2p0mq.security (module) p2p0mq.utils (module) peers (p2p0mq.peer_store.PeerStore attribute) peers_lock (p2p0mq.peer_store.PeerStore attribute)

PeerStore (class in p2p0mq.peer_store) prepare_cert_store() (p2p0mq.security.SecurityManager method) private_cert_dir (p2p0mq.security.SecurityManager attribute) private_file (p2p0mq.security.SecurityManager attribute) process_common() (p2p0mq.concerns.manager.ConcernsManager method) process_replies() (p2p0mq.concerns.manager.ConcernsManager method) process_reply() (p2p0mq.concerns.ask_around.AskAroundConcern method) (p2p0mq.concerns.base.Concern method) (p2p0mq.concerns.connector.ConnectorConcern method) (p2p0mq.concerns.heart_beat.HeartBeatConcern method) process_request() (p2p0mq.concerns.ask_around.AskAroundConcern method) (p2p0mq.concerns.base.Concern method) (p2p0mq.concerns.connector.ConnectorConcern method) (p2p0mq.concerns.heart_beat.HeartBeatConcern method) process_requests() (p2p0mq.concerns.manager.ConcernsManager method) process_routes() (p2p0mq.router.Router method) public_cert_dir (p2p0mq.security.SecurityManager attribute) public_file (p2p0mq.security.SecurityManager attribute)

R

receive_message() (p2p0mq.app.server.Receiver method) Receiver (class in p2p0mq.app.server)

receiver (in module p2p0mq.app.local_peer.LocalPeer) reconnect_peer() (p2p0mq.concerns.connector.ConnectorConcern method) Router (class in p2p0mq.router)

S

SecurityManager (class in p2p0mq.security) send_failed() (p2p0mq.concerns.base.Concern method) (p2p0mq.concerns.connector.ConnectorConcern method) send_message() (p2p0mq.app.client.Sender method) Sender (class in p2p0mq.app.client)

sender (in module p2p0mq.app.local_peer.LocalPeer) start() (p2p0mq.concerns.base.Concern method) start_auth() (p2p0mq.security.SecurityManager method) start_concerns() (p2p0mq.concerns.manager.ConcernsManager method) start_db() (p2p0mq.peer_store.PeerStore method) sync_database() (p2p0mq.peer_store.PeerStore method)

T

table_exists() (p2p0mq.peer_store.PeerStore method) take_peer() (p2p0mq.peer_store.PeerStore method) temp_cert_dir (p2p0mq.security.SecurityManager attribute) terminate() (p2p0mq.app.client.Sender method) (p2p0mq.app.server.Receiver method) (p2p0mq.concerns.base.Concern method)

terminate_auth() (p2p0mq.security.SecurityManager method) terminate_concerns() (p2p0mq.concerns.manager.ConcernsManager method) terminate_db() (p2p0mq.peer_store.PeerStore method)

U

update_queues() (p2p0mq.app.server.Receiver method)

uuid (in module p2p0mq.app.local_peer.LocalPeer) (p2p0mq.peer_store.PeerStore attribute)

V

valid_for_send() (p2p0mq.message.Message method)

validate_messages_for_send() (p2p0mq.message.Message static method) ValidationError

Z

zmq_context (in module p2p0mq.app.local_peer.LocalPeer)

zmq_monitor (in module p2p0mq.app.local_peer.LocalPeer)