This is part of Rivet Engine. This can also be implemented using an index stored in Redis + a background job to poll for updates that need to be executed within the next second.