create continuous queries for wrap_count

Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/c5576109
Tree: 
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/c5576109
Diff: 
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/c5576109

Branch: refs/heads/master
Commit: c55761091baea2074d7c2ce45cbdfe66a5ed0473
Parents: f20a856
Author: Dave Neuman <neu...@apache.org>
Authored: Wed Oct 19 07:45:07 2016 -0600
Committer: Jeremy Mitchell <mitchell...@gmail.com>
Committed: Fri Oct 28 15:04:12 2016 -0600

----------------------------------------------------------------------
 traffic_stats/influxdb_tools/create_ts_databases.go | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/c5576109/traffic_stats/influxdb_tools/create_ts_databases.go
----------------------------------------------------------------------
diff --git a/traffic_stats/influxdb_tools/create_ts_databases.go 
b/traffic_stats/influxdb_tools/create_ts_databases.go
index 8e02220..e065b30 100644
--- a/traffic_stats/influxdb_tools/create_ts_databases.go
+++ b/traffic_stats/influxdb_tools/create_ts_databases.go
@@ -83,6 +83,8 @@ func createCacheStats(client influx.Client, replication 
*string) {
        createContinuousQuery(client, "connections_cdn_type_1min", `CREATE 
CONTINUOUS QUERY connections_cdn_type_1min ON cache_stats RESAMPLE FOR 5m BEGIN 
SELECT sum(value) AS "value" INTO 
"cache_stats"."monthly"."connections.cdn.type.1min" FROM 
"cache_stats"."monthly"."connections.1min" GROUP BY time(1m), cdn, type END`)
        createContinuousQuery(client, "maxKbps_1min", `CREATE CONTINUOUS QUERY 
maxKbps_1min ON cache_stats RESAMPLE FOR 2m BEGIN SELECT mean(value) AS value 
INTO cache_stats.monthly."maxkbps.1min" FROM cache_stats.daily.maxKbps GROUP BY 
time(1m), * END`)
        createContinuousQuery(client, "maxkbps_cdn_1min", `CREATE CONTINUOUS 
QUERY maxkbps_cdn_1min ON cache_stats RESAMPLE FOR 5m BEGIN SELECT sum(value) 
AS value INTO cache_stats.monthly."maxkbps.cdn.1min" FROM 
cache_stats.monthly."maxkbps.1min" GROUP BY time(1m), cdn END`)
+       createContinuousQuery(client, "wrap_count_vol1_1m", `CREATE CONTINUOUS 
QUERY wrap_count_vol1_1m ON cache_stats RESAMPLE FOR 2m BEGIN SELECT 
mean(value) AS vol1_wrap_count INTO cache_stats.monthly."wrap_count.1min" FROM 
cache_stats.daily."ats.proxy.process.cache.volume_1.wrap_count" GROUP BY 
time(1m), * END`)
+       createContinuousQuery(client, "wrap_count_vol2_1m", `CREATE CONTINUOUS 
QUERY wrap_count_vol2_1m ON cache_stats RESAMPLE FOR 2m BEGIN SELECT 
mean(value) AS vol2_wrap_count INTO cache_stats.monthly."wrap_count.1min" FROM 
cache_stats.daily."ats.proxy.process.cache.volume_2.wrap_count" GROUP BY 
time(1m), * END`)
 }
 
 func createDeliveryServiceStats(client influx.Client, replication *string) {

Reply via email to