127 lines
		
	
	
		
			3.3 KiB
		
	
	
	
		
			Nix
		
	
	
	
	
	
			
		
		
	
	
			127 lines
		
	
	
		
			3.3 KiB
		
	
	
	
		
			Nix
		
	
	
	
	
	
{ config, lib, pkgs, ... }:
 | 
						|
 | 
						|
with lib;
 | 
						|
 | 
						|
let
 | 
						|
  cfg = config.services.mesos.master;
 | 
						|
 | 
						|
in {
 | 
						|
 | 
						|
  options.services.mesos = {
 | 
						|
 | 
						|
    master = {
 | 
						|
      enable = mkOption {
 | 
						|
        description = "Whether to enable the Mesos Master.";
 | 
						|
        default = false;
 | 
						|
        type = types.bool;
 | 
						|
      };
 | 
						|
 | 
						|
      ip = mkOption {
 | 
						|
        description = "IP address to listen on.";
 | 
						|
        default = "0.0.0.0";
 | 
						|
        type = types.str;
 | 
						|
      };
 | 
						|
 | 
						|
      port = mkOption {
 | 
						|
        description = "Mesos Master port";
 | 
						|
        default = 5050;
 | 
						|
        type = types.int;
 | 
						|
      };
 | 
						|
 | 
						|
      advertiseIp = mkOption {
 | 
						|
        description = "IP address advertised to reach this master.";
 | 
						|
        default = null;
 | 
						|
        type = types.nullOr types.str;
 | 
						|
      };
 | 
						|
 | 
						|
      advertisePort = mkOption {
 | 
						|
        description = "Port advertised to reach this Mesos master.";
 | 
						|
        default = null;
 | 
						|
        type = types.nullOr types.int;
 | 
						|
      };
 | 
						|
 | 
						|
      zk = mkOption {
 | 
						|
        description = ''
 | 
						|
          ZooKeeper URL (used for leader election amongst masters).
 | 
						|
          May be one of:
 | 
						|
            zk://host1:port1,host2:port2,.../mesos
 | 
						|
            zk://username:password@host1:port1,host2:port2,.../mesos
 | 
						|
        '';
 | 
						|
        type = types.str;
 | 
						|
      };
 | 
						|
 | 
						|
      workDir = mkOption {
 | 
						|
        description = "The Mesos work directory.";
 | 
						|
        default = "/var/lib/mesos/master";
 | 
						|
        type = types.str;
 | 
						|
      };
 | 
						|
 | 
						|
      extraCmdLineOptions = mkOption {
 | 
						|
        description = ''
 | 
						|
          Extra command line options for Mesos Master.
 | 
						|
 | 
						|
          See https://mesos.apache.org/documentation/latest/configuration/
 | 
						|
        '';
 | 
						|
        default = [ "" ];
 | 
						|
        type = types.listOf types.str;
 | 
						|
        example = [ "--credentials=VALUE" ];
 | 
						|
      };
 | 
						|
 | 
						|
      quorum = mkOption {
 | 
						|
        description = ''
 | 
						|
          The size of the quorum of replicas when using 'replicated_log' based
 | 
						|
          registry. It is imperative to set this value to be a majority of
 | 
						|
          masters i.e., quorum > (number of masters)/2.
 | 
						|
 | 
						|
          If 0 will fall back to --registry=in_memory.
 | 
						|
        '';
 | 
						|
        default = 0;
 | 
						|
        type = types.int;
 | 
						|
      };
 | 
						|
 | 
						|
      logLevel = mkOption {
 | 
						|
        description = ''
 | 
						|
          The logging level used. Possible values:
 | 
						|
            'INFO', 'WARNING', 'ERROR'
 | 
						|
        '';
 | 
						|
        default = "INFO";
 | 
						|
        type = types.str;
 | 
						|
      };
 | 
						|
 | 
						|
    };
 | 
						|
 | 
						|
 | 
						|
  };
 | 
						|
 | 
						|
 | 
						|
  config = mkIf cfg.enable {
 | 
						|
    systemd.services.mesos-master = {
 | 
						|
      description = "Mesos Master";
 | 
						|
      wantedBy = [ "multi-user.target" ];
 | 
						|
      after = [ "network.target" ];
 | 
						|
      serviceConfig = {
 | 
						|
        ExecStart = ''
 | 
						|
          ${pkgs.mesos}/bin/mesos-master \
 | 
						|
            --ip=${cfg.ip} \
 | 
						|
            --port=${toString cfg.port} \
 | 
						|
            ${optionalString (cfg.advertiseIp != null) "--advertise_ip=${cfg.advertiseIp}"} \
 | 
						|
            ${optionalString (cfg.advertisePort  != null) "--advertise_port=${toString cfg.advertisePort}"} \
 | 
						|
            ${if cfg.quorum == 0
 | 
						|
              then "--registry=in_memory"
 | 
						|
              else "--zk=${cfg.zk} --registry=replicated_log --quorum=${toString cfg.quorum}"} \
 | 
						|
            --work_dir=${cfg.workDir} \
 | 
						|
            --logging_level=${cfg.logLevel} \
 | 
						|
            ${toString cfg.extraCmdLineOptions}
 | 
						|
        '';
 | 
						|
        Restart = "on-failure";
 | 
						|
        PermissionsStartOnly = true;
 | 
						|
      };
 | 
						|
      preStart = ''
 | 
						|
        mkdir -m 0700 -p ${cfg.workDir}
 | 
						|
      '';
 | 
						|
    };
 | 
						|
  };
 | 
						|
 | 
						|
}
 | 
						|
 |