(self, entry)
Add an entry into the buffer.

        Args:
            entry: a dict object to add to the buffer.

        Raises:
            TypeError: if the entry is not a dict.
Add an entry into the buffer.
Add an entry into the buffer .
def add_dict(self, entry):
        """Add an entry into the buffer.

        Args:
            entry: a dict object to add to the buffer.

        Raises:
            TypeError: if the entry is not a dict.
        """
        self._ready()
        if not isinstance(entry, dict):
            raise TypeError('Entry object needs to be a dict.')

        if self._count >= self._threshold_entry:
            self.flush(end_stream=False)
            self._reset()

        if self._config_helper and not self._dict_config_loaded:
            data_type = entry.get('data_type', '')
            columns = entry.keys()
            self._config_helper.configure_streamer(
                self, data_type=data_type, columns=columns)
            self._dict_config_loaded = True

        # Changing the dictionary to add fields, such as timestamp description,
        # message field, etc. See function docstring for further details.
        self._fix_dict(entry)
        self._data_lines.append(entry)
        self._count += 1
def add_dict ( self , entry ) : self . _ready ( ) if not isinstance ( entry , dict ) : raise TypeError ( 'Entry object needs to be a dict.' ) if self . _count >= self . _threshold_entry : self . flush ( end_stream = False ) self . _reset ( ) if self . _config_helper and not self . _dict_config_loaded : data_type = entry . get ( 'data_type' , '' ) columns = entry . keys ( ) self . _config_helper . configure_streamer ( self , data_type = data_type , columns = columns ) self . _dict_config_loaded = True # Changing the dictionary to add fields, such as timestamp description, # message field, etc. See function docstring for further details. self . _fix_dict ( entry ) self . _data_lines . append ( entry ) self . _count += 1