@psyqueue/plugin-grpc-workers

gRPC worker transport for PsyQueue. Distribute job processing to remote workers over gRPC.

Installation

npm install @psyqueue/plugin-grpc-workers

Usage

import { grpcWorkers } from '@psyqueue/plugin-grpc-workers'

q.use(grpcWorkers({
  port: 50051,
  auth: true,
  tokens: ['worker-token-abc'],
  queues: ['email.send'],
}))

Configuration

| Option | Type | Default | Description | |--------|------|---------|-------------| | port | number | required | gRPC server port | | auth | boolean | - | Enable token authentication | | tokens | string[] | - | Allowed worker tokens | | queues | string[] | - | Restrict accessible queues |

Exports

• grpcWorkers(opts) -- Plugin factory
• GrpcWorkerServer -- Server class

Documentation

See Transport Plugins for detailed usage.

License

MIT