Liking cljdoc? Tell your friends :D
Clojure only.
salt.client.events
eventsclj
(events client-atom cancel-chan resp-chan recv-buffer-size)Subscribe with sse-subs-chan and deliver saltstack events in resp-chan.
Channel will deliver:
- Exception if error occurs
- Parsed SSE events
If you want to stop and close resp-chan, put whatever value to cancel-chan
If error occurs, this events stream is not stopped (unsubscibed), but continue
listening to events. This causes [[salt.client/sse]] to retry connection again,
if it fails again, another error is delivered and so on.
This behavior is needed to inform events consumers, there is an error on
underlining saltstack events stream.
events recv channel does not use buffer, because it does not block or park and passes all messages to resp-chan.
See salt.client/client for more details.
Subscribe with `sse-subs-chan` and deliver saltstack events in resp-chan. Channel will deliver: - Exception if error occurs - Parsed SSE events If you want to stop and close resp-chan, put whatever value to `cancel-chan` If error occurs, this events stream is not stopped (unsubscibed), but continue listening to events. This causes [[`salt.client/sse`]] to retry connection again, if it fails again, another error is delivered and so on. This behavior is needed to inform events consumers, there is an error on underlining saltstack events stream. events recv channel does not use buffer, because it does not block or park and passes all messages to resp-chan. See [[salt.client/client]] for more details.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close