core/spindle/engine/ at 7f7d89ac561f40993247a710c8ce3b5892df4cc0 · alice.pds.demo.boltless.dev/core · Tangled

alice.pds.demo.boltless.dev / core

0

This repository has no description

0

core / spindle / engine

1 file

at 7f7d89ac561f40993247a710c8ce3b5892df4cc0

Anirudh Oppiliappan spindle/engine: stream logs to websocket 1y ago

spindle/engine: stream logs to websocket Logs are streamed for each running pipeline on a websocket at /logs/{pipelineID}. engine.TailStep demuxes stdout and stderr from the container's logs and pipes that out to corresponding stdout and stderr channels. These channels are maintained inside engine's container struct, key'd by the pipeline ID, and protected by a read/write mutex. engine.LogChannels fetches the stdout/stderr chans as recieve-only if the pipeline is known to exist. Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year ago