!P`      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_7(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_` eventstoreGeneralized version of a.b eventstore1Only perform the action if the predicate returns c.d eventstore1Only perform the action if the predicate returns e. fghijklmnopqrstuvwxyz{|}~ec      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefgh`ijbdk(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_%hlmnopqrstuvwxyz{ |}~ (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_*j eventstore Gathers both an IPv4 and a port. (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',>@AHSVX_,(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_K eventstoreGlobal  Connection settings eventstoreKMaximum delay of inactivity before the client sends a heartbeat request. eventstore;Maximum delay the server has to issue a heartbeat response. eventstoreUOn a cluster settings. Requires the master node when performing a write operation. eventstore'Retry strategy when failing to connect. eventstore.Delay before issuing a new connection request. eventstore SSL settings. eventstoreType of logging to use.  eventstore$Restriction of what would be logged.! eventstore]Detailed logging output. Currently, it also indicates the location where the log occurred." eventstoreCDelay in which an operation will be retried if no response arrived.# eventstore)Retry strategy when an operation timeout.$ eventstoreEKG metric store.% eventstoreDefault connection name.& eventstore(# to use for operations where other ( are not explicitly supplied.' eventstore!Represents reconnection strategy.( eventstore%Holds login and password information. eventstoreIndicates either a Package contains ( data or not. eventstoreMaps a  into a  understandable by the server.) eventstore Creates a ( given a login and a password.* eventstoreuIndicates how many times we should try to reconnect to the server. A value less than or equal to 0 means no retry.+ eventstoreTIndicates we should try to reconnect to the server until the end of the Universe., eventstoreDefault global settings. = 750 ms = 1500 ms = c = * 3 = 3 seconds =  =    =  ! = e" = 10 seconds# = * 3$ = % = & = - eventstoreDefault SSLsettings based on ,.. eventstoreMillisecond timespan) eventstoreLogin eventstorePassword!&%$#"! '()*+,-.(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',2>@AHMSVX_N@ !"#$%&'()*+,-.      (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,27>@AHMSVX_i/ eventstore7Contains settings related to a connection to a cluster.1 eventstore.The DNS name to use for discovering endpoints.2 eventstore9The maximum number of attempts for discovering endpoints.3 eventstore>The well-known endpoint on which cluster managers are running.4 eventstore.Endpoints for seeding gossip if not using DNS.5 eventstoreTimeout for cluster gossip.6 eventstore4Indicates a specific DNS server should be contacted.7 eventstore-Tells how the DNS server should be contacted. eventstore&Procedure used to discover an network .; eventstore&Represents a source of cluster gossip. eventstoreThe endpoint for the external HTTP endpoint of the gossip seed. The HTTP endpoint is used rather than the TCP endpoint because it is required for the client to exchange gossip with the server. standard port which should be used here in 2113.< eventstore2The host header to be sent when requesting gossip.= eventstore Creates a ;.> eventstore Creates a ; with a specific HTTP header.? eventstoreReturns ; host IP address.@ eventstoreReturns ; port.A eventstore Configures a / for connecting to a cluster using gossip seeds. clusterDns = "" clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipTimeout = 1sB eventstore Configures a / for connecting to a cluster using DNS discovery. clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipSeeds = Nothing clusterGossipTimeout = 1s!/0123456789:;<=>?@AB (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_l  (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_n! (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHMSVX_qC eventstore Internal command representation.4C"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRST (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.27>@AHMSVX_m$̠D eventstore/Gathers every persistent subscription property.F eventstorebWhether or not the persistent subscription should resolve linkTo events to their linked events.G eventstore4Where the subscription should start from (position).H eventstoreUWhether or not in depth latency statistics should be tracked on this subscription.I eventstore[The amount of time after which a message should be considered to be timeout and retried.J eventstore_The maximum number of retries (due to timeout) before a message get considered to be parked.K eventstoreAThe size of the buffer listening to live messages as they happen.L eventstore;The number of events read at a time when paging in history.M eventstore;The number of events to cache when paging through history.N eventstore+The amount of time to try checkpoint after.O eventstore-The minimum number of messages to checkpoint.P eventstoregThe maximum number of message to checkpoint. If this number is reached, a checkpoint will be forced.Q eventstore*The maximum number of subscribers allowed.R eventstore@The strategy to use for distributing events to client consumers.S eventstoreKSystem supported consumer strategies for use with persistent subscriptions.T eventstore_Distributes events to a single client until it is full. Then round robin to the next client.U eventstore;Distributes events to each client in a round robin fashion.V eventstoreNRepresents stream metadata as a series of properties for system data and a ` object for user metadata.X eventstore3When the stream is either not found or 'no stream'.Y eventstore When the stream is soft-deleted.Z eventstoreThe name of the stream.[ eventstore#The version of the metadata format.\ eventstoreA `$ containing user-specified metadata.] eventstoreA _ applies to `.^ eventstoreA _ applies to h._ eventstore"Allows to build a structure using  functions.` eventstoreRepresents stream metadata with strongly typed properties for system values and a dictionary-like interface for custom values.b eventstore3The maximum number of events allowed in the stream.c eventstore0The maximum age of events allowed in the stream.d eventstoretThe event number from which previous events can be scavenged. This is used to implement soft-deletion of streams.e eventstore9The amount of time for which the stream head is cachable.f eventstore'The access control list for the stream.g eventstoreTAn enumerable of key-value pairs of keys to JSON text for user-provider metadata.h eventstore/Represents an access control list for a stream.j eventstore-Roles and users permitted to read the stream.k eventstore1Roles and users permitted to write to the stream.l eventstore2Roles and users permitted to delete to the stream.m eventstore2Roles and users permitted to read stream metadata.n eventstore3Roles and users permitted to write stream metadata.U eventstoreARepresents a package exchanged between the client and the server.o eventstorePRepresents the direction of read operation (both from $all an usual streams).p eventstoreFrom beginning to endq eventstoreFrom end to beginningr eventstoreBA structure representing a single event or an resolved link event.t eventstore.The event, or the resolved link event if this r is a link event.u eventstoreThe link event if this r is a link event.v eventstore Possible  of that event.w eventstore&Represents a previously written event.y eventstore-The event stream that this event belongs to.z eventstore*Unique identifier representing this event.{ eventstore#Number of this event in the stream.| eventstoreType of this event.} eventstore$Representing the data of this event.~ eventstore5Representing the metadada associated with this event. eventstore;Indicates whether the content is internally marked as json. eventstore7Representing when this event was created in the system. eventstorecA structure referring to a potential logical record position in the EventStore transaction file. eventstoreCommit position of the record eventstorePrepare position of the recordV eventstoreKRepresents a serialized event sent by the server in a subscription context.W eventstoreORepresents a serialized event representiong either an event or a link event.X eventstore5Represents a serialized event coming from the server.Y eventstoreSerializes form of an . eventstore}Determines whether any link event encountered in the stream will be resolved. See the discussion for more information: Nhttps://eventstore.org/docs/dotnet-api/reading-events/index.html#resolvedevent eventstore-Represents an event position within a stream. eventstore,Constants used for expected version control.}The use of expected version can be a bit tricky especially when discussing idempotency assurances given by the EventStore.QThe EventStore will assure idempotency for all operations using any value in  except for  anyStream . When using  anyStream` the EventStore will do its best to assure idempotency but will not guarantee idempotency. eventstoreHolds event data. eventstoreRContains event information like its type and data. Only used for write queries. eventstore!Constants for System event types. eventstoreEvent type for stream deleted. eventstoreEvent type for statistics. eventstoreEvent type for linkTo. eventstoreEvent type for stream metadata. eventstore#Event type for the system settings. eventstoreEvent defined by the user.Z eventstorejRepresent a class of error where the user is not at fault. It could be either the client or the server.[ eventstoreHappens when the server deliberately close the connection. This probably happens if the client didn't respect EventStore communication error. For instance, the client takes too much time to respond to a heartbeat request. eventstore Create an  meant to be persisted.\ eventstoreMaps  inner data type to an  understandable by the server.] eventstoreMaps  inner metadata type to an ! understandable by the server. eventstore"Creates an event using JSON format eventstore'Creates an event using a binary format. eventstore1Creates an event with metadata using JSON format. eventstore3Creates an event with metadata using binary format.^ eventstore Serializes  EventData's data to a raw ._ eventstore Serializes  metadata to a raw .` eventstoreMaps a  to an  understandable by the server. eventstoreGThis write should not conflict with anything and should always succeed. eventstorejThe stream being written to should not yet exist. If it does exist treat that as a concurrency problem. eventstorezThe stream should exist and should be empty. If it does not exist or is not empty, treat that as a concurrency problem. eventstoreoStates that the last event written to the stream should have a sequence number matching your expected value. eventstorejThe stream should exist. If it or a metadata stream does not exist treat that as a concurrency problem. eventstoreThe first event in a stream. eventstoreThe last event in the stream. eventstorethe Nth event of a stream. eventstore"Returns a 'EventNumber from a raw . eventstoreReturns a raw  from an .a eventstoreY smart constructor. eventstore/Representing the start of the transaction file. eventstore-Representing the end of the transaction file. eventstore*Tries to parse JSON object from the given w.b eventstoreConverts a raw  into an r fromIntegral should be a no-op in GHC and allow eventstore to compile w GHCJS GHCJS maps CTime to Int32 (cf PR .https://github.com/YoEight/eventstore/pull/47)c eventstore Constructs a w from an X.d eventstore Constructs a r from a W.e eventstore Constructs a r from a V. eventstoreDReturns the event that was read or which triggered the subscription.If this ra represents a link event, the link will be the original event, otherwise it will be the event. eventstoreTries to desarialize  data as JSON. eventstoreIndicates whether this r is a resolved link event. eventstore&The stream name of the original event. eventstoreThe ID of the original event. eventstore'The event number of the original event.f eventstore*Constructs a heartbeat response given the h of heartbeat request. eventstoreh" with no role or users whatsoever. eventstore+Gets a custom property value from metadata. eventstore*Get a custom property value from metadata. eventstore` with everything set to , using  and an empty g.h eventstoreMaps an g to a list of i to ease the `.j eventstoreGets rid of null-ed properties. If a value is an array and that array only has one element, that function simplifies that array of JSON to a single JSON value.k eventstore Serialized a h to l for serialization purpose.m eventstore Serialized a ` to l for serialization purpose.n eventstoreRead ACL property.o eventstoreWrite ACL property.p eventstoreDelete ACL property.q eventstoreMetadata read ACL property.r eventstoreMetadata write ACL property.s eventstoreMax age metadata property.t eventstoreMax count metadata property.u eventstore#truncated before metadata property.v eventstore Cache control metadata property.w eventstoreACL metadata property.x eventstore2Gathers every internal metadata properties into a e. It used to safely ` in JSON.y eventstore,Only keeps the properties the users has set.z eventstore Parses a  from an g given a JSON property.{ eventstoreParses h.| eventstoreParses `.} eventstoreBuild a structure given a _ and an initial value. eventstore4Sets role names with read permission for the stream. eventstore<Sets a single role name with read permission for the stream. eventstore5Sets role names with write permission for the stream. eventstore=Sets a single role name with write permission for the stream. eventstore6Sets role names with delete permission for the stream. eventstore>Sets a single role name with delete permission for the stream. eventstore=Sets role names with metadata read permission for the stream. eventstoreESets a single role name with metadata read permission for the stream. eventstore>Sets role names with metadata write permission for the stream. eventstoreFSets a single role name with metadata write permission for the stream. eventstore Builds a h from a ^. eventstore Modifies a h using a ^. eventstore8Sets the maximum number of events allowed in the stream. eventstore5Sets the maximum age of events allowed in the stream. eventstoreBSets the event number from which previous events can be scavenged. eventstore>Sets the amount of time for which the stream head is cachable. eventstoreOverwrites any previous h by the given one in a ]. eventstore Updates a StreamMetadata's h given a ^. eventstore Sets a custom metadata property. eventstore Builds a ` from a ]. eventstore Modifies a ` using a ]~ eventstoreMaps a S to a  understandable by the server. eventstoreTries to parse a S given a raw . eventstore0System default persistent subscription settings. eventstore Event type eventstoreEvent ID, generated if  eventstore Event dataa eventstore Event type eventstoreEvent ID eventstoreData content type eventstoreMetadata content type eventstore Event data eventstoreMetadataDERQPONMLKJIHGFSUTVYXW\[Z]^_`agfedcbhinmlkjUoqprsvutwx~}|{zyVWXYZ[\]^_`abcdefhjkmnopqrstuvwxyz{|}~(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_B* eventstoreSAvalaible event sent by the server in the context of a persistent subscription.. eventstore/Connection to persistent subscription response. eventstoreNak processed events request. eventstore#Gathers every possible Nak actions. eventstoreAck processed events request. eventstore-Connect to a persistent subscription request. eventstore(Update persistent subscription response. eventstore'Update persistent subscription outcome. eventstore'Update persistent subscription request. eventstore(Delete persistent subscription response. eventstore'Delete persistent subscription outcome. eventstore'Delete persistent subscription request. eventstore(Create persistent subscription response. eventstore'Create persistent subscription outcome. eventstore'Create persistent subscription request. eventstoreQA message sent to the server to indicate the user asked to end a subscription. eventstoreBA message sent by the server when a subscription has been dropped. eventstore1Represents the reason subscription drop happened. eventstoreVSerialized event sent by the server when a new event has been appended to a stream. eventstore(Stream subscription connection response. eventstore'Stream subscription connection request. eventstore smart constructor. eventstore smart constructor. eventstore smart construction. eventstore smart constructor. eventstore smart constructor. eventstore smart constructor. eventstore smart constructor.}      !"#$%&'()*+,-./0123456789:;<=>?(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,2>@AHSVX_Y eventstore,Enumerates all persistent action exceptions. eventstoreThe action failed. eventstore_Happens when creating a persistent subscription on a stream with a group name already taken. eventstore`An operation tried to do something on a persistent subscription or a stream that don't exist. eventstore`The current user is not allowed to operate on the supplied stream or persistent subscription. eventstoreThat action has been aborted because the user shutdown the connection to the server or the connection to the server is no longer possible.@ eventstoreType of persistent action. eventstorezSubscription runtime details. Not useful for the user but at least it makes Haddock documentation generation less ugly. eventstoreRepresents a subscription id. eventstore.Indicates why a subscription has been dropped. eventstore4Subscription connection has been closed by the user. eventstoreBThe current user is not allowed to operate on the supplied stream. eventstore Given stream name doesn't exist. eventstoreGiven stream is deleted. eventstorewOccurs when the user shutdown the connection from the server or if the connection to the server is no longer possible. eventstore!Unexpected error from the server.(ABCDE@FGHIJKLMNOPQR(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.>@AHSVX_^ eventstore0Represents a regular stream name or $all stream. eventstore!If the stream is the $all stream.S(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_dhT eventstore&Batch read on regular stream response.U eventstoreJEnumeration detailing the possible outcomes of reading a slice of a streamV eventstore%Batch read on regular stream request.W eventstoreV smart constructor.TXYZ[\]^_U`abcdeVfghijkW(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_jl eventstore(Read event on a regular stream response.m eventstoreEEnumeration representing the status of a single event read operation.n eventstore'Read event on a regular stream request.o eventstoren smart constructor.lpqrsmtuvwxynz{|}~o(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_p eventstore#Batch read on $all stream response. eventstoreQEnumeration detailing the possible outcomes of reading a slice of $all stream. eventstore"Batch read on $all stream request. eventstore smart constructor.(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.>@AHSVX_yo eventstore&Represents a slice of the $all stream. eventstoreRegular stream slice. eventstore Gathers common slice operations. eventstore@Enumeration detailing the possible outcomes of reading a stream. eventstore Empty slice. eventstore Gets slice's ResolvedEventss. eventstore/If the slice has reached the end of the stream. eventstore%Gets the next location of this slice.(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_}p eventstore Creates Ack U. eventstore Create Nak U. eventstoreCreate an unsubscribe U.(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> experimental non-portableNone"#,.7>@AHSVX_(C) 2018 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> experimental non-portableNone"#,>@AHSVX_(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.12>@AHMSVX_ eventstore=Operation exception that can occurs on an operation response. eventstoreStream and Expected Version eventstoreStream eventstoreStream eventstoreExpected, Found eventstoreReason eventstore7Invalid operation state. If happens, it's a driver bug. eventstorecOccurs when the user asked to close the connection or if the connection can't reconnect anymore. eventstore$Operation result sent by the server. eventstoreAsks for a unused h. eventstore Raises an . eventstore5Asks to resume the interpretation from the beginning. eventstore6Sends a package to the server and wait for a response. eventstoreWaits package from the server. eventstoreLike B except it discards the correlation id of the network exchange. eventstore&Runs the first expection that matches. eventstoreSends a message to remote server. It returns the expected deserialized message along with the correlation id of the network exchange. eventstore$waitForElse uuid alternative expects5 Waits for a message from the server at the given uuidC. If the connection has been reset in the meantime, it will use  alternative. eventstoreRaises  exception. eventstoreRaises  exception. eventstoreRaises  exception. eventstoreRaises  exception. eventstoreRaises  exception. eventstoreRaises  exception. eventstoreRaises  exception.B9 (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_: eventstoreWrite events response. eventstoreWrite events request. eventstore smart constructor. eventstoreStream eventstoreExpected version eventstoreEvents eventstoreRequire master(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_V eventstore#Returned after writing to a stream.  eventstore$Next expected version of the stream.  eventstore of the write. eventstore Constructs a Y from an .  (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_H eventstoreWrite events operation.(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_  eventstoreCommit transaction response. eventstoreCommit transaction request. eventstore$Write transactional events response. eventstore#Write transactional events request. eventstoreStart transaction response. eventstoreStart transaction request. eventstore smart constructor. eventstore smart constructor. eventstore smart constructor.$     (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.>@AHSVX_v eventstoreStart transaction operation.  eventstoreTransactional write operation.! eventstoreTransactional commit operation. ! (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.>@AHSVX_" eventstore+Batch read from a regular stream operation."!(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.>@AHSVX_l  eventstoreJRepresents the result of looking up a specific event number from a stream.# eventstore3Read a specific event given event number operation.   #"(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.>@AHSVX_H$ eventstoreRead stream metadata operation.% eventstoreSet stream metadata operation.$%#(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_b& eventstore$Batch read on $all stream operation.&$(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_˶'()%(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_*&(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.7>@AHSVX_+ eventstoreDelete stream response., eventstoreDelete stream request.- eventstore, smart constructor. +./012,34567-'(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.>@AHSVX_c eventstore"Returned after deleting a stream.  of the write.8 eventstore"Delete a regular stream operation.8((C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',.>@AHSVX_9)(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_3 !"   #$%&'()89*(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,27>@AEHSVX_:;<=>?@ABCDEFGHIJKLMNO+(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AEHSVX_P,(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,2>@ACHSVX_  eventstore%Returns the stream of a subscription. eventstore.Common operations supported by a subscription. eventstore&Asks for the next incoming event like ! while still being in the the . eventstore.Returns the runtime details of a subscription. eventstore/Asynchronously unsubscribe from the the stream. eventstoreAwaits for the next event. eventstoreNon blocking version of . eventstoreWaits until the  has been confirmed. eventstoreLike  but lives in  monad. eventstoreNon blocking version of . eventstore;Wait until unsubscription has been confirmed by the server. eventstore Gets the ID of the subscription.QRST-(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,2>@AHSVX_BU eventstore Serializes a U into raw bytes.V eventstoreThe minimun size a UC should have. It's basically a command byte, correlation bytes (h) and a  byte.WXYZ[\]^_`abcdefghijklmnopqr.(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,2>@AEHSVX_!  eventstore4Occurs when an operation has been retried more than #.  !stuvwxyz{|/(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_ stu}~0(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#%,2>@AHSVX_%1(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,2>@AHSVX_2(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_ufghijklmnopqrstuvwxyz{|}~ec      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrlmnopqrstuvwxyz{ |}~stuvwxyz{|}~       !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefgh`ijbdk !"#$%&'()*+,-.     /0123456789:;<=>?@ABC"$#%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnUopqrstuvwxyz{|}~VWXYZ[\]^_`abcdefhjkmnopqrstuvwxyz{|}~ !"   #$%&'()89:;<=>?@ABDCEFGHIKJLMNOWXYZ[\]^_`abcdefghijklmnopqr3(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,=>?@AHSVX_" eventstoreAlso referred as volatile subscription. For example, if a stream has 100 events in it when a subscriber connects, the subscriber can expect to see event number 101 onwards until the time the subscription is closed or dropped. "4(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,=>?@AHSVX_*# eventstoreThe server remembers the state of the subscription. This allows for many different modes of operations compared to a regular or catchup subscription where the client holds the subscription state. (Need EventStore >= v3.1.0).$ eventstore>Acknowledges those event ids have been successfully processed.% eventstoreAcknowledges that r! has been successfully processed.& eventstoreAcknowledges those r#s have been successfully processed.' eventstorejMark a message that has failed processing. The server will take action based upon the action parameter.( eventstorejMark messages that have failed processing. The server will take action based upon the action parameter.) eventstoreFAcknowledges those event ids have failed to be processed successfully.#$%&'()5(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&',=>?@AHSVX_7* eventstoreThis kind of subscription specifies a starting point, in the form of an event number or transaction file position. The given function will be called for events from the starting point until the end of the stream, and then for subsequently written events.For example, if a starting point of 50 is specified when a stream has 100 events in it, the subscriber can expect to see events 51 through 100, and then any events subsequently written until such time as the subscription is dropped or closed.+ eventstoreNon blocking version of ,., eventstore Waits until *" subscription catch-up its stream.- eventstoreLike + but lives in  monad.*+,-6(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,.2>@AEHSVX_hh. eventstoreCWhen batch-reading a stream, this type-level function maps the result you will have whether you read a regular stream or $all stream. When reading a regular stream, some read-error can occur like the stream got deleted. However read-error cannot occur when reading $all stream (because $all cannot get deleted)./ eventstore The id of a 0.0 eventstore;Represents a multi-request transaction with the EventStore.1 eventstore4Represents a connection to a single EventStore node.2 eventstore4Gathers every connection type handled by the client.3 eventstoreHostName and Port.5 eventstore*Domain name, optional DNS server and port.6 eventstoreCreates a new 1] to a single node. It maintains a full duplex connection to the EventStore. An EventStore 1 operates quite differently than say a SQL connection. Normally when you use an EventStore connection you want to keep the connection open for a much longer of time than when you use a SQL connection.0Another difference is that with the EventStore 1 all operations are handled in a full async manner (even if you call the synchronous behaviors). Many threads can use an EvenStore 1 at the same time or a single thread can make many asynchronous requests. To get the most performance out of the connection it is generally recommended to use it in this way.7 eventstore Waits the 1 to be closed.8 eventstore Returns a 1 's .9 eventstoreAsynchronously closes the 1.: eventstoreSends a single  to given stream.; eventstoreSends a list of  to given stream.< eventstoreDeletes given stream.= eventstoreGets the id of a 0.> eventstore%Starts a transaction on given stream.? eventstore9Asynchronously writes to a transaction in the EventStore.@ eventstore(Asynchronously commits this transaction.A eventstorenThere isn't such of thing in EventStore parlance. Basically, if you want to rollback, you just have to not @ a 0.B eventstore'Reads a single event from given stream.C eventstore#Reads events from a stream forward.D eventstore$Reads events from a stream backward.E eventstoreSubscribes to a stream.F eventstoreDSubscribes to a stream. If last checkpoint is defined, this will readStreamEventsForward from that event number, otherwise from the beginning. Once last stream event reached up, a subscription request will be sent using E.G eventstore.Asynchronously sets the metadata for a stream.H eventstore-Asynchronously gets the metadata of a stream.I eventstoreBAsynchronously create a persistent subscription group on a stream.J eventstoreBAsynchronously update a persistent subscription group on a stream.K eventstoreBAsynchronously delete a persistent subscription group on a stream.L eventstoreQAsynchronously connect to a persistent subscription given a group on a stream.< eventstore Hard delete> eventstore Stream nameC eventstore Batch sizeD eventstore Batch sizeF eventstore Batch size-./0125436789:;<=>?@ABCDEFGHIJKL(C) 2019 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#,>@AHSVX_klM   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLM12345( !"#$%&'*+),-6978/0123456789:;=>?<@AB !VWXYZ[\.BDCHhijklmn`abcdefg<:;G_^]0/>=@A?"E*F,+-#DEFGHIJKLMNOPQRSTU%&'($)IJKL  wxyz{|}~   opqrstuv C.(C) 2018 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> experimental non-portableNone"#&',1>@AHSVX_~Z eventstoreReturns an iterator able to consume a stream entirely. When reading forward, the iterator ends when the last stream's event is reached.[ eventstoreReturns an iterator able to consume a stream entirely. When reading backward, the iterator ends when the first stream's event is reached.\ eventstoreThrows an exception in case  is a .] eventstore6Returns an iterator able to consume a stream entirely.MNOPRQSWVUTXYZ[\]SWVUTPRQMNOZ[\XY]7None"#,>@AHSVX_+89:8;<89=89>?@ABCDBCEBCFBCGBCHBCIBCJBCKLMNLMOLMPLMQLMRLMSTUVWWXYYZ[\]^_`abcdefghijklmno p p q r s t u v w x y z { | } ~                                                !"#$#%&'()*+,-./0123456789:;<<=>!?!@!?!A!B!C'D'D,E,F,G,H,I,J,K,L,M,N,O,P,Q.R.R3S4T4U4V4W4X4Y4Z5[5\5]5^6_6`6a6b6c6d6e6f6g6h6i6j6k6l6m6n6o6p6q6r6s6t6u6v6w6x6y6z6{6|6}~~*2*4888898989888888888888888888888888888989898989898989888888888888888888989898989898888888888898989898989898888888     88888888 !"#$%89&89'89(T)*T)*T)+T),-./8012312412512612712812912:12;12<12=12>12?12?12@12@89A89B89C89D89E89F89G89H8IJ8KL8MN8OP8QR8QS8TU8TV8TW8TX8TY8Z8[8\8]8^8_8`a8b8c8d8e8f8g8h8i8j8k8lm8lm8no8pq8lr8st8su8sv8sw8xy8xz8x{8x|8x}8x~8x8x8x8x8x8x8x8x8x8x8x8x8x8x8x8x8x888888888888888888888888889898989888s8sT      !"#$#%#&#'#(#)#*#+#,#-#.#/#0#1#2#3#4565758595:5;<=><=?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\][\^[\_[\`[\a[\b[\c[\d[\e[\f[\g[\h[\i[\j[\k[\l[\m[\n[\o[\p[\q[\r[\s[\t[\u[\v[\w[\x[\y[\z[\{[\|[\}[\~[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[\[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[[      !"#$%&'(())**+,-+./+.0+.1+.2+.3+45+46+47+48+49+4:+4;+4<+4=+4>+4?+@A+@B+@C+@D+@E+@F+@G+@H+@I+@J+@K+@L+@M+@N+OP+OQ+OR+OS+OT+OU+OV+OW+OX+OY+OZ+O[+O\+O]+^_+^`+^a+^b+^c+^d+^e+^f+^g+^h+^i+^j+^klmnlmolmplmqlmrlmslmtlmulmvlmwlmxlmylmzlm{lm|lm}T~T~T~T~TTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTTUTTTTTTTTTTTTTTTTTT<=BCBCBCBCBCBCBCBCBCBCBCBCBCBCBCBCBBBBBBBBBBBBBB B B B  B BBBBBBB !"LM#LM$LM%LM&LM'LM(LM)LM*LM+LM,LM-LM.LM/LM0LM1LM2LM3LM4LM5LM6LM7LM8LM9LM:LM;LM<LM=LM>LM?LM@LMALMBLMCLMDLMELMFLMGLMHLMILMJLMKLMLLMMLMNLMOLMPLMQLMRLMSLMTLMULMULMVLMWLMWLMXLMYLMYLMZ[\]^__`a^bcdefghijklmnopiqrstuvwxyz{|}~v                                                                                                                                                  ! " # $ % & ' ( ) *  + , - . / 0  1 2 3  4 5 6  7 8 9 : ; < = > ? @ A B CDEFGHIJKLMNOPQRSTUVWXYZ[\]D^E_`aFbcdeGfgHhijIklmnopKqrstuvwxyz{|}~LNOQRSTUV  h    !"#$%&'()*+,-./0123456.789(/:;0<=>1?@2A)3*Bpq C!s"D"E#F$G$H$I%J&&&&&)&&&&&K&*&&'m(L*M*M*N*N*O*O*P*P*Q*R*Q*S*S*T*T*U*V*W*X*X*Y*Y+Z,[,\,],^-_-`-a-a-b-b-c-c-d-d-b-b-e-f-g-h-i-i-j-k-l-m-n-o-p-p-g-q-r-s.t.u.v.w.x.y.z.{.|.}/~//[///01111113S3333333334T44444444445[55555555555556`66a66666b66666677777777'eventstore-1.3.1-5qKP6Hut1MKDTpjScnI8PQDatabase.EventStoreDatabase.EventStore.Streaming$Database.EventStore.Internal.Prelude#Database.EventStore.Internal.Logger%Database.EventStore.Internal.EndPoint%Database.EventStore.Internal.Callback%Database.EventStore.Internal.Settings$Database.EventStore.Internal.Control&Database.EventStore.Internal.Discovery&Database.EventStore.Internal.Stopwatch"Database.EventStore.Internal.Utils$Database.EventStore.Internal.Command"Database.EventStore.Internal.Types1Database.EventStore.Internal.Subscription.Message/Database.EventStore.Internal.Subscription.Types#Database.EventStore.Internal.Stream?Database.EventStore.Internal.Operation.ReadStreamEvents.Message8Database.EventStore.Internal.Operation.ReadEvent.MessageData.List.NonEmptynonEmpty:|NonEmpty'connection-0.3.1-GdSmK3DtKURB6NMovrfm5TNetwork.Connection.Types TLSSettings)fast-logger-2.4.17-DpntV4m5nh5JaoWiJvQ295System.Log.FastLogger LogCallbackLogFileTimedRotateLogFileLogFileNoRotate LogStderr LogStdoutLogNoneLogType)monad-logger-0.3.30-ikWmML9rZk6KEBHAntmd4Control.Monad.Logger LevelOther LevelError LevelWarn LevelInfo LevelDebugLogLevel time-1.8.0.2(Data.Time.Clock.Internal.NominalDiffTimeNominalDiffTime LoggerFilter LoggerLevelSettingss_heartbeatIntervals_heartbeatTimeouts_requireMasters_retrys_reconnect_delays_ssl s_loggerTypes_loggerFilters_loggerDetaileds_operationTimeouts_operationRetry s_monitorings_defaultConnectionNames_defaultUserCredentialsRetry Credentials credentialsatMost keepRetryingdefaultSettingsdefaultSSLSettings msDiffTimeClusterSettings clusterDnsclusterMaxDiscoverAttemptsclusterExternalGossipPortclusterGossipSeedsclusterGossipTimeoutclusterDnsServer DnsServer DnsFilePath DnsHostName DnsHostPort GossipSeedgossipSeedHeader gossipSeedgossipSeedWithHeadergossipSeedHostgossipSeedPortgossipSeedClusterSettingsdnsClusterSettingsCommandPersistentSubscriptionSettingspsSettingsResolveLinkTospsSettingsStartFrompsSettingsExtraStatspsSettingsMsgTimeoutpsSettingsMaxRetryCountpsSettingsLiveBufSizepsSettingsReadBatchSizepsSettingsHistoryBufSizepsSettingsCheckPointAfterpsSettingsMinCheckPointCountpsSettingsMaxCheckPointCountpsSettingsMaxSubsCountpsSettingsNamedConsumerStrategySystemConsumerStrategyDispatchToSingle RoundRobinStreamMetadataResultNotFoundStreamMetadataResultDeletedStreamMetadataResultstreamMetaResultStreamstreamMetaResultVersionstreamMetaResultDataStreamMetadataBuilderStreamACLBuilderBuilderStreamMetadatastreamMetadataMaxCountstreamMetadataMaxAgestreamMetadataTruncateBeforestreamMetadataCacheControlstreamMetadataACLstreamMetadataCustom StreamACLstreamACLReadRolesstreamACLWriteRolesstreamACLDeleteRolesstreamACLMetaReadRolesstreamACLMetaWriteRoles ReadDirectionForwardBackward ResolvedEventresolvedEventRecordresolvedEventLinkresolvedEventPosition RecordedEventrecordedEventStreamIdrecordedEventIdrecordedEventNumberrecordedEventTyperecordedEventDatarecordedEventMetadatarecordedEventIsJsonrecordedEventCreatedPositionpositionCommitpositionPrepare ResolveLink NoResolveLink EventNumberExpectedVersion EventDataEvent EventTypeStreamDeletedTypeStatsCollectionType LinkToTypeStreamMetadataType SettingsType UserDefined createEventwithJson withBinarywithJsonAndMetadatawithBinaryAndMetadata anyVersionnoStreamVersionemptyStreamVersionexactEventVersion streamExists streamStart streamEnd eventNumberrawEventNumbereventNumberToInt64 positionStart positionEndrecordedEventDataAsJsonresolvedEventOriginalresolvedEventDataAsJsonisEventResolvedLinkresolvedEventOriginalStreamIdresolvedEventOriginalId resolvedEventOriginalEventNumberemptyStreamACLgetCustomPropertyValuegetCustomPropertyemptyStreamMetadata setReadRoles setReadRole setWriteRoles setWriteRolesetDeleteRoles setDeleteRolesetMetaReadRolessetMetaReadRolesetMetaWriteRolessetMetaWriteRolebuildStreamACLmodifyStreamACL setMaxCount setMaxAgesetTruncateBeforesetCacheControlsetACL modifyACLsetCustomPropertybuildStreamMetadatamodifyStreamMetadata%defaultPersistentSubscriptionSettings NakAction NA_UnknownNA_ParkNA_RetryNA_SkipNA_Stop DropReasonD_UnsubscribedD_AccessDenied D_NotFoundD_PersistentSubscriptionDeletedD_SubscriberMaxCountReachedPersistActionExceptionPersistActionFailPersistActionAlreadyExistPersistActionDoesNotExistPersistActionAccessDeniedPersistActionAborted SubDetailsSubscriptionIdSubscriptionClosed SubDropReasonSubUnsubscribedSubAccessDenied SubNotFoundSubPersistDeleted SubAbortedSubNotAuthenticatedSubServerError SubNotHandledSubClientErrorSubSubscriberMaxCountReached StreamNameStreamIdAll isAllStreamAllSlice StreamSliceSliceSliceEndOfStream ReadResult ReadSuccess ReadNoStreamReadStreamDeletedReadNotModified ReadErrorReadAccessDenied emptySlice sliceEventssliceEOS sliceNextOperationErrorWrongExpectedVersion StreamDeletedInvalidTransaction AccessDeniedInvalidServerResponseProtobufDecodingError ServerErrorInvalidOperationStreamNotFoundNotAuthenticatedOpAborted WriteResultwriteNextExpectedVersion writePosition ReadEventReadEventNotFoundreadEventStreamreadEventNumberreadEventResolved DeleteResultSubscriptionStreamsubscriptionStream SubscriptionnextEventMaybeSTMgetSubscriptionDetailsSTM unsubscribe nextEventnextEventMaybewaitConfirmationunsubscribeConfirmedSTMunsubscribeConfirmedwaitUnsubscribeConfirmedgetSubscriptionIdOperationMaxAttemptReachedRegularSubscriptionPersistentSubscriptionnotifyEventsProcessed acknowledgeacknowledgeEventsfailed eventsFailednotifyEventsFailedCatchupSubscription hasCaughtUpwaitTillCatchuphasCaughtUpSTM BatchResult TransactionId Transaction ConnectionConnectionTypeStaticClusterDnsconnectwaitTillClosedconnectionSettingsshutdown sendEvent sendEvents deleteStream transactionIdstartTransactiontransactionWritetransactionCommittransactionRollback readEventreadEventsForwardreadEventsBackward subscribe subscribeFromsetStreamMetadatagetStreamMetadatacreatePersistentSubscriptionupdatePersistentSubscriptiondeletePersistentSubscriptionconnectToPersistentSubscriptionReadResultHandlerrunReadResultHandlerFetch FetchErrorNoStreamdefaultReadResultHandleronRegularStreamreadThroughForwardreadThroughBackward throwOnError readThrough$fExceptionReadError$fShowReadError atomically GHC.Conc.SyncwhenMghc-prim GHC.TypesTrueunlessMFalseGHC.Listzip System.IOprint otherwiseassert$GHC.Real fromIntegral realToFracGHC.EnumBoundedminBoundmaxBoundEnumenumFrom enumFromThenenumFromThenTo enumFromTofromEnumtoEnumsuccpred GHC.ClassesEq==/= Fractional fromRational/recipIntegral toIntegerquotremdivmodquotRemdivModMonadfail>>=>>returnFunctorfmap<$GHC.NumNum+*-negate fromIntegerabssignumOrd>=minmax><compare<= toRationaltruncateGHC.ShowShow showsPrecshowshowListData.Typeable.InternalTypeable Data.StringIsString fromString Applicative<*>pure*><*liftA2 Data.FoldableFoldabletoListfoldMapfoldl'Data.Traversable TraversabletraversemapM sequenceAsequence GHC.GenericsGeneric SemigroupsconcatstimesMonoidmconcatmemptymappendBoolDoubleFloatIntGHC.IntInt8Int16Int32Int64 integer-gmpGHC.Integer.TypeInteger GHC.MaybeMaybeNothingJustOrderingLTEQGTIOWordGHC.WordWord8Word16Word32Word64 Data.EitherEitherLeftRightTyConbytestring-0.10.8.2Data.ByteString.Internal ByteString Data.Functor<$>'hashable-1.3.0.0-1RsrIcitxVDKffGN1TuMlmData.Hashable.ClassHashablehash hashWithSalt text-1.2.3.1Data.Text.InternalTextconst.id Data.Time.Clock.Internal.UTCTimeUTCTimeutctDay utctDayTime3unordered-containers-0.2.10.0-b9YJCQLkMeLUf311RZkQDData.HashMap.BaseHashMapThreadId"async-2.2.2-JNOgs3QkEuXLm97AkAPhACControl.Concurrent.Async waitBothSTMwaitEitherSTM_ waitEitherSTMwaitEitherCatchSTM waitAnySTMwaitAnyCatchSTMpollSTM waitCatchSTMwaitSTM compareAsyncsAsync asyncThreadIdAsyncCancelledExceptionInLinkedThread Alternativeempty<|>manysome MonadPlusmzeromplusControl.ConcurrentrtsSupportsBoundThreadsControl.Concurrent.ChanChanControl.Concurrent.QSemQSemControl.Concurrent.QSemNQSemNControl.Monad.IO.ClassMonadIOliftIO Control.MonadunlessfoldM_foldMforever<=<foldMapDefault fmapDefault mapAccumR mapAccumLforMfor GHC.Conc.IO registerDelay writeTVarreadTVar readTVarIO newTVarIOnewTVarcatchSTMthrowSTMorElseSTMTVarGHC.IO.ExceptionSomeAsyncException GHC.IORefIORefGHC.IOFilePath IOExceptionGHC.Exception.Type Exception toException fromExceptiondisplayException Data.TypeabletypeOf7typeOf6typeOf5typeOf4typeOf3typeOf2typeOf1 rnfTypeReptypeRepFingerprint typeRepTyCon typeRepArgs splitTyConAppmkFunTy funResultTygcast2gcast1gcasteqTcast showsTypeReptypeReptypeOfTypeReprnfTyContyConFingerprint tyConName tyConModule tyConPackageforM_for_ traverse_eitherData.OrdDown Data.ProxyProxyData.Type.Equality:~:Refl:~~:HRefl byteSwap64 byteSwap32 byteSwap16zipWith Data.Maybe fromMaybeisJustmaybeGHC.MVarMVarflipapwhen=<<GHC.Err undefinederror SomeException&&||nottransformers-0.5.5.0Control.Monad.Trans.Classlift(exceptions-0.10.3-JCVBmzxJmVzJ5RaoaWAPCEControl.Monad.Catch MonadThrowthrowMcontainers-0.6.0.1Data.Sequence.InternalSeqData.Set.InternalSet!Data.Time.Clock.Internal.DiffTimeDiffTime handleIOError catchIOErroruninterruptibleMask_mask_ MonadCatchcatch MonadMaskmaskuninterruptibleMaskgeneralBracketHandler,lifted-async-0.10.0.4-B9Pl876H24eGIJ70Dei01cControl.Concurrent.Async.LiftedreplicateConcurrently_replicateConcurrentlyforConcurrently_forConcurrentlymapConcurrently_mapConcurrently concurrently_ concurrentlyrace_racelink2linkwaitBoth waitEither_waitEitherCatchCancelwaitEitherCancelwaitEitherCatch waitEitherwaitAnyCatchCancel waitAnyCancel waitAnyCatchwaitAny waitCatchuninterruptibleCancel cancelWithcancelpollwaitwithAsyncOnWithUnmaskwithAsyncWithUnmask withAsyncOnwithAsyncBound withAsyncasyncOnWithUnmaskasyncWithUnmaskasyncOn asyncBoundasync ConcurrentlyrunConcurrently,monad-control-1.0.2.3-72Lqn5gml7WCRCL7FrqymTControl.Monad.Trans.Control liftBaseOp_+lifted-base-0.2.3.12-BX7AqBlSHUtAMSlfQj489gData.IORef.Lifted mkWeakIORefatomicWriteIORefatomicModifyIORef' modifyIORef'atomicModifyIORef modifyIORef writeIORef readIORefnewIORefControl.Concurrent.LiftedmkWeakThreadIdrunInUnboundThreadrunInBoundThreadisCurrentThreadBoundforkOSthreadWaitWritethreadWaitRead threadDelaythreadCapabilitysetNumCapabilitiesgetNumCapabilitiesforkOnWithUnmaskforkOn killThread forkFinallyforkWithUnmaskfork myThreadIdControl.Concurrent.QSemN.Lifted signalQSemN waitQSemNnewQSemNControl.Concurrent.QSem.Lifted signalQSemwaitQSemnewQSemControl.Concurrent.MVar.Lifted tryReadMVarwithMVarMasked mkWeakMVarmodifyMVarMaskedmodifyMVarMasked_ modifyMVar modifyMVar_withMVar isEmptyMVar tryPutMVar tryTakeMVarswapMVarreadMVarputMVartakeMVarnewMVar newEmptyMVarControl.Concurrent.Chan.LiftedwriteList2ChangetChanContentsdupChanreadChan writeChannewChan0transformers-base-0.4.5.2-BhLYwiQwhWJHqbdgZJP6qvControl.Monad.Base MonadBaseliftBase liftThroughliftBaseOpDiscardliftBaseDiscard liftBaseOpcaptureMcaptureTcontroldefaultRestoreMdefaultLiftBaseWithdefaultRestoreT2defaultLiftWith2defaultRestoreTdefaultLiftWithMonadTransControlStTliftWithrestoreTRun RunDefault RunDefault2MonadBaseControlStM liftBaseWithrestoreM RunInBase ComposeStRunInBaseDefault0mono-traversable-1.0.12.0-GUp7QAYjSZIGKqcb8aGycJData.SequencesrepackunpackpacksortOn catMaybessortreplaceSeqLazyTextsplitSeqLazyTextreplaceSeqStrictTextsplitSeqStrictTextstripSuffixLazyBSstripPrefixLazyBSsplitSeqLazyBSstripSuffixStrictBSstripPrefixStrictBSsplitElemStrictBSdeleteBydeletegroupAll isInfixOf isSuffixOf isPrefixOf ensureSuffix ensurePrefix dropSuffix dropPrefix stripSuffix stripPrefix replaceSeqsplitSeq splitEleminitDeftailDef defaultSnoc defaultCons vectorSort vectorSortBydefaultSplitWhen defaultSortBydefaultReversedefaultIntersperse defaultFind singleton SemiSequenceIndexsortByreversefind intersperseconssnoc IsSequencefromListfilterindex takeWhiletake unsafeIndex unsafeDropuncons replicate dropWhiledropsplitAtspanbreak partitiongroupBy subsequences permutationsfilterM replicateMunsnoc unsafeTake unsafeTail unsafeInit lengthIndex unsafeSplitAtdropEnd groupAllOntailExtailMayinitExinitMayindexEx splitWhenTextualtoUppertoLowerlinesunlineswordsunwords breakLine toCaseFold breakWord LazySequence fromStrict fromChunkstoChunkstoStrictUtf8 encodeUtf8 decodeUtf8Data.MonoTraversable.UnprefixedlengthnullData.Containers SetContainer ContainerKeymemberunion notMemberunions difference intersectionkeysPolyMap differenceMapintersectionMapintersectionWithMap BiPolyMapBPMKeyConstraint mapKeysWithIsMapMapValuelookup insertWithupdateLookupWithKey insertWithKeyinsertLookupWithKeyfindWithDefault adjustWithKey updateWithKey unionsWith unionWith unionWithKey mapWithKey insertMap deleteMap singletonMap mapFromList mapToList adjustMap updateMapalterMap omapKeysWith filterMapIsSet insertSet deleteSet singletonSet setFromList setToList filterSetMonoZipozipWithozipounzip HasKeysSetKeySetkeysSet.safe-exceptions-0.1.7.0-K31d9eGVLajFrIQnbtvxu5Control.Exception.Safe catchesAsync catchesDeepcatchesisAsyncExceptionisSyncExceptiontoAsyncExceptiontoSyncExceptionbracketWithErrorbracketOnError_bracketOnErrorfinallybracket_bracket withException onExceptiontryJusttryAsync tryAnyDeeptryDeeptryAnytryIOtry handleJust handleAsync handleAnyDeep handleDeep handleAnyhandleIO catchJust catchAsync catchAnyDeep catchDeepcatchAnycatchIO impureThrowthrowTo throwStringthrowIOthrowStringExceptionSyncExceptionWrapperAsyncExceptionWrapper stm-2.5.0.0Control.Concurrent.STM.TArrayTArrayControl.Concurrent.STM.TVar mkWeakTVarswapTVar stateTVar modifyTVar' modifyTVarControl.Concurrent.STM.TQueue isEmptyTQueue unGetTQueue tryPeekTQueue peekTQueue flushTQueue tryReadTQueue readTQueue writeTQueue newTQueueIO newTQueueTQueueControl.Concurrent.STM.TMVar mkWeakTMVar isEmptyTMVar swapTMVar tryReadTMVar readTMVar tryPutTMVarputTMVar tryTakeTMVar takeTMVarnewEmptyTMVarIO newEmptyTMVar newTMVarIOnewTMVarTMVarControl.Concurrent.STM.TChan cloneTChan isEmptyTChan unGetTChandupTChan tryPeekTChan peekTChan tryReadTChan readTChan writeTChannewBroadcastTChanIOnewBroadcastTChan newTChanIOnewTChanTChanControl.Concurrent.STM.TBQueue isFullTBQueueisEmptyTBQueue lengthTBQueue unGetTBQueuetryPeekTBQueue peekTBQueue flushTBQueuetryReadTBQueue readTBQueue writeTBQueue newTBQueueIO newTBQueueTBQueue(stm-chans-3.0.0.4-HYjkOAxusm59Rsr7teGCcbControl.Concurrent.STM.TBMQueuefreeSlotsTBMQueueestimateFreeSlotsTBMQueueisFullTBMQueueisEmptyTBMQueueisClosedTBMQueue closeTBMQueue unGetTBMQueuetryWriteTBMQueue writeTBMQueuetryPeekTBMQueue peekTBMQueuetryReadTBMQueue readTBMQueue newTBMQueueIO newTBMQueueTBMQueueData.Time.Format formatTimeNumericPadOption FormatTimeformatCharacterData.Time.Format.Parse readsTimereadTime parseTime readPTime readSTimeparseTimeOrError parseTimeM ParseTime buildTime&Data.Time.LocalTime.Internal.ZonedTimeutcToLocalZonedTime getZonedTimezonedTimeToUTCutcToZonedTime ZonedTimezonedTimeToLocalTime zonedTimeZoneData.Time.Format.Localerfc822DateFormatiso8601DateFormatdefaultTimeLocale TimeLocalewDaysmonthsamPm dateTimeFmtdateFmttimeFmt time12FmtknownTimeZones&Data.Time.LocalTime.Internal.LocalTimelocalTimeToUT1ut1ToLocalTimelocalTimeToUTCutcToLocalTime LocalTimelocalDaylocalTimeOfDay&Data.Time.LocalTime.Internal.TimeOfDaytimeOfDayToDayFractiondayFractionToTimeOfDaytimeOfDayToTimetimeToTimeOfDaylocalToUTCTimeOfDayutcToLocalTimeOfDaymakeTimeOfDayValidmiddaymidnight TimeOfDaytodHourtodMintodSec%Data.Time.LocalTime.Internal.TimeZonegetCurrentTimeZone getTimeZoneutctimeZoneOffsetStringtimeZoneOffsetString'hoursToTimeZoneminutesToTimeZoneTimeZonetimeZoneMinutestimeZoneSummerOnly timeZoneName Data.Time.Clock.Internal.UTCDiff diffUTCTime addUTCTimeData.Time.Clock.POSIXgetCurrentTime&Data.Time.Clock.Internal.UniversalTime UniversalTime ModJulianDategetModJulianDate#Data.Time.Clock.Internal.SystemTimegetTime_resolution nominalDaydiffTimeToPicosecondspicosecondsToDiffTimesecondsToDiffTimeData.Time.Calendar.GregorianaddGregorianYearsRollOveraddGregorianYearsClipaddGregorianMonthsRollOveraddGregorianMonthsClipgregorianMonthLength showGregorianfromGregorianValid fromGregorian toGregorianData.Time.Calendar.OrdinalDate isLeapYearData.Time.Calendar.DaysdiffDaysaddDaysDayModifiedJulianDaytoModifiedJulianDayliftBaseDefault'uuid-types-1.0.3-Ch4DBmGyJLS7uw4hSXblWiData.UUID.Types.InternalUUIDtshowretrySTMnewUUIDwithTimedFastLoggernewTimedFastLoggerwithFastLogger newFastLogger rmLoggerSetrenewLoggerSet flushLogStr pushLogStrLn pushLogStr newLoggerSetnewStderrLoggerSetnewStdoutLoggerSetnewFileLoggerSet LoggerSet FastLoggerTimedFastLoggerSystem.Log.FastLogger.DatesimpleTimeFormat'simpleTimeFormat newTimeCacheSystem.Log.FastLogger.File prefixTimerotate FileLogSpeclog_file log_file_sizelog_backup_numberTimedFileLogSpectimed_log_file timed_timefmttimed_same_timeframetimed_post_processSystem.Log.FastLogger.Types FormattedTime TimeFormatSystem.Log.FastLogger.IOdefaultBufSizeBufSizeSystem.Log.FastLogger.LogStr fromLogStr logStrLengthLogStrToLogStrtoLogStrtemplate-haskellLanguage.Haskell.TH.SyntaxLoc loc_filename loc_package loc_module loc_startloc_end(interpolate-0.2.0-BNmYuHQAP6hJqcbMZxDMTI Data.String.Interpolate.IsStringi logOtherCS logErrorCS logWarnCS logInfoCS logDebugCS logOtherNS logErrorNS logWarnNS logInfoNS logDebugNS logOtherN logErrorNlogWarnNlogInfoN logDebugN logWithoutLoc defaultLoc mapNoLoggingT mapLoggingT filterLoggerwithChannelLoggerunChanLoggingTrunChanLoggingTrunStdoutLoggingTrunStderrLoggingTrunFileLoggingT defaultLogStrexecWriterLoggingTrunWriterLoggingT logOtherS logErrorSlogWarnSlogInfoS logDebugSliftLoc logOtherSH logErrorSH logWarnSH logInfoSH logDebugSHlogOtherlogErrorlogWarnlogInfologDebug LogSource MonadLoggermonadLoggerLog MonadLoggerIO askLoggerIO NoLoggingT runNoLoggingTWriterLoggingTunWriterLoggingTLoggingT runLoggingT LoggerRefloggerCallback newLoggerRefEndPoint NodeEndPointssecureEndPoint tcpEndPoint endPointPort endPointIp emptyEndPointCallbackfulfillreject tryRetrieveretrieve fromEither newPromise newCallbackFlag flagWord8 KeepRetryingAtMost credPassword credLogin AuthenticatedNoneBusHub SubscribePublishSubsubscribeEventHandlerPub publishSTMMessage EventStore getSettings freshUUID publisherstopBus runEventStoretoMsgfromMsgpublish publishWithasSubasPubasHubbusStopbusProcessedEverythingnewBusmonitorIncrPkgCountmonitorIncrConnectionDropmonitorAddDataTransmittedmonitorIncrForceReconnectmonitorIncrHeartbeatTimeouts DiscoverygossipEndpoint runDiscoveryDnsDiscoveryExceptionMaxDiscoveryAttemptReachedDNSDiscoveryErrorstaticEndPointDiscoverysimpleDnsEndPointDiscoveryclusterDnsEndPointDiscovery Stopwatch newStopwatchstopwatchElapsed prettyWord8cmdDesccmdWord8heartbeatRequestCmdheartbeatResponseCmdwriteEventsCmdwriteEventsCompletedCmdtransactionStartCmdtransactionStartCompletedCmdtransactionWriteCmdtransactionWriteCompletedCmdtransactionCommitCmdtransactionCommitCompletedCmddeleteStreamCmddeleteStreamCompletedCmd readEventCmdreadEventCompletedCmdreadStreamEventsForwardCmd#readStreamEventsForwardCompletedCmdreadStreamEventsBackwardCmd$readStreamEventsBackwardCompletedCmdreadAllEventsForwardCmd readAllEventsForwardCompletedCmdreadAllEventsBackwardCmd!readAllEventsBackwardCompletedCmdsubscribeToStreamCmdsubscriptionConfirmationCmdstreamEventAppearedCmdunsubscribeFromStreamCmdsubscriptionDroppedCmd"connectToPersistentSubscriptionCmd%persistentSubscriptionConfirmationCmd,persistentSubscriptionStreamEventAppearedCmdcreatePersistentSubscriptionCmd(createPersistentSubscriptionCompletedCmddeletePersistentSubscriptionCmd(deletePersistentSubscriptionCompletedCmd"persistentSubscriptionAckEventsCmd"persistentSubscriptionNakEventsCmdupdatePersistentSubscriptionCmd(updatePersistentSubscriptionCompletedCmd badRequestCmd notHandledCmdauthenticateCmdauthenticatedCmdnotAuthenticatedCmdidentifyClientCmdclientIdentifiedCmd unknownCmd getCommand_cmdDictPackageResolvedEventBufResolvedIndexedEvent EventRecordNewEventInternalExceptionConnectionClosedByServer eventDataTypeeventMetadataTypeeventDataByteseventMetadataBytesexpVersionInt64newEventtoUTCnewRecordedEventnewResolvedEventnewResolvedEventFromBufheartbeatResponsePackage$aeson-1.4.5.0-9WciqreC8Dh4Ox91K72izuData.Aeson.Types.InternalObjectcustomMetaToPairsPair cleanPairs streamACLJSON'protobuf-0.2.1.2-FW3zKrbfARcLEYYMkYp5ACData.ProtocolBuffers.TypesValuestreamMetadataJSON p_readRoles p_writeRoles p_deleteRolesp_metaReadRolesp_metaWriteRolesp_maxAge p_maxCountp_truncateBeforep_cacheControlp_aclinternalMetaPropertieskeepUserPropertiesparseNominalDiffTimeparseStreamACLparseStreamMetadatabuild strategyTextstrategyFromTextDuration packageCred packageDatapackageCorrelation packageCmdresolvedEventBufPreparePositionresolvedEventBufCommitPositionresolvedEventBufLinkresolvedEventBufEvent NotHandledBufnotHandledAdditionalInfonotHandledReason MasterInfomasterExternalSecureTcpPortmasterExternalSecureTcpAddrmasterExternalHttpPortmasterExternalHttpAddrmasterExternalTcpPortmasterExternalTcpAddr MasterInfoBufbufMasterExternalSecureTcpPortbufMasterExternalSecureTcpAddrbufMasterExternalHttpPortbufMasterExternalHttpAddrbufMasterExternalTcpPortbufMasterExternalTcpAddrNotHandledReason N_NotMaster N_TooBusy N_NotReadyresolvedIndexedLinkresolvedIndexedRecordeventRecordCreatedEpocheventRecordCreatedeventRecordMetadataeventRecordDataeventRecordMetadataTypeeventRecordDataTypeeventRecordType eventRecordIdeventRecordNumbereventRecordStreamIdnewEventMetadata newEventDatanewEventMetadataTypenewEventDataType newEventType newEventId StreamExists EmptyStreamExactAnyJsonBinary eventDataeventId eventType eventTypeTexteventTypeFromStrresolveLinkToBool masterInfomasterInfoNodeEndPointspackageDataAsTextheartbeatRequestPackageparseSingleOrMultiple msDuration secsDuration)PersistentSubscriptionStreamEventAppeared"PersistentSubscriptionConfirmationPersistentSubscriptionNakEventsPersistentSubscriptionAckEventsConnectToPersistentSubscription%UpdatePersistentSubscriptionCompleted"UpdatePersistentSubscriptionResultUpdatePersistentSubscription%DeletePersistentSubscriptionCompleted"DeletePersistentSubscriptionResultDeletePersistentSubscription%CreatePersistentSubscriptionCompleted"CreatePersistentSubscriptionResultCreatePersistentSubscriptionUnsubscribeFromStreamSubscriptionDroppedStreamEventAppearedSubscriptionConfirmationSubscribeToStreamsubscribeToStream_createPersistentSubscription_deletePersistentSubscription_updatePersistentSubscription _connectToPersistentSubscriptionpersistentSubscriptionAckEventspersistentSubscriptionNakEventspsseaEvtpscLastEvtNumberpscIdpscLastCommitPos psneActionpsneMsgpsneProcessedEvtIdspsneIdpsaeProcessedEvtIdspsaeIdctsAllowedInFlightMsgs ctsStreamIdctsId upscReason upscResultUPS_AccessDeniedUPS_FailUPS_DoesNotExist UPS_SuccessupsNamedConsStrategyupsSubMaxCountupsChkPtMinCountupsChkPtMaxCountupsChkPtAfterTimeupsPreferRoundRobinupsMaxRetryCount upsBufSizeupsReadBatchSizeupsLiveBufSizeupsRecordStats upsMsgTimeout upsStartFromupsResolveLinkTos upsStreamId upsGroupName dpscReason dpscResultDPS_AccessDeniedDPS_FailDPS_DoesNotExist DPS_Success dpsStreamId dpsGroupName cpscReason cpscResultCPS_AccessDeniedCPS_FailCPS_AlreadyExists CPS_SuccesscpsNamedConsStrategycpsSubMaxCountcpsChkPtMinCountcpsChkPtMaxCountcpsChkPtAfterTimecpsPreferRoundRobincpsMaxRetryCount cpsBufSizecpsReadBatchSizecpsLiveBufSizecpsRecordStats cpsMsgTimeout cpsStartFromcpsResolveLinkTos cpsStreamId cpsGroupName dropReasonstreamResolvedEventsubscribeLastEventNumbersubscribeLastCommitPossubscribeResolveLinkTossubscribeStreamId PersistAction SubActionConnectionReset ConfirmedDroppedSubmit PersistDelete PersistUpdate PersistCreatesubSubIdsubLastEventNum subCommitPossubIdtoSubDropReasoncreateRExceptiondeleteRExceptionupdateRException streamIdRawResponseResultRequest newRequest_error _endOfStream _lastNumber _nextNumber_result_events_lastCommitPosition ACCESS_DENIEDERROR NOT_MODIFIEDSTREAM_DELETED NO_STREAMSUCCESS_requireMaster_resolveLinkTos _maxCount _eventNumber _streamId _indexedEvent NOT_FOUND_Error_Result_NextPreparePosition_NextCommitPosition_Events_PreparePosition_CommitPosition_preparePosition_commitPositioncreateAckPackagecreateNakPackagecreateUnsubscribePackagecreateAuthPackageErrorMsg UnknownMsgNotAuthenticatedMsg NotHandledMsg BadRequestMsgConfirmationMsgPersistentConfirmationMsgRegularConfirmationMsgLiveMsg DroppedMsgPersistentEventAppearedMsgEventAppearedMsg ServerMessageconfirmationCommitPosconfirmationLastEventNumconfirmationPersistentSubIddecodeServerMessagemaybeDecodeMessagenewIdentifyPkgnewAuthenticatePkgOpResultfreshIdfailureretry sendRemote waitRemotesendrequest runFirstMatch waitForOr wrongVersion streamDeletedinvalidTransaction accessDeniedprotobufDecodingError serverErrorinvalidServerResponse(streaming-0.2.2.0-KgxN3O1cM4lA0LLkvoX7vtStreaming.InternalStreamStepEffectReturnExpect OperationCode ExecutionProceedFailedNeedNeedUUID NeedRemote WaitRemote CoroutineStopYieldAwaitPayload payloadCmd payloadData payloadCreds OP_SUCCESSOP_PREPARE_TIMEOUTOP_COMMIT_TIMEOUTOP_FORWARD_TIMEOUTOP_WRONG_EXPECTED_VERSIONOP_STREAM_DELETEDOP_INVALID_TRANSACTIONOP_ACCESS_DENIEDstopyield traversingappend unfolding<~ construct _firstNumber_message_expectedVersioneventToNewEvent writeEventsvolatile CommittedCommitWrittenWriteStartedStartnewStartnewWrite newCommit _ccMessage _ccResult _ccTransId_cRequireMaster _cTransId _wwMessage _wwResult _wwTransId_wRequireMaster _wTransId_transIdtransactionStartreadStreamEventsreadMetaStream setMetaStream readAllEvents createPersist updatePersist deletePersistpersist _hardDeletecatchup SendPackageNewTimerServiceTerminatedSubmitOperationFatalExceptionFatalCondition InitFailed InitializedService TimerServiceConnectionManagerSystemShutdown SystemInit timerServicesubmitdropped confirmedsubUnsubscribe putPackage mandatorySizeConnectionEstablishedConnectionClosedConnectionErrorPackageArrived connectionIdconnectionEndPointenqueuePackagedispose ConnectionRefmaybeConnection RecvOutcome ResetByPeerRecv WrongFraming ParsingErrorConnectionBuilder getConnectionconnectionErrorconnectionBuilderDecisionHandled ReconnectRegistry newRegistryregisterabortPendingRequests handlePackage checkAndRetrystartAwaitingsManagernewhandlecleanupcheckconnectionManagerExecexecWaitTillClosed execSettings TerminatednewExec_regNext _regPhase _regStream_regExecPhaseRunningClosedPendingnewRegularSubscription_perNext _perPhase_perCred _perStream_perExecnewPersistentSubscription _catchupNext _catchupTrack _catchupPhase_catchupStream _catchupExec CatchingUpreceivedAlready nextTargetnewCatchupSubscription throwClosed _unTransId_tConn_tExpVer _tTransId_tStream_type _settings_execreadEventsCommonsubscribeFromCommon persistAsyncControl.Monad.Trans.ExceptExceptTversion getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileName