patroni package
Subpackages
- patroni.dcs package
- Submodules
- Module contents
AbstractDCS
AbstractDCS._CONFIG
AbstractDCS._FAILOVER
AbstractDCS._FAILSAFE
AbstractDCS._HISTORY
AbstractDCS._INITIALIZE
AbstractDCS._LEADER
AbstractDCS._LEADER_OPTIME
AbstractDCS._MEMBERS
AbstractDCS._OPTIME
AbstractDCS._STATUS
AbstractDCS._SYNC
AbstractDCS.__get_patroni_cluster()
AbstractDCS.__init__()
AbstractDCS._abc_impl
AbstractDCS._citus_cluster_loader()
AbstractDCS._cluster_loader()
AbstractDCS._delete_leader()
AbstractDCS._get_citus_cluster()
AbstractDCS._load_cluster()
AbstractDCS._set_loop_wait()
AbstractDCS._update_leader()
AbstractDCS._write_failsafe()
AbstractDCS._write_leader_optime()
AbstractDCS._write_status()
AbstractDCS.attempt_to_acquire_leader()
AbstractDCS.cancel_initialization()
AbstractDCS.client_path()
AbstractDCS.cluster
AbstractDCS.config_path
AbstractDCS.delete_cluster()
AbstractDCS.delete_leader()
AbstractDCS.delete_sync_state()
AbstractDCS.failover_path
AbstractDCS.failsafe
AbstractDCS.failsafe_path
AbstractDCS.get_citus_coordinator()
AbstractDCS.get_cluster()
AbstractDCS.history_path
AbstractDCS.initialize()
AbstractDCS.initialize_path
AbstractDCS.is_citus_coordinator()
AbstractDCS.last_seen
AbstractDCS.leader_optime_path
AbstractDCS.leader_path
AbstractDCS.loop_wait
AbstractDCS.manual_failover()
AbstractDCS.member_path
AbstractDCS.members_path
AbstractDCS.reload_config()
AbstractDCS.reset_cluster()
AbstractDCS.set_config_value()
AbstractDCS.set_failover_value()
AbstractDCS.set_history_value()
AbstractDCS.set_retry_timeout()
AbstractDCS.set_sync_state_value()
AbstractDCS.set_ttl()
AbstractDCS.status_path
AbstractDCS.sync_path
AbstractDCS.sync_state()
AbstractDCS.take_leader()
AbstractDCS.touch_member()
AbstractDCS.ttl
AbstractDCS.update_leader()
AbstractDCS.watch()
AbstractDCS.write_failsafe()
AbstractDCS.write_leader_optime()
AbstractDCS.write_status()
AbstractDCS.write_sync_state()
Cluster
Cluster.__permanent_logical_slots
Cluster.__permanent_physical_slots
Cluster.__permanent_slots
Cluster._get_members_slots()
Cluster._get_permanent_slots()
Cluster._has_permanent_logical_slots()
Cluster._merge_permanent_slots()
Cluster.empty()
Cluster.filter_permanent_slots()
Cluster.get_clone_member()
Cluster.get_member()
Cluster.get_my_slot_name_on_primary()
Cluster.get_replication_slots()
Cluster.has_member()
Cluster.has_permanent_slots()
Cluster.is_empty()
Cluster.is_logical_slot()
Cluster.is_physical_slot()
Cluster.is_unlocked()
Cluster.last_lsn
Cluster.leader_name
Cluster.min_version
Cluster.should_enforce_hot_standby_feedback()
Cluster.slots
Cluster.timeline
Cluster.use_slots
ClusterConfig
ClusterConfig._asdict()
ClusterConfig._field_defaults
ClusterConfig._fields
ClusterConfig._make()
ClusterConfig._replace()
ClusterConfig.data
ClusterConfig.from_node()
ClusterConfig.ignore_slots_matchers
ClusterConfig.max_timelines_history
ClusterConfig.modify_version
ClusterConfig.permanent_slots
ClusterConfig.version
Failover
Leader
Member
RemoteMember
ReturnFalseException
Status
SyncState
SyncState._asdict()
SyncState._field_defaults
SyncState._fields
SyncState._make()
SyncState._replace()
SyncState._str_to_list()
SyncState.empty()
SyncState.from_node()
SyncState.is_empty
SyncState.leader
SyncState.leader_matches()
SyncState.matches()
SyncState.members
SyncState.sync_standby
SyncState.version
TimelineHistory
catch_return_false_exception()
dcs_modules()
find_dcs_class_in_module()
get_dcs()
iter_dcs_classes()
parse_connection_string()
slot_name_from_member_name()
- patroni.postgresql package
- Submodules
- patroni.postgresql.bootstrap module
- patroni.postgresql.callback_executor module
- patroni.postgresql.cancellable module
- patroni.postgresql.citus module
- patroni.postgresql.config module
- patroni.postgresql.connection module
- patroni.postgresql.misc module
- patroni.postgresql.postmaster module
- patroni.postgresql.rewind module
- patroni.postgresql.slots module
- patroni.postgresql.sync module
- patroni.postgresql.validator module
- Module contents
- Submodules
- patroni.scripts package
- patroni.watchdog package
Submodules
- patroni.api module
- patroni.async_executor module
- patroni.collections module
- patroni.config module
- patroni.config_generator module
- patroni.ctl module
- patroni.daemon module
AbstractPatroniDaemon
AbstractPatroniDaemon.__init__()
AbstractPatroniDaemon._abc_impl
AbstractPatroniDaemon._run_cycle()
AbstractPatroniDaemon._shutdown()
AbstractPatroniDaemon.api_sigterm()
AbstractPatroniDaemon.received_sigterm
AbstractPatroniDaemon.reload_config()
AbstractPatroniDaemon.run()
AbstractPatroniDaemon.setup_signal_handlers()
AbstractPatroniDaemon.shutdown()
AbstractPatroniDaemon.sighup_handler()
AbstractPatroniDaemon.sigterm_handler()
abstract_main()
get_base_arg_parser()
- patroni.exceptions module
- patroni.file_perm module
__FilePermissions
__FilePermissions._FilePermissions__PG_DIR_MODE_GROUP
__FilePermissions._FilePermissions__PG_DIR_MODE_OWNER
__FilePermissions._FilePermissions__PG_FILE_MODE_GROUP
__FilePermissions._FilePermissions__PG_FILE_MODE_OWNER
__FilePermissions._FilePermissions__PG_MODE_MASK_GROUP
__FilePermissions._FilePermissions__PG_MODE_MASK_OWNER
__FilePermissions._FilePermissions__set_group_permissions()
__FilePermissions._FilePermissions__set_owner_permissions()
__FilePermissions._FilePermissions__set_umask()
__FilePermissions.__init__()
__FilePermissions.dir_create_mode
__FilePermissions.file_create_mode
__FilePermissions.set_permissions_from_data_directory()
- patroni.ha module
- patroni.log module
PatroniLogger
PatroniLogger.DEFAULT_FORMAT
PatroniLogger.DEFAULT_LEVEL
PatroniLogger.DEFAULT_MAX_QUEUE_SIZE
PatroniLogger.DEFAULT_TRACEBACK_LEVEL
PatroniLogger.LOGGING_BROKEN_EXIT_CODE
PatroniLogger.NORMAL_LOG_QUEUE_SIZE
PatroniLogger.__init__()
PatroniLogger._close_old_handlers()
PatroniLogger.queue_size
PatroniLogger.records_lost
PatroniLogger.reload_config()
PatroniLogger.run()
PatroniLogger.shutdown()
PatroniLogger.update_loggers()
ProxyHandler
QueueHandler
debug_exception()
error_exception()
- patroni.psycopg module
- patroni.raft_controller module
- patroni.request module
- patroni.tags module
- patroni.utils module
Retry
RetryFailedError
_sleep()
cluster_as_json()
compare_values()
convert_to_base_unit()
data_directory_is_empty()
deep_compare()
enable_keepalive()
get_major_version()
is_subpath()
iter_response_objects()
keepalive_intvl()
keepalive_socket_options()
parse_bool()
parse_int()
parse_real()
patch_config()
polling_loop()
read_stripped()
split_host_port()
strtod()
strtol()
unquote()
uri()
validate_directory()
- patroni.validator module
AtMostOne
BinDirectory
Case
Directory
EnumValidator
IntValidator
Optional
Or
Result
Schema
_get_type_name()
assert_()
comma_separated_host_port()
data_directory_empty()
get_bin_name()
is_ipv4_address()
is_ipv6_address()
validate_binary_name()
validate_connect_address()
validate_data_dir()
validate_host_port()
validate_host_port_list()
validate_host_port_listen()
validate_host_port_listen_multiple_hosts()
validate_watchdog_mode()
- patroni.version module
Module contents
Define general variables and functions for patroni
.
- var PATRONI_ENV_PREFIX:
prefix for Patroni related configuration environment variables.
- var KUBERNETES_ENV_PREFIX:
prefix for Kubernetes related configuration environment variables.
- var MIN_PSYCOPG2:
minimum version of
psycopg2
required by Patroni to work.- var MIN_PSYCOPG3:
minimum version of
psycopg
required by Patroni to work.
- patroni.parse_version(version: str) Tuple[int, ...] View on GitHub
Convert version from human-readable format to tuple of integers.
Note
Designed for easy comparison of software versions in Python.
- Parameters:
version – human-readable software version, e.g.
2.5.4.dev1 (dt dec pq3 ext lo64)
.- Returns:
tuple of version parts, each part as an integer.
- Example:
>>> parse_version('2.5.4.dev1 (dt dec pq3 ext lo64)') (2, 5, 4)