rp.jackdaw.serdes.homogeneous-edn
Implements an EDN SerDe (Serializer/Deserializer). While the native jackdaw EDN SerDe fulfills most purposes, in order for the RentPath Kafka Connect EdnConverter (https://search.maven.org/artifact/com.rentpath/kafka-connect-converters/0.1.1/jar) to infer the requisite schema from the data itself, said data must conform to a series of further rules above and beyond those normally associated with the EDN specification; namely, that all compound data structures be consistent, their elements homogeneous in both type and structure. This SerDe exists to provide an (optional) means of validating these additional requirements, so as to ensure that no data from which a schema may not be autoderived (and thus unable to be sunk) is produced to any Kafka topic that is intended for Kafka Connect sinking.
Implements an EDN SerDe (Serializer/Deserializer). While the native jackdaw EDN SerDe fulfills most purposes, in order for the RentPath Kafka Connect EdnConverter (https://search.maven.org/artifact/com.rentpath/kafka-connect-converters/0.1.1/jar) to infer the requisite schema from the data itself, said data must conform to a series of further rules above and beyond those normally associated with the EDN specification; namely, that all compound data structures be consistent, their elements homogeneous in both type and structure. This SerDe exists to provide an (optional) means of validating these additional requirements, so as to ensure that no data from which a schema may not be autoderived (and thus unable to be sunk) is produced to any Kafka topic that is intended for Kafka Connect sinking.
conform!clj
(conform! data)Validates the input as homogeneous in all respects save structs, and recursively homogenizes structs, returning the resulting conformed data structure. Will throw an exception if not valid and conformable.
Validates the input as homogeneous in all respects save structs, and recursively homogenizes structs, returning the resulting conformed data structure. Will throw an exception if not valid and conformable.
serdeclj
(serde & [opts])Returns an optionally-homogeneous EDN serde.
Returns an optionally-homogeneous EDN serde.
serializerclj
(serializer)(serializer {:keys [validate?] :as opts})Returns an EDN serializer. If the :validate? option is set, the data to be written will first
be validated as and conformed to the homogeneous EDN spec. Will throw an exception if not valid
and conformable.
Returns an EDN serializer. If the `:validate?` option is set, the data to be written will first be validated as and conformed to the homogeneous EDN spec. Will throw an exception if not valid and conformable.
valid?clj
(valid? data & [schema])Will return true if the input data structure conforms to the homogeneous EDN requirements. May be provided with an optional previously-compiled schema structure to prevent recompilation.
Will return true if the input data structure conforms to the homogeneous EDN requirements. May be provided with an optional previously-compiled schema structure to prevent recompilation.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close