1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
create or replace function pgq_ext.get_last_tick(a_consumer text)
returns int8 as $$
declare
res int8;
begin
select last_tick_id into res
from pgq_ext.completed_tick
where consumer_id = a_consumer;
return res;
end;
$$ language plpgsql security definer;
create or replace function pgq_ext.set_last_tick(a_consumer text, a_tick_id bigint)
returns integer as $$
begin
if a_tick_id is null then
delete from pgq_ext.completed_tick
where consumer_id = a_consumer;
else
update pgq_ext.completed_tick
set last_tick_id = a_tick_id
where consumer_id = a_consumer;
if not found then
insert into pgq_ext.completed_tick (consumer_id, last_tick_id)
values (a_consumer, a_tick_id);
end if;
end if;
return 1;
end;
$$ language plpgsql security definer;
|
