class InfluxdbSetup::CreateRetentionPolicy
Public Instance Methods
call()
click to toggle source
# File lib/influxdb_setup/create_retention_policy.rb, line 3 def call retention_policies = @config.retention_policies return if retention_policies.nil? db = @config.db_name root = @config.build_client rcs = root.list_retention_policies(db).map { |row| row["name"] } retention_policies.each do |rc| if rcs.include? rc['name'] root.alter_retention_policy(rc['name'], db, rc['duration'], rc['replication']) else root.create_retention_policy(rc['name'], db, rc['duration'], rc['replication']) end end end