omni_cloudevents

pig build pkg omnigres;		# build rpm/deb

pig repo add pgsql -u   # add both repo and update cache

pig install omnigres;		# install via package name, for the active PG version
pig install omni_cloudevents;		# install by extension name, for the current active PG version

pig install omni_cloudevents -v 18;   # install for PG 18
pig install omni_cloudevents -v 17;   # install for PG 17
pig install omni_cloudevents -v 16;   # install for PG 16
pig install omni_cloudevents -v 15;   # install for PG 15
pig install omni_cloudevents -v 14;   # install for PG 14

CREATE EXTENSION omni_cloudevents CASCADE; -- requires omni_web

SELECT omni_cloudevents.instantiate(schema => 'omni_cloudevents');
SET search_path TO omni_cloudevents, public;

SELECT cloudevent(
    id     => gen_random_uuid(),
    source => 'https://service.com/endpoint',
    type   => 'user.login'
);

SELECT publish(
    cloudevent(
        id     => gen_random_uuid(),
        source => 'https://api.yourservice.com/sys',
        type   => 'file.uploaded',
        data   => 'data-lake-bucket-123'::text
    )
);

SELECT omni_cloudevents.create_notice_publisher();
-- To observe uncommitted events:
SELECT omni_cloudevents.create_notice_publisher(publish_uncommitted => true);
-- Delete a publisher:
SELECT omni_cloudevents.delete_publisher(name);