| var through = require('through'); | |
| // pure js vertica driver. im not into the coffee script but this is so useful even i domnt hold it against them | |
| var vertica = require('vertica'); | |
| var stream = through(); | |
| // | |
| // pipe some bar delimited rows of data to your stream. | |
| // until you call stream.end() the data will not commit. | |
| // because you can use logical streams rather than "real" streams.. | |
| // .. you can break a job up simply by ending the stream and starting another copy command .. |
| var level = require('levelup') | |
| , db = level('./streamtest.db') | |
| var dbws = db.createWriteStream() | |
| , c = 0 | |
| , start = Date.now() | |
| , intervalCount = 0 | |
| , bytes = 0 | |
| , paused = false |
| // do series or exactly N parallel its the same | |
| var c = jobs.length | |
| , job = function(){ | |
| doThing(function(){ | |
| next() | |
| }) | |
| }, next = function(){ | |
| c--; | |
| if(!c) done(); | |
| else job() |
| // write a log file! | |
| file = open(logname,'a+'); | |
| file.write("log line!\n"); | |
| // stringify json | |
| import json | |
| json.dumps("hi"); | |
| process.stdin.pipe(require('line-stream')()).pipe(require('through')(function(line){ | |
| // do analysis on a line | |
| })).pipe(process.stdout) |
| var levelup = require('level') | |
| var zlib = require('zlib') | |
| var fs = require('fs') | |
| var through = require('through') | |
| //hot backup | |
| db = levelup(...) | |
| var backingup = false |
| { | |
| "name": "multilevel-end-test", | |
| "description": "analyze end behavior", | |
| "version": "0.0.0", | |
| "repository": { | |
| "url": "git@gist.github.com:6034011" | |
| }, | |
| "main": "index.js", | |
| "scripts": { | |
| "test": "tape test/*.js" |
| sudo npm install -g npm | |
| npm http GET https://registry.npmjs.org/npm | |
| npm ERR! cb() never called! | |
| npm ERR! not ok code 0 |
| var through = require('through') | |
| module.exports = function(chain){ | |
| chain = chain(); | |
| var s = through(function(data){ | |
| if(!chain.write(data)) this.pause(); | |
| }); | |
| chain.on('drain',function(){ | |
| s.resume(); | |
| }) |
i've exposed quite a few stats in my procfs-stats module. now i need to be able to make use of the data!
###poll-stream
###subtract-values-stream