republisher Namespace Reference

Classes
class	LatchPublisher

Functions
def	extract_value (msg, getter_fn)
def	extract_values_as_dict (msg, mapping)
def	main ()
def	process_array (field, mapping)
def	process_single_field (field_value, mapping)
def	serialize (msg, mapping)

Variables
string	MAPPING_TYPE_ARRAY_OF_FIELDS = "array_of_fields"
string	MAPPING_TYPE_JSON_OF_FIELDS = "json_of_fields"
string	MAPPING_TYPE_SERIALIZE = "serialize"
string	MAPPING_TYPE_SINGLE_FIELD = "single_field"
string	STATIC_VALUE_FROM_ENVIRONMENT_VAR = "environment_variable"
string	STATIC_VALUE_FROM_PACKAGE_VERSION = "package_version"

Function Documentation

extract_value()

def republisher.extract_value	(		msg,
			getter_fn
	)

Definition at line 197 of file republisher.py.

extract_values_as_dict()

def republisher.extract_values_as_dict	(		msg,
			mapping
	)

Definition at line 207 of file republisher.py.

main()

def republisher.main

(

)

Definition at line 56 of file republisher.py.

process_array()

def republisher.process_array	(		field,
			mapping
	)

Definition at line 247 of file republisher.py.

process_single_field()

def republisher.process_single_field	(		field_value,
			mapping
	)

Definition at line 233 of file republisher.py.

serialize()

def republisher.serialize	(		msg,
			mapping
	)

Definition at line 275 of file republisher.py.

Variable Documentation

MAPPING_TYPE_ARRAY_OF_FIELDS

string republisher.MAPPING_TYPE_ARRAY_OF_FIELDS = "array_of_fields"

Definition at line 41 of file republisher.py.

MAPPING_TYPE_JSON_OF_FIELDS

string republisher.MAPPING_TYPE_JSON_OF_FIELDS = "json_of_fields"

Definition at line 42 of file republisher.py.

MAPPING_TYPE_SERIALIZE

string republisher.MAPPING_TYPE_SERIALIZE = "serialize"

Definition at line 43 of file republisher.py.

MAPPING_TYPE_SINGLE_FIELD

string republisher.MAPPING_TYPE_SINGLE_FIELD = "single_field"

Definition at line 40 of file republisher.py.

STATIC_VALUE_FROM_ENVIRONMENT_VAR

string republisher.STATIC_VALUE_FROM_ENVIRONMENT_VAR = "environment_variable"

Definition at line 47 of file republisher.py.

STATIC_VALUE_FROM_PACKAGE_VERSION

string republisher.STATIC_VALUE_FROM_PACKAGE_VERSION = "package_version"

Definition at line 46 of file republisher.py.