def getEnterpriseControllerConfigData()

in nuvolaris/enterprise_util.py [0:0]

• 48 lines of code
• 34 McCabe index (conditional complexity)

def getEnterpriseControllerConfigData():
    data = {
        "name":"controller",
        "couchdb_host": cfg.get("couchdb.host") or "couchdb",
        "couchdb_port": cfg.get("couchdb.port") or "5984",
        "couchdb_admin_user": cfg.get("couchdb.admin.user"),
        "couchdb_admin_password": cfg.get("couchdb.admin.password"),
        "couchdb_controller_user": cfg.get("couchdb.controller.user"),
        "couchdb_controller_password": cfg.get("couchdb.controller.password"),
        "couchdb_invoker_user": cfg.get("couchdb.invoker.user"),
        "couchdb_invoker_password": cfg.get("couchdb.invoker.password"),        
        "triggers_fires_perMinute": cfg.get("configs.limits.triggers.fires-perMinute") or 999,
        "actions_sequence_maxLength": cfg.get("configs.limits.actions.sequence-maxLength") or 50,
        "actions_invokes_perMinute": cfg.get("configs.limits.actions.invokes-perMinute") or 999,
        "actions_invokes_concurrent": cfg.get("configs.limits.actions.invokes-concurrent") or 250,
        "activation_payload_max": cfg.get('configs.limits.activations.max_allowed_payload') or "1048576",
        "time_limit_min": cfg.get("configs.limits.time.limit-min") or "100ms", 
        "time_limit_std": cfg.get("configs.limits.time.limit-std") or "1min", 
        "time_limit_max": cfg.get("configs.limits.time.limit-max") or "5min", 
        "memory_limit_min": cfg.get("configs.limits.memory.limit-min") or "128m", 
        "memory_limit_std": cfg.get("configs.limits.memory.limit-std") or "256m", 
        "memory_limit_max": cfg.get("configs.limits.memory.limit-max") or "512m", 
        "concurrency_limit_min": cfg.get("configs.limits.concurrency.limit-min") or 1, 
        "concurrency_limit_std": cfg.get("configs.limits.concurrency.limit-std") or 1, 
        "concurrency_limit_max": cfg.get("configs.limits.concurrency.limit-max") or 1,
        "loadbalancer_blackbox_fraction": cfg.get("configs.limits.loadbalancer.blackbox-fraction") or "10%",
        "loadbalancer_timeout_factor": cfg.get("configs.limits.loadbalancer.timeout-factor") or "2",
        "controller_host": cfg.get("controller.host") or "localhost",
        "controller_port": cfg.get("controller.port") or "3233",
        "controller_protocol": cfg.get("controller.protocol") or "http",
        "invoker_host": cfg.get("invoker.host") or "localhost",
        "invoker_port": cfg.get("invoker.port") or "8080",
        "invoker_protocol": cfg.get("invoker.protocol") or "http",        
        "kafka_host": cfg.get("nuvolaris.kafka.url") or  "kafka:9092",
        "zookeeper_url": cfg.get('nuvolaris.zookeeper.url') or "zookeeper-0.zookeeper:2181",
        "controller_java_opts": cfg.get('configs.controller.javaOpts') or "-Xmx1024M",
        "controller_logging_level": cfg.get('configs.controller.loggingLevel') or "INFO",
        "controller_replicas": cfg.get('configs.controller.replicas') or 1,
        "container_cpu_req": cfg.get('configs.controller.resources.cpu-req') or "1",
        "container_cpu_lim": cfg.get('configs.controller.resources.cpu-lim') or "2",
        "container_mem_req": cfg.get('configs.controller.resources.mem-req') or "1G",
        "container_mem_lim": cfg.get('configs.controller.resources.mem-lim') or "2G",
        "container_manage_resources": cfg.exists('configs.controller.resources.cpu-req')      
    }
    
    util.get_controller_image_data(data)
    get_invoker_image_data(data)
    enterprise_affinity_tolerations_data(data)    
    return data