cloudwatch.js

module.exports = function (service) {
    var aws = require ('aws-lib');
    cw = aws.createCWClient(service.from.id, service.from.secret);
    var now = new Date,
        start = new Date(now.getTime() - 1 * 60 * 1000); // 1 min ago

    return function(funneler) {
        for (var serviceName in service.services) {
            var thisService = service.services[serviceName];
            (function (serviceName, thisService) {
                cw.call(
                    "GetMetricStatistics",
                    {
                        EndTime: now.toISOString(),
                        StartTime: start.toISOString(),
                        Namespace: thisService.namespace,
                        MetricName: thisService.metric,
                        'Statistics.member.1': thisService.type,
                        'Dimensions.member.1.Name': thisService.name,
                        'Dimensions.member.1.Value': thisService.value,
                        Unit: thisService.unit,
                        Period: 60,
                    },
                    function(err, result) {
                        funneler({
                            'funnel': 'cloudwatch',
                            'nodeName': thisService.value,
                            'metricName': serviceName,
                            'reading': result.GetMetricStatisticsResult.Datapoints.member[thisService.type]
                        });
                    }
                );
            })(serviceName, thisService);
        }
    }
};