salt.client.async — clj-salt-api 1.0.3-SNAPSHOT

handle-response clj

(handle-response {:keys [:command] :as op} response)

Handles response of command. Called after command has been executed and response has been received. This function just dispatches handler based on operation command and returns new operation with new command

initial-op clj

(initial-op req correlation-id recv-chan)

Create initial operation. Minion timeout is same computed from saltstack client timeout setting. See https://docs.saltstack.com/en/latest/ref/clients/index.html#salt.client.LocalClient.

master-clients clj

parse-job-returns clj

(parse-job-returns {:keys [:minions] :as op} returns)

Remove returned minions from set of expecting minions and store :last-receive-time.

request-async clj

(request-async client-atom req async-resp-chan recv-buffer-size)

Subscribe with :sse-subs-chan, invoke async client request and deliver responses in resp-chan.

This function uses salt.client.request/request to call async client. Channel will deliver:

• Exception if error occurs
• Parsed SSE events

This function implements best practices for working with salt-api as defined in https://docs.saltstack.com/en/latest/ref/netapi/all/salt.netapi.rest_cherrypy.html#best-practices Channel is closed after all minions return or master returns (in case of runner ane wheel). See salt.client/client for configuration options.