Function createRuntimeNodeLivenessProbe

projects/runtime-node/src/liveness.ts:64–126

()

}

export function createRuntimeNodeLivenessProbe(): RuntimeLivenessProbe {
    return {
        probe(runtime: RuntimeRecord): RuntimeLivenessProbeResult {
            const pid = runtime.pid
            if (!Number.isInteger(pid) || !pid || pid <= 0) {
                return { state: "unknown", reason: "Runtime has no process id" }
            }

            const state = pidState(pid)
            if (state.state !== "alive") return state

            let verifiedByProcessGroup = false
            const pgid = runtime.pgid
            if (process.platform !== "win32" && Number.isInteger(pgid) && pgid && pgid > 0) {
                const groupState = processGroupState(pgid)
                if (groupState.state === "dead") return { state: "unknown", reason: `Process ${pid} is alive but expected process group ${pgid} is not` }
                if (groupState.state === "alive") verifiedByProcessGroup = true
            }

            let verifiedByLabel = false
            if (runtime.processLabel) {
                const command = commandForPid(pid)
                if (!command) {
                    return {
                        state: "unknown",
                        reason: `Process ${pid} is alive but command identity could not be verified`,
                    }
                }
                if (command && !commandMatchesLabel(command, runtime.processLabel)) {
                    return {
                        state: "unknown",
                        reason: `Process ${pid} is alive but does not match expected runtime label`,
                    }
                }
                verifiedByLabel = true
            }

            let verifiedByStartTime = false
            if (runtime.processStartedAt) {
                const actualStartedAt = startedAtForPid(pid)
                if (!actualStartedAt) {
                    return {
                        state: "unknown",
                        reason: `Process ${pid} is alive but start time could not be verified`,
                    }
                }
                if (actualStartedAt && !processStartedAtMatches(runtime.processStartedAt, actualStartedAt)) {
                    return {
                        state: "unknown",
                        reason: `Process ${pid} is alive but started at ${actualStartedAt}, not ${runtime.processStartedAt}`,
                    }
                }
                verifiedByStartTime = true
            }

            return {
                state: "alive",
                verified: verifiedByProcessGroup || verifiedByLabel || verifiedByStartTime,