greengrasssdk/stream_manager/data/__init__.py [2740:2826]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def _get_batch_size(self):
        return self.__batch_size

    def _set_batch_size(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("batch_size must be int")

        self.__batch_size = value

    batch_size = property(_get_batch_size, _set_batch_size)
    """
    The maximum size of a batch to send to IoT Analytics. Messages will be queued until the batch size is reached, after which they will then be uploaded. If unspecified the default will be 100.
    If both batchSize and batchIntervalMillis are specified, then messages will be eligible for upload when either condition is met.
    The batch size must be between 1 and 100.
    """

    def _get_batch_interval_millis(self):
        return self.__batch_interval_millis

    def _set_batch_interval_millis(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("batch_interval_millis must be int")

        self.__batch_interval_millis = value

    batch_interval_millis = property(
        _get_batch_interval_millis, _set_batch_interval_millis
    )
    """
    The time in milliseconds between the earliest un-uploaded message and the current time. If this time is exceeded, messages will be uploaded in the next batch. If unspecified messages will be eligible for upload immediately.
    If both batchSize and batchIntervalMillis are specified, then messages will be eligible for upload when either condition is met.
    The minimum value is 60000 milliseconds and the maximum is 9223372036854 milliseconds.
    """

    def _get_priority(self):
        return self.__priority

    def _set_priority(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("priority must be int")

        self.__priority = value

    priority = property(_get_priority, _set_priority)
    """
    Priority for this upload stream. Lower values are higher priority. If not specified it will have the lowest priority.
    """

    def _get_start_sequence_number(self):
        return self.__start_sequence_number

    def _set_start_sequence_number(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("start_sequence_number must be int")

        self.__start_sequence_number = value

    start_sequence_number = property(
        _get_start_sequence_number, _set_start_sequence_number
    )
    """
    The sequence number of the message to use as the starting message in the export. Default is 0. The sequence number provided should be less than the newest sequence number in the stream, i.e., sequence number of the last messaged appended. To find the newest sequence number, describe the stream and then check the storage status of the returned MessageStreamInfo object.
    """

    def _get_disabled(self):
        return self.__disabled

    def _set_disabled(self, value):
        if value is not None and not isinstance(value, bool):
            raise TypeError("disabled must be bool")

        self.__disabled = value

    disabled = property(_get_disabled, _set_disabled)
    """
    Enable or disable this export. Default is false.
    """

    @staticmethod
    def from_dict(d):
        v = {}
        if "identifier" in d:
            v["identifier"] = (
                str.from_dict(d["identifier"])
                if hasattr(str, "from_dict")
                else d["identifier"]
            )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



greengrasssdk/stream_manager/data/__init__.py [3058:3144]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def _get_batch_size(self):
        return self.__batch_size

    def _set_batch_size(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("batch_size must be int")

        self.__batch_size = value

    batch_size = property(_get_batch_size, _set_batch_size)
    """
    The maximum size of a batch to send to the destination. Messages will be queued until the batch size is reached, after which they will then be uploaded. If unspecified the default will be 10.
    If both batchSize and batchIntervalMillis are specified, then messages will be eligible for upload when either condition is met.
    The minimum batch size is 1 and the maximum is 10.
    """

    def _get_batch_interval_millis(self):
        return self.__batch_interval_millis

    def _set_batch_interval_millis(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("batch_interval_millis must be int")

        self.__batch_interval_millis = value

    batch_interval_millis = property(
        _get_batch_interval_millis, _set_batch_interval_millis
    )
    """
    The time in milliseconds between the earliest un-uploaded message and the current time. If this time is exceeded, messages will be uploaded in the next batch. If unspecified messages will be eligible for upload immediately.
    If both batchSize and batchIntervalMillis are specified, then messages will be eligible for upload when either condition is met.
    The minimum value is 60000 milliseconds and the maximum is 9223372036854 milliseconds.
    """

    def _get_priority(self):
        return self.__priority

    def _set_priority(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("priority must be int")

        self.__priority = value

    priority = property(_get_priority, _set_priority)
    """
    Priority for this upload stream. Lower values are higher priority. If not specified it will have the lowest priority.
    """

    def _get_start_sequence_number(self):
        return self.__start_sequence_number

    def _set_start_sequence_number(self, value):
        if value is not None and not isinstance(value, int):
            raise TypeError("start_sequence_number must be int")

        self.__start_sequence_number = value

    start_sequence_number = property(
        _get_start_sequence_number, _set_start_sequence_number
    )
    """
    The sequence number of the message to use as the starting message in the export. Default is 0. The sequence number provided should be less than the newest sequence number in the stream, i.e., sequence number of the last messaged appended. To find the newest sequence number, describe the stream and then check the storage status of the returned MessageStreamInfo object.
    """

    def _get_disabled(self):
        return self.__disabled

    def _set_disabled(self, value):
        if value is not None and not isinstance(value, bool):
            raise TypeError("disabled must be bool")

        self.__disabled = value

    disabled = property(_get_disabled, _set_disabled)
    """
    Enable or disable this export. Default is false.
    """

    @staticmethod
    def from_dict(d):
        v = {}
        if "identifier" in d:
            v["identifier"] = (
                str.from_dict(d["identifier"])
                if hasattr(str, "from_dict")
                else d["identifier"]
            )
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -