X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/24b0d7526f2c2068955664eb592f82c827b01c07..620a85fdb0b9221dbbb32ef1366deded932c83e1:/lib/constants.py diff --git a/lib/constants.py b/lib/constants.py index c21a7f4..815e666 100644 --- a/lib/constants.py +++ b/lib/constants.py @@ -24,9 +24,11 @@ from ganeti import _autoconf # various versions -PROTOCOL_VERSION = 13 +PROTOCOL_VERSION = 20 RELEASE_VERSION = _autoconf.PACKAGE_VERSION -OS_API_VERSION = 10 +OS_API_V10 = 10 +OS_API_V15 = 15 +OS_API_VERSIONS = frozenset([OS_API_V10, OS_API_V15]) EXPORT_VERSION = 0 RAPI_VERSION = 2 @@ -95,32 +97,60 @@ SSCONF_LOCK_FILE = LOCK_DIR + "/ganeti-ssconf.lock" CLUSTER_CONF_FILE = DATA_DIR + "/config.data" SSL_CERT_FILE = DATA_DIR + "/server.pem" RAPI_CERT_FILE = DATA_DIR + "/rapi.pem" +HMAC_CLUSTER_KEY = DATA_DIR + "/hmac.key" WATCHER_STATEFILE = DATA_DIR + "/watcher.data" +WATCHER_PAUSEFILE = DATA_DIR + "/watcher.pause" +INSTANCE_UPFILE = RUN_GANETI_DIR + "/instance-status" SSH_KNOWN_HOSTS_FILE = DATA_DIR + "/known_hosts" RAPI_USERS_FILE = DATA_DIR + "/rapi_users" QUEUE_DIR = DATA_DIR + "/queue" ETC_HOSTS = "/etc/hosts" DEFAULT_FILE_STORAGE_DIR = _autoconf.FILE_STORAGE_DIR +SYSCONFDIR = _autoconf.SYSCONFDIR +TOOLSDIR = _autoconf.TOOLSDIR +CONF_DIR = SYSCONFDIR + "/ganeti" MASTER_SOCKET = SOCKET_DIR + "/ganeti-master" -# PID files -MASTERD_PID = "ganeti-masterd" -NODED_PID = "ganeti-noded" -RAPI_PID = "ganeti-rapi" +NODE_INITD_SCRIPT = SYSCONFDIR + "/init.d/ganeti" + +NODED = "ganeti-noded" +CONFD = "ganeti-confd" +RAPI = "ganeti-rapi" +MASTERD = "ganeti-masterd" + +MULTITHREADED_DAEMONS = frozenset([MASTERD]) + +DAEMONS_SSL = { + # daemon-name: (default-cert-path, default-key-path) + NODED: (SSL_CERT_FILE, SSL_CERT_FILE), + RAPI: (RAPI_CERT_FILE, RAPI_CERT_FILE), +} + +DAEMONS_PORTS = { + # daemon-name: ("proto", "default-port") + NODED: ("tcp", 1811), + CONFD: ("udp", 1814), + RAPI: ("tcp", 5080), +} +DEFAULT_NODED_PORT = DAEMONS_PORTS[NODED][1] +DEFAULT_CONFD_PORT = DAEMONS_PORTS[CONFD][1] +DEFAULT_RAPI_PORT = DAEMONS_PORTS[RAPI][1] -NODE_INITD_SCRIPT = _autoconf.SYSCONFDIR + "/init.d/ganeti" -DEFAULT_NODED_PORT = 1811 FIRST_DRBD_PORT = 11000 LAST_DRBD_PORT = 14999 MASTER_SCRIPT = "ganeti-master" LOG_DIR = _autoconf.LOCALSTATEDIR + "/log/ganeti/" +DAEMONS_LOGFILES = { + # "daemon-name": "logfile" + NODED: LOG_DIR + "node-daemon.log", + CONFD: LOG_DIR + "conf-daemon.log", + RAPI: LOG_DIR + "rapi-daemon.log", + MASTERD: LOG_DIR + "master-daemon.log", + } LOG_OS_DIR = LOG_DIR + "os" -LOG_NODESERVER = LOG_DIR + "node-daemon.log" LOG_WATCHER = LOG_DIR + "watcher.log" -LOG_MASTERDAEMON = LOG_DIR + "master-daemon.log" -LOG_RAPISERVER = LOG_DIR + "rapi-daemon.log" LOG_COMMANDS = LOG_DIR + "commands.log" LOG_BURNIN = LOG_DIR + "burnin.log" @@ -129,11 +159,13 @@ EXPORT_DIR = _autoconf.EXPORT_DIR EXPORT_CONF_FILE = "config.ini" +XEN_BOOTLOADER = _autoconf.XEN_BOOTLOADER XEN_KERNEL = _autoconf.XEN_KERNEL XEN_INITRD = _autoconf.XEN_INITRD KVM_PATH = _autoconf.KVM_PATH SOCAT_PATH = _autoconf.SOCAT_PATH +KVM_MIGRATION_PORT = _autoconf.KVM_MIGRATION_PORT VALUE_DEFAULT = "default" VALUE_AUTO = "auto" @@ -143,11 +175,11 @@ VALUE_TRUE = "true" VALUE_FALSE = "false" # hooks-related constants -HOOKS_BASE_DIR = _autoconf.SYSCONFDIR + "/ganeti/hooks" +HOOKS_BASE_DIR = CONF_DIR + "/hooks" HOOKS_PHASE_PRE = "pre" HOOKS_PHASE_POST = "post" HOOKS_NAME_CFGUPDATE = "config-update" -HOOKS_VERSION = 1 +HOOKS_VERSION = 2 # hooks subject type (what object type does the LU deal with) HTYPE_CLUSTER = "CLUSTER" @@ -158,6 +190,45 @@ HKR_SKIP = 0 HKR_FAIL = 1 HKR_SUCCESS = 2 +# Storage types +ST_FILE = "file" +ST_LVM_PV = "lvm-pv" +ST_LVM_VG = "lvm-vg" + +# Storage fields +# first two are valid in LU context only, not passed to backend +SF_NODE = "node" +SF_TYPE = "type" +# and the rest are valid in backend +SF_NAME = "name" +SF_SIZE = "size" +SF_FREE = "free" +SF_USED = "used" +SF_ALLOCATABLE = "allocatable" + +# Storage operations +SO_FIX_CONSISTENCY = "fix-consistency" + +# Available fields per storage type +VALID_STORAGE_FIELDS = frozenset([SF_NAME, SF_TYPE, SF_SIZE, + SF_USED, SF_FREE, SF_ALLOCATABLE]) + +VALID_STORAGE_TYPES = frozenset([ST_FILE, ST_LVM_PV, ST_LVM_VG]) + +MODIFIABLE_STORAGE_FIELDS = { + ST_LVM_PV: frozenset([SF_ALLOCATABLE]), + } + +VALID_STORAGE_OPERATIONS = { + ST_LVM_VG: frozenset([SO_FIX_CONSISTENCY]), + } + +# Local disk status +# Note: Code depends on LDS_OKAY < LDS_UNKNOWN < LDS_FAULTY +(LDS_OKAY, + LDS_UNKNOWN, + LDS_FAULTY) = range(1, 4) + # disk template types DT_DISKLESS = "diskless" DT_PLAIN = "plain" @@ -196,6 +267,7 @@ DISK_ACCESS_SET = frozenset([DISK_RDONLY, DISK_RDWR]) REPLACE_DISK_PRI = "replace_on_primary" # replace disks on primary REPLACE_DISK_SEC = "replace_on_secondary" # replace disks on secondary REPLACE_DISK_CHG = "replace_new_secondary" # change secondary node +REPLACE_DISK_AUTO = "replace_auto" # lock recalculate mode LOCKS_REPLACE = 'replace' @@ -222,9 +294,11 @@ DDM_REMOVE = 'remove' # common exit codes EXIT_SUCCESS = 0 EXIT_FAILURE = 1 +EXIT_NOTCLUSTER = 5 EXIT_NOTMASTER = 11 EXIT_NODESETUP_ERROR = 12 EXIT_CONFIRMATION = 13 # need user confirmation +EXIT_NOTCANDIDATE = 14 # tags TAG_CLUSTER = "cluster" @@ -242,13 +316,17 @@ GANETI_RUNAS = "root" DEFAULT_VG = "xenvg" BIND_ADDRESS_GLOBAL = "0.0.0.0" MIN_VG_SIZE = 20480 +DEFAULT_MAC_PREFIX = "aa:00:00" +LVM_STRIPECOUNT = _autoconf.LVM_STRIPECOUNT +# default maximum instance wait time, in seconds. +DEFAULT_SHUTDOWN_TIMEOUT = 120 + # RPC constants (RPC_ENCODING_NONE, RPC_ENCODING_ZLIB_BASE64) = range(2) # os related constants -OS_VALID_STATUS = "VALID" OS_SCRIPT_CREATE = 'create' OS_SCRIPT_IMPORT = 'import' OS_SCRIPT_EXPORT = 'export' @@ -256,6 +334,9 @@ OS_SCRIPT_RENAME = 'rename' OS_SCRIPTS = frozenset([OS_SCRIPT_CREATE, OS_SCRIPT_IMPORT, OS_SCRIPT_EXPORT, OS_SCRIPT_RENAME]) +OS_API_FILE = 'ganeti_api_version' +OS_VARIANTS_FILE = 'variants.list' + # ssh constants SSH_INITD_SCRIPT = _autoconf.SSH_INITD_SCRIPT SSH_CONFIG_DIR = "/etc/ssh/" @@ -275,66 +356,155 @@ REBOOT_TYPES = frozenset([INSTANCE_REBOOT_SOFT, INSTANCE_REBOOT_HARD, INSTANCE_REBOOT_FULL]) +VTYPE_STRING = 'string' +VTYPE_BOOL = 'bool' +VTYPE_SIZE = 'size' # size, in MiBs +VTYPE_INT = 'int' +ENFORCEABLE_TYPES = frozenset([ + VTYPE_STRING, + VTYPE_BOOL, + VTYPE_SIZE, + VTYPE_INT, + ]) + # HV parameter names (global namespace) HV_BOOT_ORDER = "boot_order" HV_CDROM_IMAGE_PATH = "cdrom_image_path" HV_NIC_TYPE = "nic_type" HV_DISK_TYPE = "disk_type" HV_VNC_BIND_ADDRESS = "vnc_bind_address" +HV_VNC_PASSWORD_FILE = "vnc_password_file" +HV_VNC_TLS = "vnc_tls" +HV_VNC_X509 = "vnc_x509_path" +HV_VNC_X509_VERIFY = "vnc_x509_verify" HV_ACPI = "acpi" HV_PAE = "pae" +HV_USE_BOOTLOADER = "use_bootloader" +HV_BOOTLOADER_ARGS = "bootloader_args" +HV_BOOTLOADER_PATH = "bootloader_path" +HV_KERNEL_ARGS = "kernel_args" HV_KERNEL_PATH = "kernel_path" HV_INITRD_PATH = "initrd_path" - -HVS_PARAMETERS = frozenset([ - HV_BOOT_ORDER, - HV_CDROM_IMAGE_PATH, - HV_NIC_TYPE, - HV_DISK_TYPE, - HV_VNC_BIND_ADDRESS, - HV_ACPI, - HV_PAE, - HV_KERNEL_PATH, - HV_INITRD_PATH, - ]) +HV_ROOT_PATH = "root_path" +HV_SERIAL_CONSOLE = "serial_console" +HV_USB_MOUSE = "usb_mouse" +HV_DEVICE_MODEL = "device_model" +HV_INIT_SCRIPT = "init_script" + +HVS_PARAMETER_TYPES = { + HV_BOOT_ORDER: VTYPE_STRING, + HV_CDROM_IMAGE_PATH: VTYPE_STRING, + HV_NIC_TYPE: VTYPE_STRING, + HV_DISK_TYPE: VTYPE_STRING, + HV_VNC_PASSWORD_FILE: VTYPE_STRING, + HV_VNC_BIND_ADDRESS: VTYPE_STRING, + HV_VNC_TLS: VTYPE_BOOL, + HV_VNC_X509: VTYPE_STRING, + HV_VNC_X509_VERIFY: VTYPE_BOOL, + HV_ACPI: VTYPE_BOOL, + HV_PAE: VTYPE_BOOL, + HV_USE_BOOTLOADER: VTYPE_BOOL, + HV_BOOTLOADER_PATH: VTYPE_STRING, + HV_BOOTLOADER_ARGS: VTYPE_STRING, + HV_KERNEL_PATH: VTYPE_STRING, + HV_KERNEL_ARGS: VTYPE_STRING, + HV_INITRD_PATH: VTYPE_STRING, + HV_ROOT_PATH: VTYPE_STRING, + HV_SERIAL_CONSOLE: VTYPE_BOOL, + HV_USB_MOUSE: VTYPE_STRING, + HV_DEVICE_MODEL: VTYPE_STRING, + HV_INIT_SCRIPT: VTYPE_STRING, + } + +HVS_PARAMETERS = frozenset(HVS_PARAMETER_TYPES.keys()) # BE parameter names BE_MEMORY = "memory" BE_VCPUS = "vcpus" BE_AUTO_BALANCE = "auto_balance" -BES_PARAMETERS = frozenset([ - BE_MEMORY, - BE_VCPUS, - BE_AUTO_BALANCE, - ]) +BES_PARAMETER_TYPES = { + BE_MEMORY: VTYPE_SIZE, + BE_VCPUS: VTYPE_INT, + BE_AUTO_BALANCE: VTYPE_BOOL, + } + +BES_PARAMETERS = frozenset(BES_PARAMETER_TYPES.keys()) + +# Instance Parameters Profile +PP_DEFAULT = "default" + +NIC_MODE = "mode" +NIC_LINK = "link" -# BE GROUP -BEGR_DEFAULT = "default" +NIC_MODE_BRIDGED = "bridged" +NIC_MODE_ROUTED = "routed" + +NIC_VALID_MODES = frozenset([NIC_MODE_BRIDGED, NIC_MODE_ROUTED]) + +NICS_PARAMETER_TYPES = { + NIC_MODE: VTYPE_STRING, + NIC_LINK: VTYPE_STRING, + } + +NICS_PARAMETERS = frozenset(NICS_PARAMETER_TYPES.keys()) # Hypervisor constants HT_XEN_PVM = "xen-pvm" HT_FAKE = "fake" HT_XEN_HVM = "xen-hvm" HT_KVM = "kvm" -HYPER_TYPES = frozenset([HT_XEN_PVM, HT_FAKE, HT_XEN_HVM, HT_KVM]) -HTS_REQ_PORT = frozenset([HT_XEN_HVM]) +HT_CHROOT = "chroot" +HYPER_TYPES = frozenset([HT_XEN_PVM, HT_FAKE, HT_XEN_HVM, HT_KVM, HT_CHROOT]) +HTS_REQ_PORT = frozenset([HT_XEN_HVM, HT_KVM]) -HT_HVM_VNC_BASE_PORT = 5900 -HT_HVM_DEFAULT_BOOT_ORDER = 'dc' -VNC_PASSWORD_FILE = _autoconf.SYSCONFDIR + "/ganeti/vnc-cluster-password" +VNC_BASE_PORT = 5900 +VNC_PASSWORD_FILE = CONF_DIR + "/vnc-cluster-password" VNC_DEFAULT_BIND_ADDRESS = '0.0.0.0' -# HVM NIC types -HT_HVM_NIC_RTL8139 = "rtl8139" -HT_HVM_NIC_NE2K_PCI = "ne2k_pci" -HT_HVM_NIC_NE2K_ISA = "ne2k_isa" -HT_HVM_DEV_PARAVIRTUAL = "paravirtual" -HT_HVM_DEV_IOEMU = "ioemu" -HT_HVM_VALID_NIC_TYPES = frozenset([HT_HVM_NIC_RTL8139, HT_HVM_NIC_NE2K_PCI, - HT_HVM_NIC_NE2K_ISA, - HT_HVM_DEV_PARAVIRTUAL]) -HT_HVM_VALID_DISK_TYPES = frozenset([HT_HVM_DEV_PARAVIRTUAL, HT_HVM_DEV_IOEMU]) +# NIC types +HT_NIC_RTL8139 = "rtl8139" +HT_NIC_NE2K_PCI = "ne2k_pci" +HT_NIC_NE2K_ISA = "ne2k_isa" +HT_NIC_I82551 = "i82551" +HT_NIC_I85557B = "i82557b" +HT_NIC_I8259ER = "i82559er" +HT_NIC_PCNET = "pcnet" +HT_NIC_E1000 = "e1000" +HT_NIC_PARAVIRTUAL = HT_DISK_PARAVIRTUAL = "paravirtual" + +HT_HVM_VALID_NIC_TYPES = frozenset([HT_NIC_RTL8139, HT_NIC_NE2K_PCI, + HT_NIC_NE2K_ISA, HT_NIC_PARAVIRTUAL]) +HT_KVM_VALID_NIC_TYPES = frozenset([HT_NIC_RTL8139, HT_NIC_NE2K_PCI, + HT_NIC_NE2K_ISA, HT_NIC_I82551, + HT_NIC_I85557B, HT_NIC_I8259ER, + HT_NIC_PCNET, HT_NIC_E1000, + HT_NIC_PARAVIRTUAL]) +# Disk types +HT_DISK_IOEMU = "ioemu" +HT_DISK_IDE = "ide" +HT_DISK_SCSI = "scsi" +HT_DISK_SD = "sd" +HT_DISK_MTD = "mtd" +HT_DISK_PFLASH = "pflash" + +HT_HVM_VALID_DISK_TYPES = frozenset([HT_DISK_PARAVIRTUAL, HT_DISK_IOEMU]) +HT_KVM_VALID_DISK_TYPES = frozenset([HT_DISK_PARAVIRTUAL, HT_DISK_IDE, + HT_DISK_SCSI, HT_DISK_SD, HT_DISK_MTD, + HT_DISK_PFLASH]) + +# Mouse types: +HT_MOUSE_MOUSE = "mouse" +HT_MOUSE_TABLET = "tablet" + +HT_KVM_VALID_MOUSE_TYPES = frozenset([HT_MOUSE_MOUSE, HT_MOUSE_TABLET]) + +# Boot order +HT_BO_CDROM = "cdrom" +HT_BO_DISK = "disk" +HT_BO_NETWORK = "network" + +HT_KVM_VALID_BO_TYPES = frozenset([HT_BO_CDROM, HT_BO_DISK, HT_BO_NETWORK]) # Cluster Verify steps VERIFY_NPLUSONE_MEM = 'nplusone_mem' @@ -350,16 +520,16 @@ NV_NODELIST = "nodelist" NV_NODENETTEST = "node-net-test" NV_VERSION = "version" NV_VGLIST = "vglist" +NV_DRBDLIST = "drbd-list" +NV_NODESETUP = "nodesetup" # Allocator framework constants +IALLOCATOR_VERSION = 2 IALLOCATOR_DIR_IN = "in" IALLOCATOR_DIR_OUT = "out" IALLOCATOR_MODE_ALLOC = "allocate" IALLOCATOR_MODE_RELOC = "relocate" IALLOCATOR_SEARCH_PATH = _autoconf.IALLOCATOR_SEARCH_PATH -IARUN_NOTFOUND = 1 -IARUN_FAILURE = 2 -IARUN_SUCCESS = 3 # Job queue JOB_QUEUE_VERSION = 1 @@ -385,67 +555,190 @@ JOB_STATUS_CANCELED = "canceled" JOB_STATUS_SUCCESS = "success" JOB_STATUS_ERROR = "error" +# OpCode status +# not yet finalized OP_STATUS_QUEUED = "queued" OP_STATUS_WAITLOCK = "waiting" OP_STATUS_CANCELING = "canceling" OP_STATUS_RUNNING = "running" +# finalized OP_STATUS_CANCELED = "canceled" OP_STATUS_SUCCESS = "success" OP_STATUS_ERROR = "error" +OPS_FINALIZED = frozenset([OP_STATUS_CANCELED, + OP_STATUS_SUCCESS, + OP_STATUS_ERROR]) # Execution log types ELOG_MESSAGE = "message" ELOG_PROGRESS = "progress" -# Temporary RAPI constants until we have cluster parameters -RAPI_ENABLE = True -RAPI_PORT = 5080 - -# max dynamnic devices +# max dynamic devices MAX_NICS = 8 MAX_DISKS = 16 # SSCONF keys SS_CLUSTER_NAME = "cluster_name" +SS_CLUSTER_TAGS = "cluster_tags" SS_FILE_STORAGE_DIR = "file_storage_dir" SS_MASTER_CANDIDATES = "master_candidates" +SS_MASTER_CANDIDATES_IPS = "master_candidates_ips" SS_MASTER_IP = "master_ip" SS_MASTER_NETDEV = "master_netdev" SS_MASTER_NODE = "master_node" SS_NODE_LIST = "node_list" +SS_NODE_PRIMARY_IPS = "node_primary_ips" +SS_NODE_SECONDARY_IPS = "node_secondary_ips" SS_OFFLINE_NODES = "offline_nodes" +SS_ONLINE_NODES = "online_nodes" +SS_INSTANCE_LIST = "instance_list" SS_RELEASE_VERSION = "release_version" # cluster wide default parameters DEFAULT_ENABLED_HYPERVISOR = HT_XEN_PVM HVC_DEFAULTS = { - HT_XEN_PVM: { - HV_KERNEL_PATH: "/boot/vmlinuz-2.6-xenU", - HV_INITRD_PATH: None, - }, - HT_XEN_HVM: { - HV_BOOT_ORDER: "cd", - HV_CDROM_IMAGE_PATH: None, - HV_NIC_TYPE: HT_HVM_NIC_RTL8139, - HV_DISK_TYPE: HT_HVM_DEV_PARAVIRTUAL, - HV_VNC_BIND_ADDRESS: '0.0.0.0', - HV_ACPI: True, - HV_PAE: True, - }, - HT_KVM: { - HV_KERNEL_PATH: "/boot/vmlinuz-2.6-kvmU", - HV_INITRD_PATH: None, - HV_ACPI: True, - }, - HT_FAKE: { - }, - } + HT_XEN_PVM: { + HV_USE_BOOTLOADER: False, + HV_BOOTLOADER_PATH: XEN_BOOTLOADER, + HV_BOOTLOADER_ARGS: '', + HV_KERNEL_PATH: "/boot/vmlinuz-2.6-xenU", + HV_INITRD_PATH: '', + HV_ROOT_PATH: '/dev/sda1', + HV_KERNEL_ARGS: 'ro', + }, + HT_XEN_HVM: { + HV_BOOT_ORDER: "cd", + HV_CDROM_IMAGE_PATH: '', + HV_NIC_TYPE: HT_NIC_RTL8139, + HV_DISK_TYPE: HT_DISK_PARAVIRTUAL, + HV_VNC_BIND_ADDRESS: '0.0.0.0', + HV_VNC_PASSWORD_FILE: VNC_PASSWORD_FILE, + HV_ACPI: True, + HV_PAE: True, + HV_KERNEL_PATH: "/usr/lib/xen/boot/hvmloader", + HV_DEVICE_MODEL: "/usr/lib/xen/bin/qemu-dm", + }, + HT_KVM: { + HV_KERNEL_PATH: "/boot/vmlinuz-2.6-kvmU", + HV_INITRD_PATH: '', + HV_KERNEL_ARGS: 'ro', + HV_ROOT_PATH: '/dev/vda1', + HV_ACPI: True, + HV_SERIAL_CONSOLE: True, + HV_VNC_BIND_ADDRESS: '', + HV_VNC_TLS: False, + HV_VNC_X509: '', + HV_VNC_X509_VERIFY: False, + HV_VNC_PASSWORD_FILE: '', + HV_CDROM_IMAGE_PATH: '', + HV_BOOT_ORDER: HT_BO_DISK, + HV_NIC_TYPE: HT_NIC_PARAVIRTUAL, + HV_DISK_TYPE: HT_DISK_PARAVIRTUAL, + HV_USB_MOUSE: '', + }, + HT_FAKE: { + }, + HT_CHROOT: { + HV_INIT_SCRIPT: "/ganeti-chroot", + }, + } BEC_DEFAULTS = { - BE_MEMORY: 128, - BE_VCPUS: 1, - BE_AUTO_BALANCE: True, - } + BE_MEMORY: 128, + BE_VCPUS: 1, + BE_AUTO_BALANCE: True, + } + +NICC_DEFAULTS = { + NIC_MODE: NIC_MODE_BRIDGED, + NIC_LINK: DEFAULT_BRIDGE, + } MASTER_POOL_SIZE_DEFAULT = 10 + +CONFD_PROTOCOL_VERSION = 1 + +CONFD_REQ_PING = 0 +CONFD_REQ_NODE_ROLE_BYNAME = 1 +CONFD_REQ_NODE_PIP_BY_INSTANCE_IP = 2 +CONFD_REQ_CLUSTER_MASTER = 3 +CONFD_REQ_NODE_PIP_LIST = 4 +CONFD_REQ_MC_PIP_LIST = 5 +CONFD_REQ_INSTANCES_IPS_LIST = 6 + +# Confd request query fields. These are used to narrow down queries. +# These must be strings rather than integers, because json-encoding +# converts them to strings anyway, as they're used as dict-keys. +CONFD_REQQ_LINK = "0" +CONFD_REQQ_IP = "1" +CONFD_REQQ_IPLIST = "2" + +CONFD_REQS = frozenset([ + CONFD_REQ_PING, + CONFD_REQ_NODE_ROLE_BYNAME, + CONFD_REQ_NODE_PIP_BY_INSTANCE_IP, + CONFD_REQ_CLUSTER_MASTER, + CONFD_REQ_NODE_PIP_LIST, + CONFD_REQ_MC_PIP_LIST, + CONFD_REQ_INSTANCES_IPS_LIST, + ]) + +CONFD_REPL_STATUS_OK = 0 +CONFD_REPL_STATUS_ERROR = 1 +CONFD_REPL_STATUS_NOTIMPLEMENTED = 2 + +CONFD_REPL_STATUSES = frozenset([ + CONFD_REPL_STATUS_OK, + CONFD_REPL_STATUS_ERROR, + CONFD_REPL_STATUS_NOTIMPLEMENTED, + ]) + +(CONFD_NODE_ROLE_MASTER, + CONFD_NODE_ROLE_CANDIDATE, + CONFD_NODE_ROLE_OFFLINE, + CONFD_NODE_ROLE_DRAINED, + CONFD_NODE_ROLE_REGULAR, + ) = range(5) + +# A few common errors for confd +CONFD_ERROR_UNKNOWN_ENTRY = 1 +CONFD_ERROR_INTERNAL = 2 +CONFD_ERROR_ARGUMENT = 3 + +# Each request is "salted" by the current timestamp. +# This constants decides how many seconds of skew to accept. +# TODO: make this a default and allow the value to be more configurable +CONFD_MAX_CLOCK_SKEW = 300 + +# When we haven't reloaded the config for more than this amount of seconds, we +# force a test to see if inotify is betraying us. +CONFD_CONFIG_RELOAD_TIMEOUT = 60 + +# If we receive more than one update in this amount of seconds, we move to +# polling every RATELIMIT seconds, rather than relying on inotify, to be able +# to serve more requests. +CONFD_CONFIG_RELOAD_RATELIMIT = 2 + +# Magic number prepended to all confd queries. +# This allows us to distinguish different types of confd protocols and handle +# them. For example by changing this we can move the whole payload to be +# compressed, or move away from json. +CONFD_MAGIC_FOURCC = 'plj0' + +# By default a confd request is sent to the minimum between this number and all +# MCs. 6 was chosen because even in the case of a disastrous 50% response rate, +# we should have enough answers to be able to compare more than one. +CONFD_DEFAULT_REQ_COVERAGE = 6 + +# Timeout in seconds to expire pending query request in the confd client +# library. We don't actually expect any answer more than 10 seconds after we +# sent a request. +CONFD_CLIENT_EXPIRE_TIMEOUT = 10 + +# Maximum UDP datagram size. +# On IPv4: 64K - 20 (ip header size) - 8 (udp header size) = 65507 +# On IPv6: 64K - 40 (ip6 header size) - 8 (udp header size) = 65487 +# (assuming we can't use jumbo frames) +# We just set this to 60K, which should be enough +MAX_UDP_DATA_SIZE = 61440