Atlas Solr Collection Bootstrap

module.exports = headler: 'SolrCloud Ranger Layout', handler: ({options}) ->
  # migration: lucasbak 02112017
  # use this bootstrap scripts for every type
  return unless options.solr_type is 'external'
  protocol = if options.solr.cluster_config.ssl_enabled then 'https' else 'http'

Wait

  @connection.wait options.wait_solr

Collection Layout

  @file.download
    source: "#{__dirname}/../resources/solr/managed-schema"
    target: "#{options.solr.cluster_config.ranger_collection_dir}/managed-schema"
  @file.render
    source: "#{__dirname}/../resources/solr/solrconfig.xml.j2"
    target: "#{options.solr.cluster_config.ranger_collection_dir}/solrconfig.xml"
    local: true
    context: retention_period: options.audit_retention_period
  @file.download
    source: "#{__dirname}/../resources/solr/elevate.xml"
    target: "#{options.solr.cluster_config.ranger_collection_dir}/elevate.xml"
  @file.download
    source: "#{__dirname}/../resources/solr/elevate.xml"
    target: "#{options.solr.cluster_config.ranger_collection_dir}/elevate.xml"

Create Atlas Collection in Solr

  @call
    header: "Create ranger_audits collection"
    unless_exec: mkcmd.solr options.solr.cluster_config, """
      curl --fail --negotiate -k -u : \
      "#{protocol}://#{options.solr.cluster_config['master']}:#{options.solr.cluster_config['port']}/solr/admin/collections?action=LIST" | grep ranger_audits
    """
  , ->
    @system.execute
      cmd: mkcmd.solr options.solr.cluster_config, """
      #{options.solr_client_source}/server/scripts/cloud-scripts/zkcli.sh  \
      -zkhost #{options.solr.cluster_config.zk_connect} \
      -cmd upconfig \
      -confdir #{options.solr.cluster_config.ranger_collection_dir} \
      -confname ranger_audits
    """
    @system.execute
      cmd: mkcmd.solr options.solr.cluster_config, """
        curl --fail --negotiate -k -u : "#{protocol}://#{options.solr.cluster_config['master']}:#{options.solr.cluster_config['port']}/solr/#{getPath(options.solr.cluster_config.collection)}"
      """
    #equivalent to
    #curl  --negotiate -k -u : "http://docker01.metal.ryba8983/solr/admin/collections?action=CREATE&name=ranger_audits&numShards=3&replicationFactor=2&collection.configName=ranger_audits&maxShardsPerNode=2"

Zookeeper Znode ACL

  @system.execute
    header: 'Zookeeper SolrCloud Znode ACL'
    unless_exec: mkcmd.solr options.solr.cluster_config, """
    zookeeper-client -server #{options.solr.cluster_config.zk_connect} \
      getAcl #{options.solr.cluster_config.zk_node} | grep \"'sasl,'#{options.solr.cluster_config.user}\"
    """
    cmd: mkcmd.solr options.solr.cluster_config, """
    zookeeper-client -server #{options.solr.cluster_config.zk_connect} \
      setAcl #{options.solr.cluster_config.zk_node} sasl:#{options.solr.cluster_config.user}:cdrwa
    """

getPath = (opts) ->
  path = "admin/collections?action=CREATE"
  path += "&#{param}=#{opts[param]}" for param in [
    'name'
    'numShards'
    'replicationFactor'
    'collection.configName'
    'maxShardsPerNode'
    # 'createNodeSet'
  ]
  return path

Dependencies

mkcmd = require '../../lib/mkcmd'