Skip to content

Commit e9e13d5

Browse files
oliriceolirice
committed
update test output with queue_ prefix
1 parent c359835 commit e9e13d5

File tree

1 file changed

+63
-63
lines changed

1 file changed

+63
-63
lines changed

‎nix/tests/expected/pgmq_data_api_wrapper.out‎

Lines changed: 63 additions & 63 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ alter role authenticated set statement_timeout = '8s';
5555
*/
5656
create schema if not exists queues_public;
5757
grant usage on schema queues_public to postgres, anon, authenticated, service_role;
58-
create or replace function queues_public.pop(
58+
create or replace function queues_public.queue_pop(
5959
queue_name text
6060
)
6161
returns setof pgmq.message_record
@@ -70,8 +70,8 @@ begin
7070
);
7171
end;
7272
$$;
73-
comment on function queues_public.pop(queue_name text) is 'Retrieves and locks the next message from the specified queue.';
74-
create or replace function queues_public.send(
73+
comment on function queues_public.queue_pop(queue_name text) is 'Retrieves and locks the next message from the specified queue.';
74+
create or replace function queues_public.queue_send(
7575
queue_name text,
7676
message jsonb,
7777
sleep_seconds integer default 0 -- renamed from 'delay'
@@ -90,8 +90,8 @@ begin
9090
);
9191
end;
9292
$$;
93-
comment on function queues_public.send(queue_name text, message jsonb, sleep_seconds integer) is 'Sends a message to the specified queue, optionally delaying its availability by a number of seconds.';
94-
create or replace function queues_public.send_batch(
93+
comment on function queues_public.queue_send(queue_name text, message jsonb, sleep_seconds integer) is 'Sends a message to the specified queue, optionally delaying its availability by a number of seconds.';
94+
create or replace function queues_public.queue_send_batch(
9595
queue_name text,
9696
messages jsonb[],
9797
sleep_seconds integer default 0 -- renamed from 'delay'
@@ -110,8 +110,8 @@ begin
110110
);
111111
end;
112112
$$;
113-
comment on function queues_public.send_batch(queue_name text, messages jsonb[], sleep_seconds integer) is 'Sends a batch of messages to the specified queue, optionally delaying their availability by a number of seconds.';
114-
create or replace function queues_public.archive(
113+
comment on function queues_public.queue_send_batch(queue_name text, messages jsonb[], sleep_seconds integer) is 'Sends a batch of messages to the specified queue, optionally delaying their availability by a number of seconds.';
114+
create or replace function queues_public.queue_archive(
115115
queue_name text,
116116
message_id bigint
117117
)
@@ -127,8 +127,8 @@ begin
127127
);
128128
end;
129129
$$;
130-
comment on function queues_public.archive(queue_name text, message_id bigint) is 'Archives a message by moving it from the queue to a permanent archive.';
131-
create or replace function queues_public.archive(
130+
comment on function queues_public.queue_archive(queue_name text, message_id bigint) is 'Archives a message by moving it from the queue to a permanent archive.';
131+
create or replace function queues_public.queue_archive(
132132
queue_name text,
133133
message_id bigint
134134
)
@@ -144,8 +144,8 @@ begin
144144
);
145145
end;
146146
$$;
147-
comment on function queues_public.archive(queue_name text, message_id bigint) is 'Archives a message by moving it from the queue to a permanent archive.';
148-
create or replace function queues_public.delete(
147+
comment on function queues_public.queue_archive(queue_name text, message_id bigint) is 'Archives a message by moving it from the queue to a permanent archive.';
148+
create or replace function queues_public.queue_delete(
149149
queue_name text,
150150
message_id bigint
151151
)
@@ -161,8 +161,8 @@ begin
161161
);
162162
end;
163163
$$;
164-
comment on function queues_public.delete(queue_name text, message_id bigint) is 'Permanently deletes a message from the specified queue.';
165-
create or replace function queues_public.read(
164+
comment on function queues_public.queue_delete(queue_name text, message_id bigint) is 'Permanently deletes a message from the specified queue.';
165+
create or replace function queues_public.queue_read(
166166
queue_name text,
167167
sleep_seconds integer,
168168
n integer
@@ -181,19 +181,19 @@ begin
181181
);
182182
end;
183183
$$;
184-
comment on function queues_public.read(queue_name text, sleep_seconds integer, n integer) is 'Reads up to "n" messages from the specified queue with an optional "sleep_seconds" (visibility timeout).';
184+
comment on function queues_public.queue_read(queue_name text, sleep_seconds integer, n integer) is 'Reads up to "n" messages from the specified queue with an optional "sleep_seconds" (visibility timeout).';
185185
-- Grant execute permissions on wrapper functions to roles
186-
grant execute on function queues_public.pop(text) to postgres, service_role, anon, authenticated;
186+
grant execute on function queues_public.queue_pop(text) to postgres, service_role, anon, authenticated;
187187
grant execute on function pgmq.pop(text) to postgres, service_role, anon, authenticated;
188-
grant execute on function queues_public.send(text, jsonb, integer) to postgres, service_role, anon, authenticated;
188+
grant execute on function queues_public.queue_send(text, jsonb, integer) to postgres, service_role, anon, authenticated;
189189
grant execute on function pgmq.send(text, jsonb, integer) to postgres, service_role, anon, authenticated;
190-
grant execute on function queues_public.send_batch(text, jsonb[], integer) to postgres, service_role, anon, authenticated;
190+
grant execute on function queues_public.queue_send_batch(text, jsonb[], integer) to postgres, service_role, anon, authenticated;
191191
grant execute on function pgmq.send_batch(text, jsonb[], integer) to postgres, service_role, anon, authenticated;
192-
grant execute on function queues_public.archive(text, bigint) to postgres, service_role, anon, authenticated;
192+
grant execute on function queues_public.queue_archive(text, bigint) to postgres, service_role, anon, authenticated;
193193
grant execute on function pgmq.archive(text, bigint) to postgres, service_role, anon, authenticated;
194-
grant execute on function queues_public.delete(text, bigint) to postgres, service_role, anon, authenticated;
194+
grant execute on function queues_public.queue_delete(text, bigint) to postgres, service_role, anon, authenticated;
195195
grant execute on function pgmq.delete(text, bigint) to postgres, service_role, anon, authenticated;
196-
grant execute on function queues_public.read(text, integer, integer) to postgres, service_role, anon, authenticated;
196+
grant execute on function queues_public.queue_read(text, integer, integer) to postgres, service_role, anon, authenticated;
197197
grant execute on function pgmq.read(text, integer, integer, jsonb) to postgres, service_role, anon, authenticated;
198198
ERROR: function pgmq.read(text, integer, integer, jsonb) does not exist
199199
-- For the service role, we want full access
@@ -216,20 +216,20 @@ select pgmq.create('baz');
216216
begin;
217217
set local role service_role;
218218
-- Should Succeed
219-
select queues_public.send(
219+
select queues_public.queue_send(
220220
queue_name := 'baz',
221221
message := '{}'
222222
);
223-
send
224-
------
225-
1
223+
queue_send
224+
------------
225+
1
226226
(1 row)
227227

228228
rollback;
229229
begin;
230230
set local role anon;
231231
-- Should Fail
232-
select queues_public.send(
232+
select queues_public.queue_send(
233233
queue_name := 'baz',
234234
message := '{}'
235235
);
@@ -246,12 +246,12 @@ SQL statement "select *
246246
msg := message,
247247
delay := sleep_seconds
248248
)"
249-
PL/pgSQL function queues_public.send(text,jsonb,integer) line 3 at RETURN QUERY
249+
PL/pgSQL function queues_public.queue_send(text,jsonb,integer) line 3 at RETURN QUERY
250250
rollback;
251251
begin;
252252
set local role authenticated;
253253
-- Should Fail
254-
select queues_public.send(
254+
select queues_public.queue_send(
255255
queue_name := 'baz',
256256
message := '{}'
257257
);
@@ -268,26 +268,26 @@ SQL statement "select *
268268
msg := message,
269269
delay := sleep_seconds
270270
)"
271-
PL/pgSQL function queues_public.send(text,jsonb,integer) line 3 at RETURN QUERY
271+
PL/pgSQL function queues_public.queue_send(text,jsonb,integer) line 3 at RETURN QUERY
272272
rollback;
273273
-- service_role can read mesages, anon and authenticated can not
274274
begin;
275275
set local role service_role;
276276
-- Should Succeed
277-
select queues_public.read(
277+
select queues_public.queue_read(
278278
queue_name := 'baz',
279279
sleep_seconds := 0,
280280
n := 1
281281
);
282-
read
283-
------
282+
queue_read
283+
------------
284284
(0 rows)
285285

286286
rollback;
287287
begin;
288288
set local role anon;
289289
-- Should Fail
290-
select queues_public.read(
290+
select queues_public.queue_read(
291291
queue_name := 'baz',
292292
sleep_seconds := 0,
293293
n := 1
@@ -318,12 +318,12 @@ SQL statement "select *
318318
vt := sleep_seconds,
319319
qty := n
320320
)"
321-
PL/pgSQL function queues_public.read(text,integer,integer) line 3 at RETURN QUERY
321+
PL/pgSQL function queues_public.queue_read(text,integer,integer) line 3 at RETURN QUERY
322322
rollback;
323323
begin;
324324
set local role authenticated;
325325
-- Should Fail
326-
select queues_public.read(
326+
select queues_public.queue_read(
327327
queue_name := 'baz',
328328
sleep_seconds := 0,
329329
n := 1
@@ -354,7 +354,7 @@ SQL statement "select *
354354
vt := sleep_seconds,
355355
qty := n
356356
)"
357-
PL/pgSQL function queues_public.read(text,integer,integer) line 3 at RETURN QUERY
357+
PL/pgSQL function queues_public.queue_read(text,integer,integer) line 3 at RETURN QUERY
358358
rollback;
359359
/*
360360
WORKFLOW: Create a Queue named "baz"
@@ -428,7 +428,7 @@ select front_end.create_queue(
428428
begin;
429429
set local role anon;
430430
-- Should Fail
431-
select queues_public.read(
431+
select queues_public.queue_read(
432432
queue_name := 'qux',
433433
sleep_seconds := 0,
434434
n := 1
@@ -459,53 +459,53 @@ SQL statement "select *
459459
vt := sleep_seconds,
460460
qty := n
461461
)"
462-
PL/pgSQL function queues_public.read(text,integer,integer) line 3 at RETURN QUERY
462+
PL/pgSQL function queues_public.queue_read(text,integer,integer) line 3 at RETURN QUERY
463463
rollback;
464464
-- Should all work
465465
begin;
466466
set local role authenticated;
467467
-- Should succeed
468-
select queues_public.send(
468+
select queues_public.queue_send(
469469
queue_name := 'qux',
470470
message := '{}'
471471
);
472-
send
473-
------
474-
1
472+
queue_send
473+
------------
474+
1
475475
(1 row)
476476

477-
select queues_public.send_batch(
477+
select queues_public.queue_send_batch(
478478
queue_name := 'qux',
479479
messages := array['{"a": 1}', '{"b": 2}']::jsonb[]
480480
);
481-
send_batch
482-
------------
483-
2
484-
3
481+
queue_send_batch
482+
------------------
483+
2
484+
3
485485
(2 rows)
486486

487-
select queues_public.pop(
487+
select queues_public.queue_pop(
488488
queue_name := 'qux'
489489
);
490-
pop
491-
-----
490+
queue_pop
491+
-----------
492492
(0 rows)
493493

494-
select queues_public.delete(
494+
select queues_public.queue_delete(
495495
queue_name := 'qux',
496496
message_id := 2
497497
);
498-
delete
499-
--------
498+
queue_delete
499+
--------------
500500
t
501501
(1 row)
502502

503-
select queues_public.archive(
503+
select queues_public.queue_archive(
504504
queue_name := 'qux',
505505
message_id := 3
506506
);
507-
archive
508-
---------
507+
queue_archive
508+
---------------
509509
t
510510
(1 row)
511511

@@ -532,7 +532,7 @@ PL/pgSQL function front_end.create_queue(text,boolean,boolean,text) line 25 at E
532532
begin;
533533
set local role authenticated;
534534
-- Should fail
535-
select queues_public.send(
535+
select queues_public.queue_send(
536536
queue_name := 'waldo',
537537
message := '{}'
538538
);
@@ -551,17 +551,17 @@ SQL statement "select *
551551
msg := message,
552552
delay := sleep_seconds
553553
)"
554-
PL/pgSQL function queues_public.send(text,jsonb,integer) line 3 at RETURN QUERY
554+
PL/pgSQL function queues_public.queue_send(text,jsonb,integer) line 3 at RETURN QUERY
555555
rollback;
556556
/*
557557
Cleanup
558558
*/
559559
drop schema queues_public cascade;
560560
NOTICE: drop cascades to 6 other objects
561-
DETAIL: drop cascades to function queues_public.pop(text)
562-
drop cascades to function queues_public.send(text,jsonb,integer)
563-
drop cascades to function queues_public.send_batch(text,jsonb[],integer)
564-
drop cascades to function queues_public.archive(text,bigint)
565-
drop cascades to function queues_public.delete(text,bigint)
566-
drop cascades to function queues_public.read(text,integer,integer)
561+
DETAIL: drop cascades to function queues_public.queue_pop(text)
562+
drop cascades to function queues_public.queue_send(text,jsonb,integer)
563+
drop cascades to function queues_public.queue_send_batch(text,jsonb[],integer)
564+
drop cascades to function queues_public.queue_archive(text,bigint)
565+
drop cascades to function queues_public.queue_delete(text,bigint)
566+
drop cascades to function queues_public.queue_read(text,integer,integer)
567567
drop extension pgmq cascade; create extension pgmq;

0 commit comments

Comments
 (0)