core/spindle/ at c3b287b10e3551efbb0a5072bcb635e53d3cd315 · alice.pds.demo.boltless.dev/core · Tangled

alice.pds.demo.boltless.dev / core

0

This repository has no description

0

core / spindle

4 folders 3 files

at c3b287b10e3551efbb0a5072bcb635e53d3cd315

Anirudh Oppiliappan spindle/queue: enqueue pipeline jobs 1y ago

spindle/queue: enqueue pipeline jobs Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year ago

spindle/{db,engine}: rework db to use rkey Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year 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

spindle/queue: enqueue pipeline jobs Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year ago

spindle/queue: enqueue pipeline jobs Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year 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

spindle/{db,engine}: rework db to use rkey Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year ago