c165157afdbdb907983822ce941932b06f1ba95e
1 import { dirname
, extname
, join
} from
'node:path'
2 import { fileURLToPath
} from
'node:url'
4 import { availableParallelism
, FixedClusterPool
} from
'poolifier'
6 import type { WorkerData
, WorkerResponse
} from
'./types.js'
8 const workerFile
= join(
9 dirname(fileURLToPath(import.meta
.url
)),
10 `worker${extname(fileURLToPath(import.meta.url))}`
13 const pool
= new FixedClusterPool
<WorkerData
, WorkerResponse
>(
14 availableParallelism(),
18 onlineHandler
: () => {
20 .execute({ port
: 8080 })
22 if (response
.status) {
24 `Fastify is listening in cluster worker on port ${response.port}`
30 console
.error('Fastify failed to start in cluster worker:', error
)
33 errorHandler
: (e
: Error) => {
34 console
.error('Cluster worker error:', e
)