Skip to main content

ForkParentLogger

@webda/workout

Class: ForkParentLogger

Defined in: packages/workout/src/fork.ts:11

Logger that forwards all messages to the parent process via IPC Used internally by Fork() to enable logging from forked child processes

Extends​

  • WorkerLogger

Constructors​

Constructor​

new ForkParentLogger(output, level?): ForkParentLogger

Defined in: packages/workout/src/loggers/index.ts:26

Create a new logger instance

The effective log level is resolved as:

  1. Async-local override from useLogLevel (if active)
  2. The level parameter (string or function)
  3. process.env.LOG_LEVEL or "INFO" as fallback

Parameters​

output​

WorkerOutput

The WorkerOutput to listen to

level?​

WorkerLogLevel | (() => WorkerLogLevel)

Log level as string or function (defaults to process.env.LOG_LEVEL or "INFO")

Returns​

ForkParentLogger

Inherited from​

WorkerLogger.constructor

Properties​

pending​

pending: number = 0

Defined in: packages/workout/src/fork.ts:13

Number of pending messages being sent to parent process

Methods​

flush()​

flush(timeout?): Promise<void>

Defined in: packages/workout/src/fork.ts:35

Wait for all pending messages to be sent to the parent process

Parameters​

timeout?​

number = 30000

Maximum time to wait in milliseconds (default: 30000)

Returns​

Promise<void>

Promise that resolves when all messages are sent or rejects on timeout

onMessage()​

onMessage(msg): void

Defined in: packages/workout/src/fork.ts:19

Send a log message to the parent process via process.send()

Parameters​

msg​

WorkerMessage

The message to forward to the parent process

Returns​

void

Overrides​

WorkerLogger.onMessage