pgnats

PostgreSQL расширение для совершения побликации сообщений в NATS

WIP, Not usable yet!

Install

sudo apt-get install build-essential libreadline-dev zlib1g-dev flex bison libxml2-dev libxslt-dev libssl-dev libxml2-utils xsltproc ccache pkg-config
cargo install --locked cargo-pgrx
cargo install nats-connect

Usage

-- Ручная инициализация настроек (производится автоматически при первом использовании каких-либо функций расширения)
Select nats_init();

-- Просмотр значения настройки:
Select get_config('nats.host');

-- Установка значения настройки
Select set_config('nats.host', '''test.url''');
Select set_config('nats.port', '1111');
Select set_config_string('nats.host', 'test.url');

Select set_config('nats.host', 'DEFAULT');
Select reset_config('nats.host');

-- Публикация в NATS
Select nats_publish('publish_text', 'sub.ject')

-- Публикация с помощью jetstream (sync)
Select nats_publish_stream('publish_text', 'sub.ject')

При публикации с помощью jetstream создается стрим с именем субъекта без последнего блока. Спецсимволы (.^?) заменяются на _.

Например:

luxmsbi.cdc.audit.events: luxmsbi_cdc_audit

Source

init.rs

Системные процедуры инициализации расширения

lib.rs

Точка входа в расширение, подключение необходимых модулей

api

Набор функций, экспортируемых в PostgreSQL

api/config.rs

Функции для изменения параметров конфигурации

api/nats.rs

Функции для работы с NATS

config.rs

Закрытые функции инициализации, настройка параметров по-умолчанию

Настройки:

CONFIG_HOST: str = "адрес NATS сервиса"
CONFIG_PORT: int = "порт NATS сервиса"

connection.rs

Внутренние функции для работы с NATS-соединением и NATS-stream

errors.rs

Внутренние типы ошибок

tests.rs

Функции тестирования

utils.rs

Вспомогательные функции