simplexmq-0.3.2: SimpleXMQ message broker

Safe Haskell	None
Language	Haskell2010

Simplex.Messaging.Agent.Store.SQLite

Contents

Orphan instances

Documentation

data SQLiteStore Source #

Constructors

SQLiteStore
Fields dbFilePath :: FilePath dbConn :: Connection

Instances

Instances details

(MonadUnliftIO m, MonadError StoreError m) => MonadAgentStore SQLiteStore m Source #

Instance details

Defined in Simplex.Messaging.Agent.Store.SQLite

Methods

createRcvConn :: SQLiteStore -> RcvQueue -> m () Source #

createSndConn :: SQLiteStore -> SndQueue -> m () Source #

getConn :: SQLiteStore -> ConnAlias -> m SomeConn Source #

getAllConnAliases :: SQLiteStore -> m [ConnAlias] Source #

getRcvConn :: SQLiteStore -> SMPServer -> RecipientId -> m SomeConn Source #

deleteConn :: SQLiteStore -> ConnAlias -> m () Source #

upgradeRcvConnToDuplex :: SQLiteStore -> ConnAlias -> SndQueue -> m () Source #

upgradeSndConnToDuplex :: SQLiteStore -> ConnAlias -> RcvQueue -> m () Source #

setRcvQueueStatus :: SQLiteStore -> RcvQueue -> QueueStatus -> m () Source #

setRcvQueueActive :: SQLiteStore -> RcvQueue -> VerificationKey -> m () Source #

setSndQueueStatus :: SQLiteStore -> SndQueue -> QueueStatus -> m () Source #

updateRcvIds :: SQLiteStore -> RcvQueue -> m (InternalId, InternalRcvId, PrevExternalSndId, PrevRcvMsgHash) Source #

createRcvMsg :: SQLiteStore -> RcvQueue -> RcvMsgData -> m () Source #

updateSndIds :: SQLiteStore -> SndQueue -> m (InternalId, InternalSndId, PrevSndMsgHash) Source #

createSndMsg :: SQLiteStore -> SndQueue -> SndMsgData -> m () Source #

getMsg :: SQLiteStore -> ConnAlias -> InternalId -> m Msg Source #

createSQLiteStore :: MonadUnliftIO m => FilePath -> m SQLiteStore Source #

connectSQLiteStore :: MonadUnliftIO m => FilePath -> m SQLiteStore Source #

Orphan instances

FromField MsgIntegrity Source #
Instance details Methods fromField :: FieldParser MsgIntegrity #
FromField QueueStatus Source #
Instance details Methods fromField :: FieldParser QueueStatus #
FromField InternalId Source #
Instance details Methods fromField :: FieldParser InternalId #
FromField InternalSndId Source #
Instance details Methods fromField :: FieldParser InternalSndId #
FromField InternalRcvId Source #
Instance details Methods fromField :: FieldParser InternalRcvId #
ToField MsgIntegrity Source #
Instance details Methods toField :: MsgIntegrity -> SQLData #
ToField QueueStatus Source #
Instance details Methods toField :: QueueStatus -> SQLData #
ToField InternalId Source #
Instance details Methods toField :: InternalId -> SQLData #
ToField SndMsgStatus Source #
Instance details Methods toField :: SndMsgStatus -> SQLData #
ToField InternalSndId Source #
Instance details Methods toField :: InternalSndId -> SQLData #
ToField RcvMsgStatus Source #
Instance details Methods toField :: RcvMsgStatus -> SQLData #
ToField InternalRcvId Source #
Instance details Methods toField :: InternalRcvId -> SQLData #
(FromField a, FromField b, FromField c, FromField d, FromField e, FromField f, FromField g, FromField h, FromField i, FromField j, FromField k) => FromRow (a, b, c, d, e, f, g, h, i, j, k) Source #
Instance details Methods fromRow :: RowParser (a, b, c, d, e, f, g, h, i, j, k) #