public static Options constructManagerOptions()

in uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/ManagerConf.java [404:439]
36 lines of code
1 McCabe index (conditional complexity)

  public static Options constructManagerOptions() {
    final Options managerOptions = new Options();
    managerOptions.addOption("help", false, "Help")
        .addOption("config", true, "Config file")
        .addOption("srcClusters", true, "Source cluster names for federated uReplicator")
        .addOption("destClusters", true, "Destination cluster names for federated uReplicator")
        .addOption("enableRebalance", true, "Enable rebalance when there is liveinstance change")
        .addOption("zookeeper", true, "Zookeeper path")
        .addOption("managerPort", true, "Manager port number")
        .addOption("deployment", true, "Manager deployment")
        .addOption("env", true, "Manager env")
        .addOption("instanceId", true, "InstanceId")
        .addOption("graphiteHost", true, "GraphiteHost")
        .addOption("graphitePort", true, "GraphitePort")
        .addOption("metricsPrefix", true, "MetricsPrefix")
        .addOption("graphiteReportFreqInSec", true, "Graphite report frequency in seconds")
        .addOption("enableJmxReport", true, "enable jmx report")
        .addOption("enableGraphiteReport", true, "enable graphite report")
        .addOption("c3Host", true, "Chaperone3 Host")
        .addOption("c3Port", true, "Chaperone3 Port")
        .addOption("clusterPrefixLength", true,
            "Cluster prefix length to extract route name from cluster name")
        .addOption("workloadRefreshPeriodInSeconds", true,
            "The period to refresh workload information in seconds")
        .addOption("initMaxNumPartitionsPerRoute", true,
            "The max number of partitions when init a route")
        .addOption("maxNumPartitionsPerRoute", true,
            "The max number of partitions a route can have")
        .addOption("initMaxNumWorkersPerRoute", true, "The max number of workers when init a route")
        .addOption("maxNumWorkersPerRoute", true, "The max number of workers a route can have")
        .addOption("bytesPerSecondDefault", true, "The default value for bytes per second")
        .addOption("msgsPerSecondDefault", true, "The default value for msgs per second")
        .addOption("updateStatusCoolDownMs", true,
            "The waiting period for next helix status check");
    return managerOptions;
  }