-
-
Notifications
You must be signed in to change notification settings - Fork 91
smp server: store messages in PostgreSQL #1622
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
66b6a89 to
bfb0176
Compare
bfb0176 to
9ba7c3d
Compare
4a1eddf to
f1c73ba
Compare
f1c73ba to
3d61ab0
Compare
| unsafeRunStore :: StoreQueue s -> Text -> StoreMonad s a -> IO a | ||
|
|
||
| data MSType = MSMemory | MSJournal | ||
| -- default implementations are overridden for PostgreSQL storage of messages |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
moved into typeclass to redefine in PostgreSQL store
| {-# INLINE recipientId #-} | ||
| queueRec = queueRec' | ||
| {-# INLINE queueRec #-} | ||
| withQueueLock PostgresQueue {} _ = id -- TODO [messages] maybe it's just transaction? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think it may depend on configured transaction isolation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
not used, will just remove comment or put error there
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
actually it is used...
* smp server: store messages in PostgreSQL * stored procedures to write and to expire messages * function to export messages * move all message functions to PostgreSQL, remove delete trigger * comments * import messages to db * fix message import, add export * fix export * fix export * fix compilation flags * import messages line by line * fix server start with database storage * fix compilation * comments
No description provided.