simplexmq-0.3.2: SimpleXMQ message broker
Safe HaskellNone
LanguageHaskell2010

Simplex.Messaging.Agent.Store.SQLite

Documentation

data SQLiteStore Source #

Constructors

SQLiteStore 

Fields

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) #