app

func CreateApp ¶

func CreateApp() (app *fiber.App)

func NewStreamJobForTests ¶

func NewStreamJobForTests(prefix, owner string) *streamJob

NewStreamJobForTests exposes the internal stream job constructor to test suites.

func NewTeardownJobForTests ¶

func NewTeardownJobForTests(owner, compID string) *teardownJob

NewTeardownJobForTests creates a teardown job without side effects for unit tests.

func StartApp ¶

func StartApp() (err error)

func StreamJobErrorf ¶

func StreamJobErrorf(job *streamJob, format string, args ...any)

StreamJobErrorf writes an error message to the stream job.

func StreamJobStatus ¶

func StreamJobStatus(job *streamJob, message string)

StreamJobStatus writes a status message to the stream job.

func StreamJobStatusf ¶

func StreamJobStatusf(job *streamJob, format string, args ...any)

StreamJobStatusf formats a status message for the stream job.

func StreamJobSuccessf ¶

func StreamJobSuccessf(job *streamJob, format string, args ...any)

StreamJobSuccessf writes a success message to the stream job.

func TestStreamJobMarkDone ¶

func TestStreamJobMarkDone(job *streamJob)

TestStreamJobMarkDone finalizes the stream job in tests.

func TestStreamJobSubscribe ¶

func TestStreamJobSubscribe(job *streamJob) chan string

TestStreamJobSubscribe exposes the internal subscribe helper for tests.

func TestStreamJobUnsubscribe ¶

func TestStreamJobUnsubscribe(job *streamJob, ch chan string)

TestStreamJobUnsubscribe exposes the internal unsubscribe helper for tests.

func TestTeardownJobMarkDone ¶

func TestTeardownJobMarkDone(job *teardownJob)

TestTeardownJobMarkDone finalizes the teardown job stream.

func TestTeardownJobRemove ¶

func TestTeardownJobRemove(job *teardownJob)

TestTeardownJobRemove removes the job from the registry.

func TestTeardownJobSubscribe ¶

func TestTeardownJobSubscribe(job *teardownJob) chan string

TestTeardownJobSubscribe exposes subscribe for teardown jobs.

func TestTeardownJobUnsubscribe ¶

func TestTeardownJobUnsubscribe(job *teardownJob, ch chan string)

TestTeardownJobUnsubscribe exposes unsubscribe for teardown jobs.