burningswell.worker.weather.models — burningswell/worker 0.2.4

-main clj

(-main & args)

Publish commands to update the data sources of the weather models.

build-topology clj

(build-topology {:keys [db config] :as app} builder)

Build the Kafka Streams topology.

cli-config clj

(cli-config env)

client clj

(client {:keys [db producer] :as config})

Returns a client for the weather model worker.

config clj

(config & [opts])

Returns the configuration for the app.

insert-datasources! clj

(insert-datasources! db {:keys [datasources] :as model})

Update the data sources of model.

run clj

(run {:keys [producer db] :as system} & args)

Run the client of the weather model worker.

update-latest-reference-time! clj

(update-latest-reference-time! db {:keys [datasources] :as model})

Update the latest reference time of model.

update-model! clj

(update-model! db model)

Update the data sources and the latest reference time of model.

worker clj

(worker & [opts])

Returns a new weather model worker.