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

oppiliappan spindle: use sqlite3 cursor store 1y ago

spindle: use sqlite3 cursor store Signed-off-by: oppiliappan <me@oppi.li>

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: use sqlite3 cursor store Signed-off-by: oppiliappan <me@oppi.li>

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