io.randomseed.utils.bus — io.randomseed/utils 1.0.7

Random utils, inter-thread bus.

close clj

(close wrk)

config clj

(config wid)

(config workers wid)

control-channel clj

(control-channel wrk)

current-ns-str clj

data-channel clj

(data-channel wrk)

empty-outcome clj

empty-reply clj

get-command clj

(get-command wrk)

get-data clj

(get-data wrk)

get-result clj

(get-result wrk)

handle-command clj

(handle-command wrk f)

handle-request clj

(handle-request wrk req f & handler-args)

id-request->response clj

(id-request->response wrk req id)

(id-request->response wrk req id & args)

Sends a blocking request and waits for any response.

list-workers clj

(list-workers)

(list-workers workers)

new-control-channel clj

(new-control-channel)

new-data-channel clj

(new-data-channel)

new-outcome clj

(new-outcome)

(new-outcome req)

(new-outcome req res)

(new-outcome req res data)

Used to wrap the outcome of request handling and to convert the output to the Outcome object.

new-reply clj

(new-reply)

(new-reply body)

(new-reply body data)

Used to enrich the output of a handling function so it can return both: response body and additional data.

new-request clj

(new-request wrk req)

(new-request wrk req id & args)

new-response clj

(new-response wrk res)

(new-response wrk res req)

(new-response wrk res req id)

new-worker clj

(new-worker w id config f)

(new-worker w id config f multi?)

new-worker! clj

(new-worker! id config f)

(new-worker! workers id config f)

new-worker-with-wid clj

(new-worker-with-wid w id config f multi?)

Outcome clj

outcome? clj

(outcome? v)

process-request clj

(process-request wrk f & args)

Receives a request from the control channel and calls a handler f on worker object, request and args provided. Blocks on receiving (waits for data) and on sending (waits for the channel to have some space for a new message).

If the handler function returns nil or :io.randomseed.utils.bus/no-response, the response should not be created and the returned value is an empty Outcome object.

If the handler returns a Reply object, the response should be generated even if its :body field is nil. This is helpful in cases where nil responses are required.

If the handler returns a Reply object but its :body is set to :io.randomseed.utils.bus/no-response then no response will be generated and the response in the returned Outcome object will be set to nil.

Otherwise an Outcome object will be returned with :request, :response and :data fields.

put-command clj

(put-command wrk msg)

put-data clj

(put-data wrk msg)

receive-request clj

(receive-request wrk)

receive-response clj

(receive-response wrk)

remove-worker clj

(remove-worker workers wrk)

remove-worker! clj

(remove-worker! wrk)

(remove-worker! wrokers wrk)

Reply clj

reply? clj

(reply? v)

Request clj

request->response clj

(request->response wrk req)

(request->response wrk req & args)

Sends a blocking request and waits for any response.

request? clj

(request? v)

Response clj

response? clj

(response? v)

send-id-request clj

(send-id-request wrk req id)

(send-id-request wrk req id & args)

send-request clj

(send-request wrk req)

(send-request wrk req & args)

send-response clj

(send-response wrk res)

(send-response wrk res req)

(send-response wrk res req id & args)

start-worker clj

(start-worker id config f & args)

stop-worker clj

(stop-worker wrk)

(stop-worker wrk msg-or-fn)

try-process-request clj

(try-process-request wrk f & args)

Receives a request from the control channel and calls a handler f on worker object, request and args provided. Does not block on receiving (returns immediately when there is no data on the control channel and blocks on sending (waits for the channel to have some space for a new message).

If the handler function returns nil or :io.randomseed.utils.bus/no-response, the response should not be created and the returned value is an empty Outcome object.

If the handler returns a Reply object, the response should be generated even if its :body field is nil. This is helpful in cases where nil responses are required.

If the handler returns a Reply object but its :body is set to :io.randomseed.utils.bus/no-response then no response will be generated and the response in the returned Outcome object will be set to nil.

Otherwise an Outcome object will be returned with :request, :response and :data fields.

try-put-command clj

(try-put-command wrk msg)

try-put-data clj

(try-put-data wrk msg)

try-send-id-request clj

(try-send-id-request wrk req id)

(try-send-id-request wrk req id & args)

try-send-request clj

(try-send-request wrk req)

(try-send-request wrk req & args)

try-send-response clj

(try-send-response wrk res)

(try-send-response wrk res req)

(try-send-response wrk res req id & args)

update-config clj

(update-config workers wrk f & args)

update-config! clj

(update-config! & args)

update-worker clj

(update-worker workers wrk)

(update-worker workers wrk f & args)

update-worker! clj

(update-worker! & args)

wait-for-command clj

(wait-for-command wrk)

wait-for-data clj

(wait-for-data wrk)

wait-for-request clj

(wait-for-request wrk)

wait-for-response clj

(wait-for-response wrk)

wait-for-result clj

(wait-for-result wrk)

Worker clj

worker clj

(worker v)

(worker workers v)

worker-exists? clj

(worker-exists? v)

(worker-exists? workers v)

worker-id clj

(worker-id v)

worker? clj

(worker? v)

Workers clj

workers clj

workers? clj

(workers? v)