onyx.tasks.elasticsearch — curbside/onyx-elasticsearch 0.13.0

inject-writer clj

(inject-writer {{user :elasticsearch/user
                 :or {mapping-type :_default_ write-type :index}
                 mapping-type :elasticsearch/mapping-type
                 index :elasticsearch/index
                 password :elasticsearch/password
                 bulk :elasticsearch/bulk
                 host :elasticsearch/host
                 id :elasticsearch/id
                 write-type :elasticsearch/write-type}
                  :onyx.core/task-map}
               _)

output clj

(output task-name opts)

Inputs: [task-name :- s/Keyword opts]

writer-lifecycles clj