@kree4js/dse

Distributed Service Events for Kree4JS.

Event-driven service framework enabling services to emit and consume events through the Kree4JS transport layer.

Installation

npm install @kree4js/dse

Quick Start

import { enableDse } from '@kree4js/dse'
import { create } from '@kree4js/kree4n'

// Create a node and enable DSE on it
const node = enableDse(create('event-producer', 'Event Producer'))

// Register a service that emits events
node.register('sensor', {
  read() {
    this.emit('data', { temperature: 25.3 })
    return { temperature: 25.3 }
  }
})

await node.listen('tcp://0.0.0.0:9000')

Consume events

import { enableDse } from '@kree4js/dse'
import { create } from '@kree4js/kree4n'

const node = enableDse(create('event-consumer', 'Event Consumer'))
node.attach('tcp://sensor-host:9000')

const sensor = node.eventService('sensor')
sensor.on('data', (event) => {
  console.log('Temperature:', event.temperature)
})

License

Apache-2.0