Database.EventStore

Contents

• Result
• Event
• Connection manager
• Transaction
• Re-export

Description

Synopsis

• data Event
• data EventData
• data Connection
• data ExpectedVersion
  • = Any
  • | NoStream
  • | EmptyStream
• type HostName = String
• type Port = Int
• data Subscription = Subscription {
  • subId :: !UUID
  • subStream :: !Text
  • subResolveLinkTos :: !Bool
  • subEventChan :: !(TChan (Either DropReason ResolvedEventBuf))
  • subLastCommitPos :: !Int64
  • subLastEventNumber :: !(Maybe Int32)
  • subUnsubscribe :: IO ()
  }
• data AllEventsSlice = AllEventsSlice {
  • allEventsSliceResult :: !ReadAllResult
  • allEventsSliceFrom :: !Position
  • allEventsSliceNext :: !Position
  • allEventsSliceIsEOS :: !Bool
  • allEventsSliceEvents :: ![ResolvedEvent]
  • allEventsSliceDirection :: !ReadDirection
  }
• newtype DeleteResult = DeleteResult {
  • deleteStreamPosition :: Position
  }
• data WriteResult = WriteResult {
  • writeNextExpectedVersion :: !Int32
  • writePosition :: !Position
  }
• data ReadResult = ReadResult {
  • readResultStatus :: !ReadEventResult
  • readResultStreamId :: !Text
  • readResultEventNumber :: !Int32
  • readResultResolvedEvent :: !(Maybe ResolvedEvent)
  }
• data RecordedEvent = RecordedEvent {
  • recordedEventStreamId :: !Text
  • recordedEventId :: !UUID
  • recordedEventNumber :: !Int32
  • recordedEventType :: !Text
  • recordedEventData :: !ByteString
  • recordedEventMetadata :: !(Maybe ByteString)
  • recordedEventIsJson :: !Bool
  • recordedEventCreated :: !(Maybe UTCTime)
  • recordedEventCreatedEpoch :: !(Maybe Integer)
  }
• data StreamEventsSlice = StreamEventsSlice {
  • streamEventsSliceResult :: !ReadStreamResult
  • streamEventsSliceStreamId :: !Text
  • streamEventsSliceStart :: !Int32
  • streamEventsSliceNext :: !Int32
  • streamEventsSliceLast :: !Int32
  • streamEventsSliceIsEOS :: !Bool
  • streamEventsSliceEvents :: ![ResolvedEvent]
  • streamEventsSliceDirection :: !ReadDirection
  }
• eventResolved :: ResolvedEvent -> Bool
• resolvedEventOriginal :: ResolvedEvent -> Maybe RecordedEvent
• resolvedEventOriginalStreamId :: ResolvedEvent -> Maybe Text
• createEvent :: Text -> EventData -> Event
• withJson :: Value -> EventData
• withJsonAndMetadata :: Value -> Value -> EventData
• defaultSettings :: Settings
• connect :: Settings -> HostName -> Port -> IO Connection
• deleteStream :: Connection -> Text -> ExpectedVersion -> Maybe Bool -> IO (Async DeleteResult)
• readEvent :: Connection -> Text -> Int32 -> Bool -> IO (Async ReadResult)
• readAllEventsBackward :: Connection -> Int64 -> Int64 -> Int32 -> Bool -> IO (Async AllEventsSlice)
• readAllEventsForward :: Connection -> Int64 -> Int64 -> Int32 -> Bool -> IO (Async AllEventsSlice)
• readStreamEventsBackward :: Connection -> Text -> Int32 -> Int32 -> Bool -> IO (Async StreamEventsSlice)
• readStreamEventsForward :: Connection -> Text -> Int32 -> Int32 -> Bool -> IO (Async StreamEventsSlice)
• sendEvent :: Connection -> Text -> ExpectedVersion -> Event -> IO (Async WriteResult)
• sendEvents :: Connection -> Text -> ExpectedVersion -> [Event] -> IO (Async WriteResult)
• shutdown :: Connection -> IO ()
• transactionStart :: Connection -> Text -> ExpectedVersion -> IO (Async Transaction)
• subscribe :: Connection -> Text -> Bool -> IO (Async Subscription)
• data Transaction
• transactionCommit :: Transaction -> IO (Async WriteResult)
• transactionRollback :: Transaction -> IO ()
• transactionSendEvents :: Transaction -> [Event] -> IO (Async ())
• module Control.Concurrent.Async

Documentation

Result

Event

Connection manager

Transaction

Re-export