topsim.core.buffer.ColdBuffer

class topsim.core.buffer.ColdBuffer(capacity, max_data_rate)

The ColdBuffer takes data from the hot buffer for use in workflow processing

Methods

__init__(capacity, max_data_rate)
has_capacity_for(observation_size)	Check if the ColdBuffer has capacity (checks self.current_capacity).
has_stored_observations()	Hides the dictionary nature of observations stored in the Buffer.
next_observation_for_processing()	Produces the next observation without removal
observation_for_transfer()
receive_observation(observation, residual_data)	For an observation that needs to be moved to ColdBuffer storage, we must 'receive' it.
remove(observation)	Removes an observation from the cold buffer and updates the capacity accordingly
transfer_observation(observation, ...)