core/spindle/ at 5cd3fc39bdf0a176f2cfc68c6acb16f1b36b5db4 · 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 5cd3fc39bdf0a176f2cfc68c6acb16f1b36b5db4

Anirudh Oppiliappan spindle/engine: setup and destroy workflows 1y ago

spindle/engine: setup and destroy workflows During setup, we register cleanup functions which get executed at the end of the workflow goroutine (deferred exec of DestroyWorkflow). Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year ago

notifier: move package to top-level As it sees use in both spindle and knotserver. Signed-off-by: Anirudh Oppiliappan <anirudh@tangled.sh>

1 year ago

spindle/engine: setup and destroy workflows During setup, we register cleanup functions which get executed at the end of the workflow goroutine (deferred exec of DestroyWorkflow). 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: setup and destroy workflows During setup, we register cleanup functions which get executed at the end of the workflow goroutine (deferred exec of DestroyWorkflow). 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