Module: InfluxDB::Query::RetentionPolicy

Included in:
Client
Defined in:
lib/influxdb/query/retention_policy.rb

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

#alter_retention_policy(name, database, duration, replication, default = false) ⇒ Object 



26
27
28
29
30
31
 
# File 'lib/influxdb/query/retention_policy.rb', line 26

def alter_retention_policy(name, database, duration, replication, default = false)
  execute(
    "ALTER RETENTION POLICY \"#{name}\" ON #{database} " \
    "DURATION #{duration} REPLICATION #{replication}#{default ? ' DEFAULT' : ''}"
  )
end

#create_retention_policy(name, database, duration, replication, default = false) ⇒ Object 



4
5
6
7
8
9
 
# File 'lib/influxdb/query/retention_policy.rb', line 4

def create_retention_policy(name, database, duration, replication, default = false)
  execute(
    "CREATE RETENTION POLICY \"#{name}\" ON #{database} " \
    "DURATION #{duration} REPLICATION #{replication}#{default ? ' DEFAULT' : ''}"
  )
end

#delete_retention_policy(name, database) ⇒ Object 



22
23
24
 
# File 'lib/influxdb/query/retention_policy.rb', line 22

def delete_retention_policy(name, database)
  execute("DROP RETENTION POLICY \"#{name}\" ON #{database}")
end

#list_retention_policies(database) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
 
# File 'lib/influxdb/query/retention_policy.rb', line 11

def list_retention_policies(database)
  resp = execute("SHOW RETENTION POLICIES ON \"#{database}\"", parse: true)
  data = fetch_series(resp).fetch(0)

  data['values'.freeze].map do |policy|
    policy.each.with_index.inject({}) do |hash, (value, index)|
      hash.tap { |h| h[data['columns'.freeze][index]] = value }
    end
  end
end