Documentation

createMsgDeliveryTask :: Connection -> GroupInfo -> GroupMember -> NewMessageDeliveryTask -> IO () Source #

deleteGroupDeliveryTasks :: Connection -> GroupInfo -> IO () Source #

deleteGroupDeliveryJobs :: Connection -> GroupInfo -> IO () Source #

getPendingDeliveryTaskScopes :: Connection -> IO [DeliveryWorkerKey] Source #

getNextDeliveryTask :: Connection -> DeliveryWorkerKey -> IO (Either StoreError (Maybe MessageDeliveryTask)) Source #

getNextDeliveryTasks :: Connection -> GroupInfo -> MessageDeliveryTask -> IO (Either StoreError [Either StoreError MessageDeliveryTask]) Source #

updateDeliveryTaskStatus :: Connection -> Int64 -> DeliveryTaskStatus -> IO () Source #

setDeliveryTaskErrStatus :: Connection -> Int64 -> Text -> IO () Source #

deleteDoneDeliveryTasks :: Connection -> UTCTime -> IO () Source #

createMsgDeliveryJob :: Connection -> GroupInfo -> DeliveryJobScope -> Maybe GroupMemberId -> ByteString -> IO () Source #

getPendingDeliveryJobScopes :: Connection -> IO [DeliveryWorkerKey] Source #

getNextDeliveryJob :: Connection -> DeliveryWorkerKey -> IO (Either StoreError (Maybe MessageDeliveryJob)) Source #

updateDeliveryJobStatus :: Connection -> Int64 -> DeliveryJobStatus -> IO () Source #

setDeliveryJobErrStatus :: Connection -> Int64 -> Text -> IO () Source #

getGroupMembersByCursor :: Connection -> VersionRangeChat -> User -> GroupInfo -> Maybe GroupMemberId -> Maybe GroupMemberId -> Int -> IO [GroupMember] Source #

updateDeliveryJobCursor :: Connection -> Int64 -> GroupMemberId -> IO () Source #

deleteDoneDeliveryJobs :: Connection -> UTCTime -> IO () Source #