Liking cljdoc? Tell your friends :D

ziggurat.middleware.default


deserialize-messageclj

(deserialize-message message proto-class topic-entity-name)
(deserialize-message message
                     proto-class
                     topic-entity-name
                     flatten-protobuf-struct?)

This function takes in the message(proto Byte Array) and the proto-class and deserializes the proto ByteArray into a Clojure PersistentHashMap. Temporary logic for migration of services to Ziggurat V3.0 If the message is of type map, the function just returns the map as it is. In older versions of Ziggurat (< 3.0) we stored the messages in deserialized formats in RabbitMQ and those messages can be processed by this function. So we have this logic here.

This function takes in the message(proto Byte Array) and the proto-class and deserializes the proto ByteArray into a
Clojure PersistentHashMap.
Temporary logic for migration of services to Ziggurat V3.0
  If the message is of type map, the function just returns the map as it is. In older versions of Ziggurat (< 3.0) we stored
  the messages in deserialized formats in RabbitMQ and those messages can be processed by this function. So we have this logic here.
sourceraw docstring

protobuf->hashclj

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

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

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

protobuf-struct->persistent-mapclj

(protobuf-struct->persistent-map struct)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close