Go to the source code of this file.
Classes | |
| class | republisher.LatchPublisher |
Namespaces | |
| republisher | |
Functions | |
| def | republisher.extract_value (msg, getter_fn) |
| def | republisher.extract_values_as_dict (msg, mapping) |
| def | republisher.main () |
| def | republisher.process_array (field, mapping) |
| def | republisher.process_single_field (field_value, mapping) |
| def | republisher.serialize (msg, mapping) |
Variables | |
| string | republisher.MAPPING_TYPE_ARRAY_OF_FIELDS = "array_of_fields" |
| string | republisher.MAPPING_TYPE_JSON_OF_FIELDS = "json_of_fields" |
| string | republisher.MAPPING_TYPE_SERIALIZE = "serialize" |
| string | republisher.MAPPING_TYPE_SINGLE_FIELD = "single_field" |
| string | republisher.STATIC_VALUE_FROM_ENVIRONMENT_VAR = "environment_variable" |
| string | republisher.STATIC_VALUE_FROM_PACKAGE_VERSION = "package_version" |