Database.EventStore.Internal.Test

data Callback a

newPromise

newCallback

fulfill

reject

retrieve

tryRetrieve

fromEither

data Command

heartbeatRequestCmd

heartbeatResponseCmd

writeEventsCmd

writeEventsCompletedCmd

transactionStartCmd

transactionStartCompletedCmd

transactionWriteCmd

transactionWriteCompletedCmd

transactionCommitCmd

transactionCommitCompletedCmd

deleteStreamCmd

deleteStreamCompletedCmd

readEventCmd

readEventCompletedCmd

readStreamEventsForwardCmd

readStreamEventsForwardCompletedCmd

readStreamEventsBackwardCmd

readStreamEventsBackwardCompletedCmd

readAllEventsForwardCmd

readAllEventsForwardCompletedCmd

readAllEventsBackwardCmd

readAllEventsBackwardCompletedCmd

subscribeToStreamCmd

subscriptionConfirmationCmd

streamEventAppearedCmd

unsubscribeFromStreamCmd

subscriptionDroppedCmd

connectToPersistentSubscriptionCmd

persistentSubscriptionConfirmationCmd

persistentSubscriptionStreamEventAppearedCmd

createPersistentSubscriptionCmd

createPersistentSubscriptionCompletedCmd

deletePersistentSubscriptionCmd

deletePersistentSubscriptionCompletedCmd

persistentSubscriptionAckEventsCmd

persistentSubscriptionNakEventsCmd

updatePersistentSubscriptionCmd

updatePersistentSubscriptionCompletedCmd

badRequestCmd

notHandledCmd

authenticateCmd

authenticatedCmd

notAuthenticatedCmd

identifyClientCmd

clientIdentifiedCmd

unknownCmd

getCommand

_cmdDict

data SystemInit

data SystemShutdown

data Service

data Initialized

data InitFailed

data FatalException

data SubmitOperation

data ServiceTerminated

data NewTimer

data SendPackage

data ConnectionBuilder

data Connection

data RecvOutcome

data PackageArrived

data ConnectionError

data ConnectionEstablished

data ConnectionClosed

data ConnectionRef

getConnection

connectionBuilder

connectionError

Control

data EventStore a

runEventStore

getSettings

freshUUID

Messaging

class Pub p

class Sub s

data Hub

data Subscribe

data Publish

asPub

asSub

asHub

data Bus

newBus

busStop

data Message

toMsg

fromMsg

busProcessedEverything

publish

publishWith

subscribe

stopBus

publisher

Monitoring

monitorIncrPkgCount

monitorIncrConnectionDrop

monitorAddDataTransmitted

monitorIncrForceReconnect

monitorIncrHeartbeatTimeouts

Re-export

data Flag

flagWord8

data Credentials

credentials

data Retry

atMost

keepRetrying

data Settings

defaultSettings

defaultSSLSettings

msDiffTime

data Discovery

data GossipSeed

data DnsDiscoveryException

data ClusterSettings

data DnsServer

data EndPoint

staticEndPointDiscovery

clusterDnsEndPointDiscovery

gossipSeedClusterSettings

simpleDnsEndPointDiscovery

dnsClusterSettings

gossipSeed

gossipSeedWithHeader

gossipSeedHeader

gossipSeedHost

gossipSeedPort

data EndPoint

emptyEndPoint

data NodeEndPoints

data Exec

data Terminated

newExec

execSettings

execWaitTillClosed

data LoggerRef

data LoggerFilter

newLoggerRef

loggerCallback

data CatchupState

data CatchupOpResult

data Checkpoint

catchup

data DeleteResult

deleteStream

createPersist

updatePersist

deletePersist

readAllEvents

data ReadEvent

readEvent

readStreamEvents

readMetaStream

setMetaStream

transactionStart

transactionWrite

transactionCommit

writeEvents

class IsString a

class Semigroup a

class MonadIO m

class Hashable a

class Monoid a

data Down a

data HashMap k v

data Seq a

data Set a

data ByteString

data Text

class Generic a

class Alternative f

class MonadBaseControl b m

atomically

zip

zipWith

tshow

length

lift

retrySTM

fromMaybe

unlessM

whenM

isJust

null

data Flag

flagWord8

data Credentials

credentials

data Retry

atMost

keepRetrying

data Settings

defaultSettings

defaultSSLSettings

msDiffTime

data InternalException

data EventType

eventTypeText

eventTypeFromStr

data Event

createEvent

data EventData

eventDataType

eventMetadataType

withJson

withBinary

withJsonAndMetadata

withBinaryAndMetadata

eventDataBytes

eventMetadataBytes

data ExpectedVersion

expVersionInt32

anyVersion

noStreamVersion

emptyStreamVersion

exactEventVersion

streamExists

data NewEvent

newEvent

data EventRecord

data ResolvedIndexedEvent

data NotHandledReason

data MasterInfoBuf

data MasterInfo

masterInfo

masterInfoNodeEndPoints

data NotHandledBuf

data ResolvedEventBuf

data Position

positionStart

positionEnd

data RecordedEvent

recordedEventDataAsJson

toUTC

newRecordedEvent

data ResolvedEvent

newResolvedEvent

newResolvedEventFromBuf

resolvedEventOriginal

resolvedEventDataAsJson

isEventResolvedLink

resolvedEventOriginalStreamId

resolvedEventOriginalId

resolvedEventOriginalEventNumber

data ReadDirection

data Package

packageDataAsText

heartbeatRequestPackage

heartbeatResponsePackage

data StreamACL

emptyStreamACL

data StreamMetadata

getCustomPropertyValue

getCustomProperty

emptyStreamMetadata

customMetaToPairs

streamACLJSON

streamMetadataJSON

p_readRoles

p_writeRoles

p_deleteRoles

p_metaReadRoles

p_metaWriteRoles

p_maxAge

p_maxCount

p_truncateBefore

p_cacheControl

p_acl

internalMetaProperties

keepUserProperties

parseNominalDiffTime

parseStreamACL

parseStreamMetadata

type Builder a

build

type StreamACLBuilder

setReadRoles

setReadRole

setWriteRoles

setWriteRole

setDeleteRoles

setDeleteRole

setMetaReadRoles

setMetaReadRole

setMetaWriteRoles

setMetaWriteRole

buildStreamACL

modifyStreamACL

type StreamMetadataBuilder

setMaxCount

setMaxAge

setTruncateBefore

setCacheControl

setACL

modifyACL

setCustomProperty

buildStreamMetadata

modifyStreamMetadata

data StreamMetadataResult

data SystemConsumerStrategy

strategyText

strategyFromText

data PersistentSubscriptionSettings

defaultPersistentSubscriptionSettings

data Duration

msDuration

secsDuration