monkey.ci.dispatcher.events — com.monkeyci/app 0.16.8

add-build-task clj

Adds a task for the build found in the incoming event

add-job-task clj

Adds a task for the job found in the incoming event

add-runner-assignment clj

Interceptor that assigns a runner to the task stored in context

add-to-queued-list clj

Interceptor that adds a queued task to the in-memory list in the state.

assignment clj

(assignment runner task)

build->task clj

(build->task b)

build-queued clj

(build-queued ctx)

clear-assignment clj

(clear-assignment prop)

consume-resources clj

Updates state to consume resources according to scheduled task

default-resources clj

delete-queued clj

If the result contains deleted queue items, this interceptor will remove them from the database.

evt-sid clj

get-assignment clj

get-queued clj

get-queued-list clj

(get-queued-list ctx)

get-runners clj

(get-runners ctx)

get-state-assignment clj

(get-state-assignment ctx id)

get-task clj

get-task-sid clj multimethod

job->task clj

(job->task job sid)

job-queued clj

(job-queued ctx)

load-assignment clj

(load-assignment prop)

make-routes clj

(make-routes state storage)

Makes mailman routes for event handling that perform actual dispatching and resource management.

release-resources clj

Same as consume, but releases the used resources instead

remove-state-assignment clj

(remove-state-assignment ctx id)

result->assignment clj

Replaces the assignment in the context with the one from the result

result->queue clj

Updates the queue with values from the result

save-assignment clj

(save-assignment prop)

save-queued clj

Interceptor that saves a queued task. These are tasks that could not be assigned immediately due to lack of resources.

set-assignment clj

(set-assignment ctx a)

set-queued clj

(set-queued ctx task)

set-runners clj

(set-runners ctx r)

set-state-assignment clj

(set-state-assignment ctx id a)

set-task clj

(set-task ctx a)

task-end clj

(task-end ctx)

When a build ends, resources become available again. This means we may be able to schedule another task from the queue. If so, we assign it here, and remove that task from the queue. Since the released resources belong to a specific runner, we can only assign the task to that runner.

task-scheduled-evt clj multimethod

unwrap-events clj

Takes the :events key from the result and puts that in the result instead.

update-runner clj

(update-runner ctx id f & args)

with-resources clj