in greengrasssdk/stream_manager/data/__init__.py [0:0]
def as_dict(self):
d = {}
if self.__identifier is not None:
d["identifier"] = (
self.__identifier.as_dict()
if hasattr(self.__identifier, "as_dict")
else self.__identifier
)
if self.__uri is not None:
d["uri"] = (
self.__uri.as_dict() if hasattr(self.__uri, "as_dict") else self.__uri
)
if self.__batch_size is not None:
d["batchSize"] = (
self.__batch_size.as_dict()
if hasattr(self.__batch_size, "as_dict")
else self.__batch_size
)
if self.__batch_interval_millis is not None:
d["batchIntervalMillis"] = (
self.__batch_interval_millis.as_dict()
if hasattr(self.__batch_interval_millis, "as_dict")
else self.__batch_interval_millis
)
if self.__priority is not None:
d["priority"] = (
self.__priority.as_dict()
if hasattr(self.__priority, "as_dict")
else self.__priority
)
if self.__start_sequence_number is not None:
d["startSequenceNumber"] = (
self.__start_sequence_number.as_dict()
if hasattr(self.__start_sequence_number, "as_dict")
else self.__start_sequence_number
)
if self.__disabled is not None:
d["disabled"] = (
self.__disabled.as_dict()
if hasattr(self.__disabled, "as_dict")
else self.__disabled
)
if self.__export_format is not None:
d["exportFormat"] = (
self.__export_format.as_dict()
if hasattr(self.__export_format, "as_dict")
else self.__export_format
)
return d