I need my application to get all body from series of POST request made to it within 1 minute from say 12:00 to 12:01 into one array/sruct (so I can process it all immediately after 1 minute). Then again this should restart to get for the next one minute and so on.
This is in golang I'm trying to build. Receiving data in JSON.
func (m *StreamsDAO) Insert(stream model.Stream) error {
err := db.C(COLLECTION).Insert(&stream)
return err
}
Instead of directly inserting into db (err := db.C(COLLECTION).Insert(&stream)
) I need all data for 1 minute process it then insert, again get all for next 1 minute and so on.