onyx.tasks.elasticsearch — curbside/onyx-elasticsearch 0.12.2.0-alpha3+writer

inject-writer clj

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

output clj

(output task-name opts)

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

writer-lifecycles clj