@forrestjs/service-postgres-pubsub NPM | npm.io

4.7.2 • Published 3 years ago

Install

Weekly downloads

25

License

MIT

Repository

Last release

3 years ago

@forrestjs/service-postgres-pubsub

🚧 DEPRECATED 🚧 service-pg-pubsub will come soon!

This service leverages a Postgres database to implement a pub/sub mechanism that can scale across multiple instances of a web service.

It implements node-pg-pubsub that is a library that works just fine.

Usage

import { addChannel, publish, once } from '@forrestjs/service-postgres-pubsub'

// create a persistent channel, the return value is a function that
// you can call to cleanup the subscription
const removeChannel = addChannel('channelName', msh => {
    console.log('channel was called with', msh)
});

// you do not need to cleanup this, it's going to be fired just once
once('channelName', () => { ... })

publish('channelName', { some: 'data' })
// -> expect the console log here

All the methods above take a 3rd argument called connectionName that allows to target a specific Postgres instance in case your app is connected to multiple ones.

Configuration

You can provide multiple Postgres connections, they should be identified by a connectionName property. If omitted it's going to be default.

registerAction({
  hook: SETTINGS,
  name: '♦ boot',
  handler: async ({ settings }) => {
    settings.postgresPubsub = [
      {
        connectionName: 'default',
        host: config.get('PG_HOST'),
        port: config.get('PG_PORT'),
        database: config.get('PG_DATABASE'),
        username: config.get('PG_USERNAME'),
        password: config.get('PG_PASSWORD'),
      },
    ];
  },
});

forrestjs service postgres pubsub pg

@babel/runtime @fetchq/pg-pubsub @forrestjs/core

@infinitebrahmanuniverse/nolb-_forr @everything-registry/sub-chunk-338 @forrestjs/package-express @forrestjs/package-fastify @forrestjs/package-universal @zalastax/nolb-_forr

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

3.21.0-3.21.0-alpha.2.0

4 years ago

3.21.0-alpha.3.0

4 years ago

3.21.0-alpha.3.1

4 years ago

3.21.0-alpha.3.2

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago

6 years ago