ziggurat.middleware.default — tech.gojek/ziggurat 3.3.1-alpha.2

Deserializable clj protocol

deserialize clj

(deserialize message proto-class topic-entity-name)

protobuf->hash clj

(protobuf->hash handler-fn proto-class topic-entity-name)

This is a middleware function that takes in a message (Proto ByteArray or PersistentHashMap) and calls the handler-fn with the deserialized PersistentHashMap

RegularMessage clj

StreamJoinsMessage clj