hive-datascript.swarm.coordination.coordinator — io.github.hive-agi/hive-datascript 0.1.1

get-all-coordinators clj

(get-all-coordinators)

Get all coordinators.

Returns: Seq of maps with coordinator attributes

get-coordinator clj

(get-coordinator coordinator-id)

Get a coordinator by ID.

Returns: Map with coordinator attributes or nil if not found

get-coordinators-by-status clj

(get-coordinators-by-status status)

Get coordinators filtered by status.

Arguments: status - Status to filter by (:active :stale :terminated)

Returns: Seq of coordinator maps

get-coordinators-for-project clj

(get-coordinators-for-project project)

Get all coordinators for a specific project.

Arguments: project - Project identifier

Returns: Seq of coordinator maps

mark-coordinator-stale! clj

(mark-coordinator-stale! coordinator-id)

Mark a coordinator as stale (not responding).

Arguments: coordinator-id - Coordinator to mark

Returns: Transaction report or nil if coordinator not found

mark-coordinator-terminated! clj

(mark-coordinator-terminated! coordinator-id)

Mark a coordinator as terminated (graceful shutdown).

Arguments: coordinator-id - Coordinator to mark

Returns: Transaction report or nil if coordinator not found

register-coordinator! clj

(register-coordinator! coordinator-id {:keys [project pid session-id]})

Register a new coordinator instance.

Arguments: coordinator-id - Unique identifier (required) opts - Map with optional keys: :project - Project identifier :pid - OS process ID (default: current JVM PID) :session-id - Session UUID (default: auto-generated)

Returns: Transaction report with :tempids

remove-coordinator! clj

(remove-coordinator! coordinator-id)

Remove a coordinator entity. Should only be used for cleanup after graceful termination.

Arguments: coordinator-id - Coordinator to remove

Returns: Transaction report or nil if coordinator not found

update-heartbeat! clj

(update-heartbeat! coordinator-id)

Update a coordinator's heartbeat timestamp. Also ensures status is :active (reactivates stale coordinators).

Arguments: coordinator-id - Coordinator to update

Returns: Transaction report or nil if coordinator not found