Module: Influxer::TimeQuery

Included in:
Relation
Defined in:
lib/influxer/metrics/relation/time_query.rb

Overview

:nodoc:

Constant Summary collapse

TIME_ALIASES = 
{
  hour: "1h",
  minute: "1m",
  second: "1s",
  ms: "1ms",
  u: "1u",
  week: "1w",
  day: "1d",
  month: "30d",
  year: "365d"
}.freeze
FILL_RESERVED = 
i[null previous none].freeze

Instance Method Summary collapse

Instance Method Details

#past(val) ⇒ Object

Shortcut to define time interval with regard to current time. Accepts symbols and numbers.

Metrics.past(:hour)
# select * from metrics where time > now() - 1h

Metrics.past(:d)
# select * from metrics where time > now() - 1d

Metrics.past(2.days)
# select * from metrics where time > now() - 172800s



51
52
53
54
55
56
57
58
59
60
 
# File 'lib/influxer/metrics/relation/time_query.rb', line 51

def past(val)
  case val
  when Symbol
    where("time > now() - #{TIME_ALIASES[val] || ("1" + val.to_s)}")
  when String
    where("time > now() - #{val}")
  else
    where("time > now() - #{val.to_i}s")
  end
end

#since(val) ⇒ Object

Shortcut to define start point of the time interval. Accepts DateTime objects.

Metrics.since(1.day.ago) # assume that now is 2014-12-31 12:00:00 UTC
# select * from metrics where time > 1420027200s

Metrics.since(Time.local(2014,12,31))
# select * from metrics where time > 1419984000s



71
72
73
 
# File 'lib/influxer/metrics/relation/time_query.rb', line 71

def since(val)
  where("time > #{val.to_i}s")
end

#time(val, options = {}) ⇒ Object

Add group value to relation. To be used instead of ‘group(“time(…)”). Accepts symbols and strings.

You can set fill value within options.

Metrics.time(:hour)
# select * from metrics group by time(1h)

Metrics.time("4d", fill: 0)
# select * from metrics group by time(4d) fill(0)



29
30
31
32
33
34
35
36
37
38
 
# File 'lib/influxer/metrics/relation/time_query.rb', line 29

def time(val, options = {})
  @values[:time] = if val.is_a?(Symbol)
    TIME_ALIASES[val] || "1" + val.to_s
  else
    val
  end

  build_fill(options[:fill])
  self
end