Browse Source

Initial commit and basic class structure

pull/3/head
Brett Langdon 14 years ago
parent
commit
1859bdd331
3 changed files with 120 additions and 1 deletions
  1. +5
    -1
      .gitignore
  2. +95
    -0
      lib/index.js
  3. +20
    -0
      package.json

+ 5
- 1
.gitignore View File

@ -12,4 +12,8 @@ logs
results
node_modules
npm-debug.log
npm-debug.log
*#*#
*~

+ 95
- 0
lib/index.js View File

@ -0,0 +1,95 @@
var ee2 = require('eventemitter2').EventEmitter2;
var net = require('net');
var util = require('util');
var kestrel = function( options ){
this._settings = {
//port: 22133,
//host: '127.0.0.1'
}
if( options instanceof Object ){
for( var key in options ){
if( this._settings[key] != undefined ){
this._settings[key] = options[key];
}
}
}
ee2.call(this);
}
util.inherits(kestrel,ee2);
kestrel.prototype.connect = function(){
//open connections to kestrel server(s)
}
kestrel.prototype.close = function(){
//close any open connections
}
kestrel.prototype.set = function( queue, value, lifetime ){
if( lifetime == undefined || lieftime == null ){
lifetime = 0;
}
var command = "SET " + queue + " 0 " + lifetime + " ";
command += value.length + "\r\n" + value + "\r\n";
//send SET command
}
kestrel.prototype.get = function(queue, timeout){
var command = "GET " + queue;
timeout = parseInt(timeout);
if( timeout > 0 ){
command += "/t="+timeout;
}
//send GET command
}
kestrel.prototype.delete = function(queue){
//delete given queue
}
kestrel.prototype.flush = function(queue){
//flush given queue
}
kestrel.prototype.flushAll = function(){
//flush all queues
}
kestrel.prototype.version = function(){
//get version of server
}
kestrel.prototype.shutdown = function(){
//shutdown server
}
kestrel.prototype.reload = function(){
//reload the server
}
kestrel.prototype.stats = function(){
//get server stats
}
kestrel.prototype.dumpStats = function(){
//dump server stats
}
kestrel.prototype.monitor = function(queue, seconds, maxItems){
//monitor the given queue
}
kestrel.prototype.confirm = function(queue, count){
//confirm received items
}
module.exports = kestrel;

+ 20
- 0
package.json View File

@ -0,0 +1,20 @@
{
"name": "kestrel"
, "version": "0.0.1"
, "description": "Kestrel client module for NodeJS"
, "homepage": "http://www.blangdon.com/"
, "keywords": ["kestrel", "client", "messaging", "queue"]
, "author": "brett_langdon <brett@blangdon.com>"
, "contributors": [
{ "name": "brett_langdon", "email": "brett@blangdon.com" }
]
, "repository":{
"type": "git"
, "url": "github.com/brettlangdon/node-kestrel.git"
}
, "dependencies": {
"eventemitter2": ">=0.4.9"
}
, "main": "./lib/index.js"
, "engines": { "node": ">= 0.6.0" }
}

Loading…
Cancel
Save