clj-nakadi-java.core — me.dryewo/clj-nakadi-java 0.0.8

->camel-case clj

(->camel-case kebab)

->raw-event-stream-config clj

(->raw-event-stream-config event-type-or-stream-config)

->subscription-stream-config clj

(->subscription-stream-config config-map)

Converts a hash-map to an instance of StreamConfiguration. Keys which do not correspond to variables of StreamConfiguration are ignored.

consume-raw-events clj

(consume-raw-events client event-type-or-stream-config callback)

consume-subscription clj multimethod

Starts consuming a subscription. Config can be either a string, a map, or an instance of StreamConfiguration. Strings and maps are internally converted to instances of StreamConfiguration. In case config is a map, its keys must correspond to the variables of StreamConfiguration. In case config is a string, it must be the subscription id.

make-client clj

(make-client nakadi-url get-token-fn)

make-observer-provider clj

(make-observer-provider callback)

make-token-provider clj

(make-token-provider get-token-fn)

method-exists? clj

(method-exists? method)

publish-events clj

(publish-events client event-type events)

set-param clj

(set-param streamConfigInstance k v)

str-invoke clj

(str-invoke instance method-str & args)