A caching module for streams with tag-based invalidation