Gusto

Micro service library

Gusto is a simple micro service library.

Needs node version > 5.00 to work.

TODO. Add more message transport layers.

Add a better pattern matching transport that supports nested objects.

Documentation, more examples...

listen to all messages

'use strict'

const _gusto = require('gusto');
const gusto  = new _gusto();

gusto.connect('global_message_bus', () => {

    gusto.tap('*', (err, message) => {

        // listen to all messages
        console.log(message);
    });
});

listen for a paticular micro service

'use strict'

const _gusto = require('gusto');
const gusto  = new _gusto();

gusto.connect('global_message_bus', () => {

    gusto.tap('{ math: "*" }', (err, message) => {

        // listen to all messages from the math micro service.
        console.log(message);
    });
});

// the math microservice would emit messages like this:

gusto.emit({
    math: {
        result: some_operation(...operands)
    }
});

another example

'use strict'

const _gusto = require('gusto');
const gusto  = new _gusto();

gusto.connect('global_message_bus', () => {
    
    gusto.tap('{ demo: "*" }', (err, message) => {
        if(err) console.log(err);
        let parse    = message.demo.cmd;
        let _parse   = parse.split(':');
        let left_op  = _parse[1].split('_')[0];
        let right_op = _parse[1].split('_')[1];
        let result = parseInt(left_op) + parseInt(right_op);
        gusto.emit({
            math: {
                result: result,
                timestamp: new Date().toISOString()
            }
        });
    });
});

setInterval(()=>{
    let left_op  = Math.floor(Math.random()*11)+5;
    let right_op = Math.floor(Math.random()*11)+5;
    let command  = `add:${left_op}_${right_op}`;
    gusto.emit({
        demo: {
            cmd: command,
            timestamp: new Date().toISOString()
        }
    });
}, 5000);

gusto.tap('*', (err, message) => {
    console.log('[monitor] ', message);
    /*
    [example output]
        [monitor]  { demo: { cmd: 'add:9_5' } }
        [monitor]  { math: { result: 14 } }
        [monitor]  { demo: { cmd: 'add:6_11' } }
        [monitor]  { math: { result: 17 } }
    */
})

setTimeout(() => {
    console.log('Thanks for trying Gusto!');
    process.exit(0);
}, 45000);