diff --git a/lib/influxdb/query/continuous_query.rb b/lib/influxdb/query/continuous_query.rb index f8421db..ae6e1fb 100644 --- a/lib/influxdb/query/continuous_query.rb +++ b/lib/influxdb/query/continuous_query.rb @@ -10,13 +10,13 @@ def list_continuous_queries(database) .map { |v| { 'name' => v.first, 'query' => v.last } } end - def create_continuous_query(name, database, query, resample_every: nil, resample_for: nil) + def create_continuous_query(name, database, query, options = {}) clause = ["CREATE CONTINUOUS QUERY", name, "ON", database] - if resample_every || resample_for + if options[:resample_every] || options[:resample_for] clause << "RESAMPLE" - clause << "EVERY #{resample_every}" if resample_every - clause << "FOR #{resample_for}" if resample_for + clause << "EVERY #{options[:resample_every]}" if options[:resample_every] + clause << "FOR #{options[:resample_for]}" if options[:resample_for] end clause = clause.join(" ") << " BEGIN\n" << query << "\nEND"