Module

Yoga.Redis.PubSub

Package: purescript-yoga-redis
Repository: rowtype-yoga/purescript-yoga-redis

#RedisSubscriber Source

data RedisSubscriber

#SubscriptionMessage Source

type SubscriptionMessage = { channel :: RedisChannel, message :: RedisValue }

#PatternMessage Source

type PatternMessage = { channel :: RedisChannel, message :: RedisValue, pattern :: RedisPattern }

#RedisSubscriberConfigImpl Source

type RedisSubscriberConfigImpl :: Row Typetype RedisSubscriberConfigImpl = (connectTimeout :: ConnectTimeout, db :: RedisDatabase, family :: IPFamily, host :: RedisHost, keepAlive :: KeepAlive, keyPrefix :: RedisKeyPrefix, password :: RedisPassword, port :: RedisPort)

#createSubscriberImpl Source

createSubscriberImpl :: forall opts. EffectFn1 (Record opts) RedisSubscriber

#createSubscriber Source

createSubscriber :: forall opts opts_. Union opts opts_ RedisSubscriberConfigImpl => Record opts -> Effect RedisSubscriber

#subscribeImpl Source

subscribeImpl :: EffectFn3 RedisSubscriber (Array RedisChannel) (SubscriptionMessage -> Effect Unit) (Promise Unit)

#unsubscribeImpl Source

unsubscribeImpl :: EffectFn2 RedisSubscriber (Array RedisChannel) (Promise Unit)

#unsubscribe Source

unsubscribe :: Array RedisChannel -> RedisSubscriber -> Aff Unit

#psubscribeImpl Source

psubscribeImpl :: EffectFn3 RedisSubscriber (Array RedisPattern) (PatternMessage -> Effect Unit) (Promise Unit)

#psubscribe Source

psubscribe :: Array RedisPattern -> (PatternMessage -> Effect Unit) -> RedisSubscriber -> Aff Unit

#punsubscribeImpl Source

punsubscribeImpl :: EffectFn2 RedisSubscriber (Array RedisPattern) (Promise Unit)

#punsubscribe Source

punsubscribe :: Array RedisPattern -> RedisSubscriber -> Aff Unit

#disconnectSubscriberImpl Source

disconnectSubscriberImpl :: EffectFn1 RedisSubscriber (Promise Unit)

#disconnectSubscriber Source

disconnectSubscriber :: RedisSubscriber -> Aff Unit

#quitSubscriberImpl Source

quitSubscriberImpl :: EffectFn1 RedisSubscriber (Promise Unit)

#quitSubscriber Source

quitSubscriber :: RedisSubscriber -> Aff Unit

Modules: Yoga.Redis; Yoga.Redis.PubSub

Yoga.Redis.PubSub

#RedisSubscriber Source

#SubscriptionMessage Source

#PatternMessage Source

#RedisSubscriberConfigImpl Source

#createSubscriberImpl Source

#createSubscriber Source

#subscribeImpl Source

#subscribe Source

#unsubscribeImpl Source

#unsubscribe Source

#psubscribeImpl Source

#psubscribe Source

#punsubscribeImpl Source

#punsubscribe Source

#disconnectSubscriberImpl Source

#disconnectSubscriber Source

#quitSubscriberImpl Source

#quitSubscriber Source