milena.interop — dvlopt/milena 0.4.0-alpha3

Miscellaneous interop utilities.

config clj

(config config nodes)

Given a Kakfa configuration map, stringifies keys and adds Kafka nodes.

Cf. https://kafka.apache.org/documentation/#configuration

config-key clj

(config-key k)

config-prefixed-key clj

(config-prefixed-key k)

future-proxy clj

(future-proxy f* transform)

Given a future, makes a future returning (transform @f*) on deref.

keywordize-keys clj

(keywordize-keys hmap)

Stringifies string keys in a map.

named? clj

(named? x)

Is x an instance of Named ?

nodes-string clj

(nodes-string nodes)

Produces a string of Kafka nodes for various configurations.

@ nodes List of [host port] representing Kafka nodes.

Ex. (nodes-string [["localhost" 9092] ["another_host" 9092]])

regex? clj

(regex? x)

Is x a regular expression ?

stringify-keys clj

(stringify-keys hmap)

Stringifies keys in a map.

In case of a named key, takes into account only the name and not the namespace.

stringify-prefixed-keys clj

(stringify-prefixed-keys hmap)

Stringifies keys in a map.

In case of a named key, takes into account the namespace for prefixing the name as needed.

Cf. config-prefixed-key