Network.MQTT.Broker.RetainedMessages

Description

Synopsis

• newtype RetainedStore = RetainedStore {
  • unstore :: MVar RetainedTree
  }
• newtype RetainedTree = RetainedTree {
  • untree :: Map Level RetainedNode
  }
• data RetainedNode = RetainedNode !RetainedTree !(Maybe Message)
• new :: IO RetainedStore
• store :: Message -> RetainedStore -> IO ()
• retrieve :: Filter -> RetainedStore -> IO (Set Message)
• empty :: RetainedTree
• null :: RetainedTree -> Bool
• insert :: Message -> RetainedTree -> RetainedTree
• delete :: Message -> RetainedTree -> RetainedTree
• singleton :: Message -> RetainedTree
• union :: RetainedTree -> RetainedTree -> RetainedTree
• difference :: RetainedTree -> RetainedTree -> RetainedTree
• lookupFilter :: Filter -> RetainedTree -> Set Message

Documentation