ИФ
Господа, а где тусуются аффтары crux?
офф чат https://juxt-oss.zulipchat.com/#narrow/stream/194466-crux
#crux в clojurians мониторим тоже. я в команде до 25 октября.
#crux в clojurians мониторим тоже. я в команде до 25 октября.
Size: a a a
2019 October 07
ИФ
Хочется понять, насколько сложно там сделать подписку на изменения. Или уже есть? Я что-то в доках не нашёл.
в последний раз ответ был слушать кафку и переигрывать запрос.
__
вот исследую 3df чтобы был ответ поинтереснее
__
вот исследую 3df чтобы был ответ поинтереснее
ИФ
а в Датомике как?
MG
Мне интересно только id изменённых энтитей, так что должно быть проще.
MG
@spacegangster
> Peers can monitor all transactions being processed by the system's transactor. The datomic.Connection.txReportQueue method provides a method to get a queue of transaction notifications.
> Peers can monitor all transactions being processed by the system's transactor. The datomic.Connection.txReportQueue method provides a method to get a queue of transaction notifications.
ИФ
@spacegangster
> Peers can monitor all transactions being processed by the system's transactor. The datomic.Connection.txReportQueue method provides a method to get a queue of transaction notifications.
> Peers can monitor all transactions being processed by the system's transactor. The datomic.Connection.txReportQueue method provides a method to get a queue of transaction notifications.
спасибо
ИФ
@spacegangster
> Peers can monitor all transactions being processed by the system's transactor. The datomic.Connection.txReportQueue method provides a method to get a queue of transaction notifications.
> Peers can monitor all transactions being processed by the system's transactor. The datomic.Connection.txReportQueue method provides a method to get a queue of transaction notifications.
Можно через
это вернёт список документов записанных не ранее tt1
crux.api/tx-log сделать(def node
(api/start-standalone-node
{:kv-backend "crux.kv.rocksdb.RocksKv"
:event-log-dir "data/eventlog"
:db-dir "data/db-dir"}))
(def tt1 1608142539479041)
(def tx-log-1 (api/tx-log node (api/new-tx-log-context node) tt1 true))
это вернёт список документов записанных не ранее tt1
ИФ
но это опрос нужен
MG
В том и проблема, что опрос.
ML
Ребят, а есть сейчас рабочий спосоь нативненько собираться при помощи GraalVM?
DL
Ребят, а есть сейчас рабочий спосоь нативненько собираться при помощи GraalVM?
плагин был для lein
ИФ
В том и проблема, что опрос.
У кракса нет единого транзактора. Всё пишется в топики в кафке (или jdbc), и оттуда индексируется множеством кракс-нод. Для случая с одним писателем можно обернуть
Пример опроса, на всякий случай https://github.com/juxt/crux/blob/3df-example-project/crux-dataflow/src/crux/dataflow.clj#L183
submit-tx и ждать sync, потом можно проверить успех операции через submitted-tx-updated-entity?Пример опроса, на всякий случай https://github.com/juxt/crux/blob/3df-example-project/crux-dataflow/src/crux/dataflow.clj#L183
MG
Топик с транзакциями один, значит и мониторить можно.
MG
Это нужно для клиентов, которые работают по событиям из базы.
AR
Топик с транзакциями один, значит и мониторить можно.
И партишен тоже один ;)
MG
Ну я про то и говорил. При этом делить его смысла особого нет, сколько там кафка выдаёт? 800k записей в секунду?
AR
Ну я про то и говорил. При этом делить его смысла особого нет, сколько там кафка выдаёт? 800k записей в секунду?
Сколько кафка выдает ОЧЕНЬ сильно зависит от кучи факторов. И масштабируется она именно что партишенами, так что тут все оч грустно пока )
2019 October 08
IG
Отчего может быть такая ошибка с Датомиком?
Транзактор поднимается, но не могу создать базу
2. Unhandled clojure.lang.ExceptionInfo
Error communicating with HOST 127.0.0.1 on PORT 4334
Caused by org.apache.activemq.artemis.api.core.ActiveMQNotConnectedException
Транзактор поднимается, но не могу создать базу