CREATE OR REPLACE FUNCTION benchmark_get(

stream_name varchar,
cycles int DEFAULT 1000

) RETURNS void AS $$ BEGIN

RAISE NOTICE 'ยป benchmark_get';
RAISE NOTICE 'stream_name: %', benchmark_get.stream_name;
RAISE NOTICE 'cycles: %', benchmark_get.cycles;

FOR i IN 1..cycles LOOP
  IF current_setting('message_store.debug_benchmark', true) = 'on' OR current_setting('message_store.debug', true) = 'on' THEN
    RAISE NOTICE '%', i;
  END IF;

  PERFORM get_stream_messages(stream_name, "position" => i - 1, batch_size => 1);
END LOOP;

END; $$ LANGUAGE plpgsql VOLATILE;