wire-subsystems-0.1.0

Safe Haskell	Safe-Inferred
Language	GHC2021

Wire.NotificationSubsystem.Interpreter

Synopsis

runNotificationSubsystemGundeck :: (Member GundeckAPIAccess r, Member Async r, Member Delay r, Member (Final IO) r, Member TinyLog r) => NotificationSubsystemConfig -> Sem (NotificationSubsystem : r) a -> Sem r a
data NotificationSubsystemConfig = NotificationSubsystemConfig {
- fanoutLimit :: Range 1 HardTruncationLimit Int32
- chunkSize :: Natural
- slowPushDelay :: DiffTime
- requestId :: RequestId
}
defaultNotificationSubsystemConfig :: RequestId -> NotificationSubsystemConfig
defaultFanoutLimit :: Range 1 HardTruncationLimit Int32
defaultChunkSize :: Natural
defaultSlowPushDelay :: DiffTime
pushAsyncImpl :: forall r. (Member GundeckAPIAccess r, Member (Input NotificationSubsystemConfig) r, Member Async r, Member (Final IO) r, Member TinyLog r) => [Push] -> Sem r (Async (Maybe ()))
pushImpl :: forall r. (Member GundeckAPIAccess r, Member (Input NotificationSubsystemConfig) r, Member Async r) => [Push] -> Sem r ()
removeIfLargeFanout :: Range n m Int32 -> [Push] -> [Push]
mkPushes :: Natural -> [Push] -> [[Push]]
toV2Push :: Push -> Push
chunkPushes :: Natural -> [Push] -> [[Push]]
pushSlowlyImpl :: (Member Delay r, Member (Input NotificationSubsystemConfig) r, Member GundeckAPIAccess r, Member Async r) => [Push] -> Sem r ()

Documentation

runNotificationSubsystemGundeck :: (Member GundeckAPIAccess r, Member Async r, Member Delay r, Member (Final IO) r, Member TinyLog r) => NotificationSubsystemConfig -> Sem (NotificationSubsystem : r) a -> Sem r a Source #

We interpret this using GundeckAPIAccess so we can mock it out for testing.

data NotificationSubsystemConfig Source #

Constructors

NotificationSubsystemConfig
Fields fanoutLimit :: Range 1 HardTruncationLimit Int32 chunkSize :: Natural slowPushDelay :: DiffTime requestId :: RequestId

defaultNotificationSubsystemConfig :: RequestId -> NotificationSubsystemConfig Source #

defaultFanoutLimit :: Range 1 HardTruncationLimit Int32 Source #

defaultChunkSize :: Natural Source #

defaultSlowPushDelay :: DiffTime Source #

pushAsyncImpl :: forall r. (Member GundeckAPIAccess r, Member (Input NotificationSubsystemConfig) r, Member Async r, Member (Final IO) r, Member TinyLog r) => [Push] -> Sem r (Async (Maybe ())) Source #

pushImpl :: forall r. (Member GundeckAPIAccess r, Member (Input NotificationSubsystemConfig) r, Member Async r) => [Push] -> Sem r () Source #

removeIfLargeFanout :: Range n m Int32 -> [Push] -> [Push] Source #

mkPushes :: Natural -> [Push] -> [[Push]] Source #

toV2Push :: Push -> Push Source #

chunkPushes :: Natural -> [Push] -> [[Push]] Source #

pushSlowlyImpl :: (Member Delay r, Member (Input NotificationSubsystemConfig) r, Member GundeckAPIAccess r, Member Async r) => [Push] -> Sem r () Source #