robertluo.waterfall.shape — io.github.robertluo/waterfall 0.1.35

Transformation functions of shapes of event data.

deserializer clj

(deserializer shapes)

returns a deserializer function which composes shapes, will be called in the reverse order of serializer, so the shapes argument can be shared. e.g. [(edn) (value-only)]

edn clj

(edn)

A shape converts string/edn.

key-value clj

(key-value f)

(key-value f g)

A shape concerns both the key and value of the Kafka event. When serializing a value, f will apply to the value, the return will be the key of the event. When deserializing a value, optional function g will apply to the key and value pari of the event. Default is identity.

nippy clj

(nippy)

A shape that direct maps data/bytes

schema clj

schema for shapes

serializer clj

(serializer shapes)

returns a serializer function which composes shapes, make sure to put the last step (like value-only) to the last. e.g. [(edn) (value-only)]

shape? clj

(shape? x)

predict if x is a shape

shapes clj

(shapes top-shapes)

(shapes top-shapes bytes-shape)

(shapes top-shapes bytes-shape kv-shape)

construct shapes in order.

topic clj

(topic f-topic)

A shape attach topic to record on serilization, do nothing when deserilizing.

• f-topic: function take data (records with :key and :value), returns a string of topic name.

transit clj

(transit format)

A shape that direct maps data/bytes.

• format: transit supporting format, one of :msgpack, :json, :json-verbose.

value-only clj

(value-only)

A shape concerns just value of the Kafka event.