úÎÕÖYrÿ±      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°3(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]'9Generalized version of ±.<1Only perform the action if the predicate returns ².=1Only perform the action if the predicate returns ³.ÿ´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ ³²       +,  !"# $%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•-/.!"–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ*      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ67„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstu8vwxyz{|}~€‚ƒ„…†‡ˆ9:;<=(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]5åq‰Š‹ŒŽ‘’“”•–—˜)('&%$#™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛ543210ÜÝÞßàáâãäåæ>?@ABC>çè?@A(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]:H Gathers both an IPv4 and a port. DEGFHIKJLDEFGHIJK(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+16<>?FKQTV]QìM7Contains settings related to a connection to a cluster.O.The DNS name to use for discovering endpoints.P9The maximum number of attempts for discovering endpoints.Q>The well-known endpoint on which cluster managers are running.R.Endpoints for seeding gossip if not using DNS.STimeout for cluster gossip.T4Indicates a specific DNS server should be contacted.U-Tells how the DNS server should be contacted.Y&Procedure used to discover an network H.\&Represents a source of cluster gossip.éúThe 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.]2The host header to be sent when requesting gossip.a Creates a \.b Creates a \ with a specific HTTP header.cReturns \ host IP address.dReturns \ port.g Configures a M¾ for connecting to a cluster using gossip seeds. clusterDns = "" clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipTimeout = 1sh Configures a MÄ for connecting to a cluster using DNS discovery. clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipSeeds = Nothing clusterGossipTimeout = 1s!HIJKMNOPQRSTUVWXYZ[\]^_`abcdefghi êëìíîïðñòóôõö÷øùúûüýþÿ      MNOPQRSTUVWXYZ[\é]^_`(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+<>?FQTV]UØjklmnopqj(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]nrGlobal  Connection settingstKMaximum delay of inactivity before the client sends a heartbeat request.u;Maximum delay the server has to issue a heartbeat response.vUOn a cluster settings. Requires the master node when performing a write operation.w„) used for an authenticated communication.x'Retry strategy when failing to connect.y.Delay before issuing a new connection request.z SSL settings.{Type of logging to use.|$Restriction of what would be logged.}]Detailed logging output. Currently, it also indicates the location where the log occurred.~CDelay in which an operation will be retried if no response arrived.)Retry strategy when an operation timeout.€EKG metric store.!Represents reconnection strategy.„%Holds login and password information.ˆIndicates either a Package contains „ data or not.‹Maps a ˆ into a  understandable by the server.Œ Creates a „ given a login and a password.uIndicates how many times we should try to reconnect to the server. A value less than or equal to 0 means no retry.ŽTIndicates we should try to reconnect to the server until the end of the Universe.Default global settings. t = 750 msu = 1500 msv = ²w =  x =  3y = 3 secondsz =  { = (| = A 3} = ³~ = 10 seconds =  3€ =  Default SSL settings based on .‘Millisecond timespanŒLoginPassword rs€~}|{zyxwvutƒ‚„…‡†ˆŠ‰‹ŒŽ‘rstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+1<>?FKQTV]qá?rstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯° ’ !"#$%&'()*+,“-”.•/–—˜™š0›12345678 (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]uè9:;9<=>?@ (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]z±0Represents a regular stream name or $all stream.´3A stream can either point to $all or a regular one.±³²´¶µA±²³´µ¶ (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]|œB (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FKQTV]‚· Internal command representation.4·¸º¹»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéê·¸¹º(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-16<>?FKQTV] ¤˜í/Gathers every persistent subscription property.ïbWhether or not the persistent subscription should resolve linkTo events to their linked events.ð4Where the subscription should start from (position).ñUWhether or not in depth latency statistics should be tracked on this subscription.ò[The amount of time after which a message should be considered to be timeout and retried.ó_The maximum number of retries (due to timeout) before a message get considered to be parked.ôAThe size of the buffer listening to live messages as they happen.õ;The number of events read at a time when paging in history.ö;The number of events to cache when paging through history.÷+The amount of time to try checkpoint after.ø-The minimum number of messages to checkpoint.ùgThe maximum number of message to checkpoint. If this number is reached, a checkpoint will be forced.ú*The maximum number of subscribers allowed.û@The strategy to use for distributing events to client consumers.üKSystem supported consumer strategies for use with persistent subscriptions.ý_Distributes events to a single client until it is full. Then round robin to the next client.þ;Distributes events to each client in a round robin fashion.ÿNRepresents stream metadata as a series of properties for system data and a   object for user metadata.3When the stream is either not found or 'no stream'. When the stream is soft-deleted.The name of the stream.#The version of the metadata format.A  $ containing user-specified metadata.A  applies to  .A  applies to ."Allows to build a structure using   functions. Represents stream metadata with strongly typed properties for system values and a dictionary-like interface for custom values. 3The maximum number of events allowed in the stream. 0The maximum age of events allowed in the stream. tThe event number from which previous events can be scavenged. This is used to implement soft-deletion of streams.9The amount of time for which the stream head is cachable.'The access control list for the stream.TAn enumerable of key-value pairs of keys to JSON text for user-provider metadata./Represents an access control list for a stream.-Roles and users permitted to read the stream.1Roles and users permitted to write to the stream.2Roles and users permitted to delete to the stream.2Roles and users permitted to read stream metadata.3Roles and users permitted to write stream metadata.ARepresents a package exchanged between the client and the server.PRepresents the direction of read operation (both from $all an usual streams).From beginning to end From end to beginning!BA structure representing a single event or an resolved link event.#.The event, or the resolved link event if this ! is a link event.$The link event if this ! is a link event.% Possible 0 of that event.&&Represents a previously written event.(-The event stream that this event belongs to.)*Unique identifier representing this event.*#Number of this event in the stream.+Type of this event.,$Representing the data of this event.-5Representing the metadada associated with this event..;Indicates whether the content is internally marked as json./7Representing when this event was created in the system.0cA structure referring to a potential logical record position in the EventStore transaction file.2Commit position of the record3Prepare position of the record4KRepresents a serialized event sent by the server in a subscription context.RORepresents a serialized event representiong either an event or a link event.V5Represents a serialized event coming from the server.bSerializes form of an s.j,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 j except for  anyStream . When using  anyStream` the EventStore will do its best to assure idempotency but will not guarantee idempotency.pHolds event data.sRContains event information like its type and data. Only used for write queries.x!Constants for System event types.yEvent type for stream deleted.zEvent type for statistics.{Event type for linkTo.|Event type for stream metadata.}#Event type for the system settings.~Event defined by the user.jRepresent a class of error where the user is not at fault. It could be either the client or the server.€æHappens 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.ƒ Create an s meant to be persisted.„Maps s inner data type to an   understandable by the server.…Maps s inner metadata type to an  ! understandable by the server.†"Creates an event using JSON format‡'Creates an event using a binary format.ˆ1Creates an event with metadata using JSON format.‰3Creates an event with metadata using binary format.Š Serializes  EventData's data to a raw  .‹ Serializes p metadata to a raw  .ŒMaps a j to an   understandable by the server.GThis write should not conflict with anything and should always succeed.ŽjThe stream being written to should not yet exist. If it does exist treat that as a concurrency problem.zThe stream should exist and should be empty. If it does not exist or is not empty, treat that as a concurrency problem.oStates that the last event written to the stream should have a sequence number matching your expected value.‘jThe stream should exist. If it or a metadata stream does not exist treat that as a concurrency problem.’b smart constructor.•/Representing the start of the transaction file.–-Representing the end of the transaction file.—*Tries to parse JSON object from the given &.˜Converts 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)™ Constructs a & from an V.š Constructs a ! from a R.› Constructs a ! from a 4.œDReturns the event that was read or which triggered the subscription.If this !a represents a link event, the link will be the original event, otherwise it will be the event.Tries to desarialize œ data as JSON.žIndicates whether this ! is a resolved link event.Ÿ&The stream name of the original event. The ID of the original event.¡'The event number of the original event.¤*Constructs a heartbeat response given the C of heartbeat request.¥" with no role or users whatsoever.¦+Gets a custom property value from metadata.§*Get a custom property value from metadata.¨  with everything set to  , using ¥ and an empty D.©Maps an D to a list of E to ease the  .ª Serialized a  to F for serialization purpose.« Serialized a   to F for serialization purpose.¬Read ACL property.­Write ACL property.®Delete ACL property.¯Metadata read ACL property.°Metadata write ACL property.±Max age metadata property.²Max count metadata property.³#truncated before metadata property.´ Cache control metadata property.µACL metadata property.¶2Gathers every internal metadata properties into a ". It used to safely   in JSON.·,Only keeps the properties the users has set.¸ Parses a 8 from an D given a JSON property.¹Parses .ºParses  .»Build a structure given a  and an initial value.¼4Sets role names with read permission for the stream.½<Sets a single role name with read permission for the stream.¾5Sets role names with write permission for the stream.¿=Sets a single role name with write permission for the stream.À6Sets role names with delete permission for the stream.Á>Sets a single role name with delete permission for the stream.Â=Sets role names with metadata read permission for the stream.ÃESets a single role name with metadata read permission for the stream.Ä>Sets role names with metadata write permission for the stream.ÅFSets a single role name with metadata write permission for the stream.Æ Builds a  from a .Ç Modifies a  using a .È8Sets the maximum number of events allowed in the stream.É5Sets the maximum age of events allowed in the stream.ÊBSets the event number from which previous events can be scavenged.Ë>Sets the amount of time for which the stream head is cachable.ÌOverwrites any previous  by the given one in a .Í Updates a StreamMetadata's  given a .Î Sets a custom metadata property.Ï Builds a   from a .Ð Modifies a   using a ÑMaps a ü to a   understandable by the server.ÒTries to parse a ü given a raw  .Ó0System default persistent subscription settings.ƒ Event typeEvent ID, generated if   Event data’ Event typeEvent IDData content typeMetadata content type Event dataMetadataëëìíîûúùø÷öõôóòñðïüþýÿ      !"%$#&'/.-,+*)(0132459876:;=<>?EDCBA@FGMLKJIHNQPORSUTVWa`_^]\[ZYXbcihgfedjomnlkpqrstwvux~}|{zy€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%& '()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUV WXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV](¤GSAvalaible event sent by the server in the context of a persistent subscription..H/Connection to persistent subscription response.INak processed events request.Ö#Gathers every possible Nak actions.JAck processed events request.K-Connect to a persistent subscription request.L(Update persistent subscription response.M'Update persistent subscription outcome.N'Update persistent subscription request.O(Delete persistent subscription response.P'Delete persistent subscription outcome.Q'Delete persistent subscription request.R(Create persistent subscription response.S'Create persistent subscription outcome.T'Create persistent subscription request.UQA message sent to the server to indicate the user asked to end a subscription.VBA message sent by the server when a subscription has been dropped.Ü1Represents the reason subscription drop happened.WVSerialized event sent by the server when a new event has been appended to a stream.X(Stream subscription connection response.Y'Stream subscription connection request.ZY smart constructor.[T smart constructor.\Q smart construction.]N smart constructor.^K smart constructor._J smart constructor.`I smart constructor.}GabHcdefIghijkÖÛÚÙØ×JlmnKopqrLstuMvwxyNz{|}~€‚ƒ„…†‡ˆ‰ŠO‹ŒPŽ‘Q’“”R•–—S˜™š›TœžŸ ¡¢£¤¥¦§¨©ª«¬U­V®¯ÜáàßÞÝW°±X²³´Yµ¶·Z[\]^_`GabHcfedIgkjihÖרÙÚÛJlnmKorqpLsutMyxwvNzЉˆ‡†…„ƒ‚€~}|{O‹ŒP‘ŽQ’”“R•—–S›š™˜Tœ¬«ª©¨§¦¥¤£¢¡ ŸžU­V®¯ÜÝÞßàáW°±X²´³Yµ·¶(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]?›â,Enumerates all persistent action exceptions.ãThe action failed.ä_Happens when creating a persistent subscription on a stream with a group name already taken.å`An operation tried to do something on a persistent subscription or a stream that don't exist.æ`The current user is not allowed to operate on the supplied stream or persistent subscription.çThat action has been aborted because the user shutdown the connection to the server or the connection to the server is no longer possible.¸Type of persistent action.èzSubscription runtime details. Not useful for the user but at least it makes Haddock documentation generation less ugly.éRepresents a subscription id.ì.Indicates why a subscription has been dropped.í4Subscription connection has been closed by the user.îBThe current user is not allowed to operate on the supplied stream.ï Given stream name doesn't exist.ðGiven stream is deleted.ñwOccurs when the user shutdown the connection from the server or if the connection to the server is no longer possible.ó!Unexpected error from the server.(¹º»¼½âçæåä㸾¿ÀèÁÂÃÄÅéÆêëìöõôóòñðïîíÇÈÉʹ½¼»ºâãäåæç¸À¿¾èÁÅÄÃÂéÆêëì íîïðñòóôõö(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]EúË&Batch read on regular stream response.ÌJEnumeration detailing the possible outcomes of reading a slice of a streamÍ%Batch read on regular stream request.ÎÍ smart constructor.ËÏÐÑÒÓÔÕÖÌרÙÚÛÜÍÝÞßàáâÎËÏÕÔÓÒÑÖÐÌÜÛÚÙØ×ÍÝâáàßÞ(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]Kåã(Read event on a regular stream response.äEEnumeration representing the status of a single event read operation.å'Read event on a regular stream request.æå smart constructor.ãçèéêäëìíîïðåñòóôõæãçêèéäðëïîíìåñõôóò(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]Q¨ö#Batch read on $all stream response.÷QEnumeration detailing the possible outcomes of reading a slice of $all stream.ø"Batch read on $all stream request.ùø smart constructor.öúûüýþÿ÷ø   ùöúÿþýüû÷ø   (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]Z¦ ÷&Represents a slice of the $all stream.øRegular stream slice.ù Gathers common slice operations.û Gets slice's !s.üGets slice's reading direction.ý+If the slice reaches the end of the stream.þ)Gets the starting location of this slice.ÿ%Gets the next location of this slice.!Returns a common view of a slice.@Enumeration detailing the possible outcomes of reading a stream.)  ÷ø !"#ùÿþýüûú  ÷ø#"! ùúûüýþÿ(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]a\$*Creates a regular subscription connection .%-Creates a persistent subscription connection .&"Creates a persistent subscription .' Creates Ack .( Create Nak .)Create an unsubscribe .$%&'()(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]cÆ*+,-./0123456789:;<=>*.-,+/1025436987(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-1<>?FKQTV]wã?Instruction that composed an @.=Operation exception that can occurs on an operation response. Stream and Expected Version Stream Stream Expected, FoundReason7Invalid operation state. If happens, it's a driver bug.cOccurs when the user asked to close the connection or if the connection can't reconnect anymore.A$Operation result sent by the server.BAsks for a unused C.C Raises an .D5Asks to resume the interpretation from the beginning.ELike FB except it discards the correlation id of the network exchange.G&Runs the first expection that matches.FˆSends a message to remote server. It returns the expected deserialized message along with the correlation id of the network exchange.HLike I but will J if the connection reset.I$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.KRaises   exception.LRaises   exception.MRaises   exception.NRaises   exception.ORaises  exception.PRaises  exception.QRaises   exception.¯RSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅJÆÇÈÉÊËÌÍÎÏÐÑÒ?ÓÔÕÖ@רÙÚ     AÛÜÝÞßàáâBCDEFHIKLMNOPQÑÒÓÔÕÖ×ÚÙØ      AÛÜÝÞßàáâ(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]uãWrite events response.äWrite events request.åä smart constructor.åStreamExpected versionEventsRequire masterãæçèéêëìäíîïðñåãæìèçëéêäíñîïð(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]„%#Returned after writing to a stream.$Next expected version of the stream.0 of the write.ò Constructs a b from an s.ò(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]‡Write events operation.(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]‰Vó(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]Æ ôCommit transaction response.õCommit transaction request.ö$Write transactional events response.÷#Write transactional events request.øStart transaction response.ùStart transaction request.úù smart constructor.û÷ smart constructor.üõ smart constructor.$ôýþÿõö   ÷  øùúûüôýÿþõö   ÷  øù(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]”ÆStart transaction operation.Transactional write operation.Transactional commit operation.(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-<>?FQTV]—à+Batch read from a regular stream operation.(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-<>?FQTV]œBJRepresents the result of looking up a specific event number from a stream.#3Read a specific event given event number operation. !"# ! !" (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]Ÿí$Read stream metadata operation.%Set stream metadata operation.$%!(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]¢ß&$Batch read on $all stream operation.&"(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]¥5'()#(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]§“$(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]«Delete stream response.Delete stream request. smart constructor.  !"#$% !%#$"%(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]¯H*"Returned after deleting a stream. 0 of the write.,"Delete a regular stream operation.*+,*+&(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]·¥2Catchup operation state.3BIndicates the stream name and the next event number to start from.4YIndicates the commit and prepare position. Used when catching up from the $all stream.5Represents the next checkpoint to reach on a catchup subscription. Wheither it's a regular stream or the $all stream, it either point to an   or a 0.8Stream catching up operation. -./012345678-./01234567'(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]ºV! !"#$%&'()*+,-./012345678((C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+16<>?CFQTV]½D9:;<=>?@ACBDEFGHJIKLMN 9:;<=>?@ABCDEFGHIJKLMN)(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?CFQTV]ÀX&'()*(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]ËZ O.Common operations supported by a subscription.P&Asks for the next incoming event like U! while still being in the the M.Q.Returns the runtime details of a subscription.RGet subscription stream.S/Asynchronously unsubscribe from the the stream.TAwaits for the next event.UNon blocking version of T.VWaits until the O has been confirmed.WLike X but lives in M monad.XNon blocking version of Y.Y;Wait until unsubscription has been confirmed by the server.Z*If the subscription is on the $all stream.[ Gets the ID of the subscription.ORSQP*+,TUVWXY-Z[OPQRS+(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]ÐE. Serializes a  into raw bytes./The minimun size a C should have. It's basically a command byte, correlation bytes (C) and a ˆ byte.\]^_`abcdefghijklmnopqrstuvw 01234\]^_`abc567defghijklmnopqrst,(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?CFQTV]Ô‹x4Occurs when an operation has been retried more than . xy89:;<=>?@A xy89:;BCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abc-(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]×¶ 89:defghidjk.(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]ÚAl mnopq rstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š/(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]Ýcz|{}~›œžŸz {¡¢|}~£¤¥¦(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]àÿZ´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ ³²       +,  !"# $%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•-/.!"–—˜™š›œžŸ ¡¢£‰Š‹ŒŽ‘’“”•–—˜)('&%$#™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ*     ³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛ543210ÜÝÞßàáâãäåæ !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ67„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstu8vwxyz{|}~€‚ƒ„…†‡ˆ9:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklnmoprqstuvwxyz{|}~€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕ !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMN\]^_`abcdefghijklmnopqrstuvwz{|}~ÿDjpqklnmo·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêMNKLHIJFGDEABC?@=>;<9:rstdefghimnopqbc`a\]^_jkluwv› œ˜™–—“”•§¦¨’«©š¡¢ª£¤¥Ÿž¬­®¯°ˆ‰Š‹„…†‡Œ‚ƒŽrstuvwxyz{|}~€‘YZ[\]^_`MNOPQRSTUVWXHIJKeigfhab]cdHIJKLDEFGz{|}~{|>?@ACB234-./015678*+,'()& ! !"#$% ,+,  !" -/.9:6*;=<7ˆ‰Š‹„…†‡Œ‚ƒŽrstuvwxyz{|}~€‘€xyz{|}~‚stuvwƒpqr„…†‡ˆ‰Š‹jklmnoŒŽ‘bcdefghi’VWXYZ[\]^_`aRSTUNOPQFGHIJKLM>?@ABCDE“”:;<=4567890123•–&'()*+,-./—˜™!"#$%š›œžŸ ¡ ¢£¤¥     ¦§¨©ª«¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÿüýþÑÒíîïðñòóôõö÷øùúûÓëìÔÕ0(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]–€êAlso 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. €§¨©ª«¬­®¯°€§«ª©¨¬­¯®1(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]0éThe 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).‚>Acknowledges those event ids have been successfully processed.ƒAcknowledges that !! has been successfully processed.„Acknowledges those !#s have been successfully processed.…jMark a message that has failed processing. The server will take action based upon the action parameter.†jMark messages that have failed processing. The server will take action based upon the action parameter.‡FAcknowledges those event ids have failed to be processed successfully.±²³´µ¶·¸¹º‚ƒ„…†‡±µ´³²¶·¹¸2(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]ЈÿThis 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.‰Non blocking version of Š.Š Waits until ˆ" subscription catch-up its stream.‹Like ‰ but lives in M monad.ˆ»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎ‰Š‹ˆ»À¿¾½¼ÁÃÂÄÅÇÆ(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-1<>?CFQTV]MÓ!Œ The id of a .;Represents a multi-request transaction with the EventStore.Ž4Represents a connection to a single EventStore node.4Gathers every connection type handled by the client.HostName and Port.’*Domain name, optional DNS server and port.“Creates a new Ž] to a single node. It maintains a full duplex connection to the EventStore. An EventStore ŽÑ 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 މ all operations are handled in a full async manner (even if you call the synchronous behaviors). Many threads can use an EvenStore Ž· 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.” Waits the Ž to be closed.• Returns a Ž 's r.–Asynchronously closes the Ž.—Sends a single s to given stream.˜Sends a list of s to given stream.™Deletes given stream.šGets the id of a .›%Starts a transaction on given stream.œ9Asynchronously writes to a transaction in the EventStore.(Asynchronously commits this transaction.žnThere isn't such of thing in EventStore parlance. Basically, if you want to rollback, you just have to not  a .Ÿ'Reads a single event from given stream. )Reads events from a given stream forward.¡*Reads events from a given stream backward.¢*Reads events from the $all stream forward.£*Reads events from the $all stream backward¤Subcribes to given stream.¥Subcribes to $all stream.¦HSubscribes to given stream. If last checkpoint is defined, this will  Š from that event number, otherwise from the beginning. Once last stream event reached up, a subscription request will be sent using ¤.§Same as ¦ but applied to $all stream.¨.Asynchronously sets the metadata for a stream.©-Asynchronously gets the metadata of a stream.ªBAsynchronously create a persistent subscription group on a stream.«BAsynchronously update a persistent subscription group on a stream.¬BAsynchronously delete a persistent subscription group on a stream.­QAsynchronously connect to a persistent subscription given a group on a stream. — Stream name˜ Stream name™ Stream name Hard delete› Stream nameŸ Stream name Event numberResolve Link Tos  Stream nameFrom event number Batch sizeResolve Link Tos¡ Stream nameFrom event number Batch sizeResolve Link Tos¢ Batch sizeResolve Link Tos£ Batch sizeResolve Link Tos¤ Stream nameResolve Link Tos¥Resolve Link Tos¦ Stream nameResolve Link TosLast checkpoint Batch size§Resolve Link TosLast checkpoint Batch sizeÿG )('&%$#5432108?@AMNOPQRSTUVWX\]abcdghrstuvwxyz{|}~€„ŒŽ‘±²³´µ¶·íîïðñòóôõö÷øùúûüýþÿ      !"#$%&'()*+,-./0123jpsxyz{|}~ƒ†‡ˆ‰Ž‘•–—œžŸ ¡¥¦§¨¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÓÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"*+ORSQPTUVWXYZ[xy€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­ÿPŽ‘’„rstuvwxyz{|}~€ŽŒ“–”•MNOPQRSTUVWX\]abc]dghspxyz{|}~ƒ†ˆ‡‰xyÿŸ£¢¡ ©     ¦§¥¨™—˜¨ÆÇ¼½¾¿ÀÁÂÃÄÅÏÐÈÉÊËÌÍÎŒ›šžœêëéOPQRSìíîïðñòóôõöèVXWYPQSR€¤¥[ZTUˆ¦§Š‰‹íîïðñòóôõö÷øùúûüýþÖרÙÚÛâãäåæçƒ„…†‚‡Óª«¬­ùúûüýþÿ÷*+&'()*+,-./ ! !"´µ¶ø0123 !"#$%     ±²³žœŸ ¡—•–543210)('&%$#?@A·ÜÝÞßàájŽ‘‘ 8ŒÏÐÑÒÓÔÕŽÖ×ØÙ‘’3None"#+<>?FQTV]YKÚÛÜÝÞßàáâ45647849:4;<4;=4;>47?4@A49B4;CDEFGHIJKLMNO4;P4;Q4;R4;S49T49U4VW4VX4VY4Z[4Z\4]^4]^45_4`a4`b4;cdefghijkljmnopqopropsoptopuopvopwxyzGH{GH|de}de~de€‚€ƒ€„€…€†€‡ˆ‰Šˆ‰‹ŒŽ‘’“”••–—˜™™š›œœžŸ  ¡¢£¤¥¦§¨©ª««¬­®¯°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÔÕÖרÙÚÛÜÝÞßà á â ã ä å æ ç è é ê ë ì í î ï ð ñ ò ó ô õ ö ÷ ø ù ú û ü ý þ ÿ                                    ! " # $ % & ' ( ) * + , - . / 0 1 2 3 4 5 6 78899:;<=>?@ABCDEFGHIJJKLMNOPQRSSTUVWXYZZ[\]^_``abcdefghhijkllmnopqrstuuvwxxyz{|}}~€€‚ƒ„…†‡‡ˆ‰Š‹ŒŽ‘’’“”••–—˜™š›œžŸ  ¡¢£¤¥¦§¨©ª«¬­®¯°°±²³´µ¶·¸¹º»¼½¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕÖרÙÚÛÜÝÞßàáâãäåæçèéêëìíîïðñòóôõö÷øùúûüýþÿ      !"#$%&&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOOPQRSTUVWXWYZ[\ ] ^!_"`"a"b%c%c%d&e&e&f&g&h&i&j&k&l&m&n&o(p(p(q(q(r(r(s(s(t(t(u(v(v(w(w(x(y(z({({(|(|*}*~**€**‚*ƒ*„*…*†*‡*ˆ*‰+Š+Š+‹+‹+Œ+Œ+++Ž+Ž+++‘+’+“+“+”+•+–+—+˜+™+š+š+›+œ++ž,Ÿ,Ÿ/ /¡/¢/£/£/¤0¥1¦1§1¨1©1ª1«1¬2­2®2¯2°±²Ž³´µ¶›·¸¹º»d¼½TU¾\¿ÀÁÂôÃÄÅÆÇÈÉÊËÌÍÎ4ÏÐÑÒÐÑÓ4ÔÕ4;Ö4;×4;Ø4ÙÚ4ÙÛ4ÜÝ4ÜÞ4Üß4Üà4Üá4Üâ4Üã4Üä4Üå4Üæ4Üç4ÜèÐéêÐéëÐéì4Ùí4Ùî4Ùï4Ùð4Ùñ4Ùò4Ùó4Ùô4Ùõ4Ùö4Ù÷4Ùø4;ù4;ú4;û4;ü4;ý4;þ4;ÿ4;44444444 Ðé Ðé Ðé Ðé ÐéÐéÐéÐé4Ù4Ù444444;4;4;4;4;4; 4!"4!#4!$4!%4&'4&(4&)4&*4&+ÐÑ,ÐÑ-ÐÑ.ÐÑ/4014024034045674;84;94;:ÐÑ;ÐÑ<ÐÑ=ÐÑ>ÐÑ?ÐÑ@4AB4AC4AD4AE4FG4FH4FIÐÑJ4;K4FL4MNŒOPŒOPŒOQŒOR4ÏSTUVTUWTUXTUYTUZTU[TU\TU]TU^TU_TU`4;a4;b4;c4de4fg4hi4jk4lm4ln4lo4lp4lq4&r4&s4&t4&u4&v4&w4xy4Ïz4Ï{4Ï|4Ï}4Ï~4Ï4Ï€4Ï4Ï‚4σ4Ï„4Ï…4†‡4†‡4ˆ‰4Š‹4†Œ4Ž444‘4’“4’”4’•4’–4’—4’˜4’™4’š4’›4’œ4’4’ž4’Ÿ4’ 4’¡4’¢4’£4’¤4’¥4’¦4’§4’¨4’©4’ª4’«4’¬4’­4’®4’¯4’°4±4²4³4´4µ4!¶4!·4!¸4¹º4¹º4»¼4»½4»¾4»¿4AÀ4AÁ4AÂ4`Ã4ÄÅ4;Æ4;Ç4;È4;É4;Ê4;Ë4ÌÍ4ÌÎ4Ï4ÏÐéÐÐéÑÐéÒŒÓÔÕÖ×ÕÖØÕÖÙÕÖÚÕÖÛÕÖÜÕÖÝÕÖÞÕÖßÕÖàÕÖáÕÖâÕÖâãäåãäæãäçãäèãäéãäêãäëãäìãäíãäîãäïãäðãäñãäòãäóãäôãäõãäöãä÷ãäøãäùãäúãäûãäüãäýãäþãäÿãäãäãäãäãäãäãäãäãäãä ãä ãä ãä de                    ! " # $ % & ' ( ) * +, +- +. /0 /1 /2 34 35 36 37 38 39 3: 3; 3< 3= 3> 3? 3@ 3A 3B 3C 3D EF EG EH EI EJ EKLMNLMOdePdeQdeRdeSdeTdeUdeVdeWdeXdeYdeZde[de\de]de^de_de`deadebdecdeddeedefˆghˆgiˆgjˆgkˆglˆgmˆgnˆgoˆgpˆgqˆgrˆgsˆgtˆguˆgvˆgwˆgxˆgyˆgzˆg{ˆg|ˆg}ˆg~ˆgˆg€ˆgˆg‚ˆgƒˆg„ˆg…ˆg†ˆg‡ˆgˆˆg‰ˆgŠˆg‹ˆgŒˆgˆgŽˆgˆgˆg‘ˆg’ˆg“ˆg”ˆg•ˆg–ˆg—ˆg˜ˆg™ˆgšˆg›ˆgœˆgˆgžˆgŸˆg ˆg¡ˆg¢ˆg£ˆg¤ˆg¥ˆg¦ˆg§ˆg¨ˆg©ˆgªˆg«ˆg¬ˆg­ˆg®ˆg¯ˆg°ˆg±ˆg²ˆg³ˆg´ˆgµˆg¶ˆg·ˆg¸ˆg¹ˆgºˆg»ˆg¼ˆg½ˆg¾ˆg¿ˆgÀˆgÁˆgˆgÈgĈgňgƈgLjgȈgɈgʈgˈg̈g͈ÎψÎЈÎшÎÒˆÎÓˆÎÔˆÎÕˆÎÖˆÎ׈Î؈ÎÙˆÎÚˆÎÛˆÎ܈Î݈ÎÞˆÎ߈ÎàˆÎáˆÎâˆÎãˆÎäˆÎåˆÎæˆÎçˆÎèˆÎéˆÎêˆÎëˆÎìˆÎíˆÎîˆÎïˆÎðˆÎñˆÎòˆÎóˆÎôˆÎõˆÎöˆÎ÷ˆÎøˆÎùˆÎúˆÎûˆÎüˆÎýˆÎþˆÎÿˆÎˆÎˆÎ      !"#$%&'()*++,,--./0.12.13.14.15.67.68.69.6:.6;.6<.6=.6>.6?.6@.AB.AC.AD.AE.AF.AG.AH.AI.AJ.AK.AL.AM.AN.AO.PQ.PR.PS.PT.PU.PV.PW.PX.PY.PZ.P[.P\.P].P^._`._a._b._c._d._e._f._g._h._i._jklmklnkloklpklqklrklskltkluklvklwklxklyklzkl{kl|Œ}~Œ}Œ}€Œ}Œ‚ƒŒ‚„Œ‚…Œ‚†Œ‚‡Œ‚ˆŒ‚‰Œ‚ŠŒ‚‹ŒŒŒŒŽŒŒŒŒŒŒ‘ŒŒ‘ŒŒ’ŒŒ“Œ”•Œ”–Œ”—Œ”˜Œ”˜Œ”™Œ”šŒ”›Œ”œŒ”Œ”žŒ”ŸŒ” Œ¡¢Œ¡£Œ¡¤Œ¡¥Œ¡¦Œ¡¦Œ¡§Œ¡¨Œ©ªŒ©«Œ©¬Œ©­Œ©®Œ©¯Œ©°Œ©±Œ©²Œ©³Œ©³Œ©´Œ©µŒ©¶Œ·¸Œ·¹Œ·ºŒ·»Œ·¼Œ·½Œ·¾Œ·¿Œ·¿Œ·ÀŒ·ÁŒ·ÂŒÃÄŒÃÅŒÆÇŒÈÉŒÈÊŒÈËŒÌ͌ΌÓÏŒÓÐŒÓÑŒÒÓŒÒÔŒÒÕŒÒÖŒÒ׌ÒØŒÒÙŒÒÚŒÒÛŒÜÝŒÞߌÞàŒÞáŒÞâŒÞãLMäopåopæopçopèopéopêopëopìopíopîopïopðopñopòopóopôoõöoõ÷oøùoøúoøûoøüoøýoþÿoþoþoþoþoþooooo   5  5            €€€€€€€€€€€€€ €!€"€#€$€%€&€'€(€)€*€+€,€-€.€/€0€1€2€3€4€5€6€7€8€9€:€;€<€=€>€?€@€A€B€B€C€D€D€E”FGHHIIJKKLMNOPQRSTUVWXYZ[\]^^_`abcdefghij­klmn»o p p q r s t u á v w x y z { | | } ~  € € â ã ä é ê  ‚ ‚ ƒ „ … † ‡ ˆ ‰ ‡ Š Š ‹ Œ  Ž‘’“”’“•–—˜™š›œžŸ ¡¢£¤¥¦§¨©ª«¬­®¯°±²™³š´µ¶›·¸¹ºœ»¼½¾¿žÀÁÂÃÄÅ ÆÇÈÉÊËÌÍÎÏÐÑÒÓÔÕ¡ÖרÙÚÛ£ÜݤÞßàáâã¦äåæçèéêëìíîïðñòó§¨ô©õªö÷«øùúûüýþÿ$%      W      !     "#$%&'( )*++,-./012324567839:;<=>?@ABCDEFGHIJKLMNOPQRFKNSTUVWXYZ[\]^_`abcdefghijklcmncmocmpcmqcmrcmscmtcmucmtcmvcmwcmxcyzcy{cy|cy|cy}c~c~€c~c~c‚ƒc‚_c‚„c‚…c‚†c‚‡c‚ˆc‚‰c‚Šc‚‹c‚Œc‚c‚Žc‚c‚c‘’c‘“c‘”c‘•c‘–c‘—c‘˜c‘™c‘šc‘›c‘œc‘cžŸcž cž¡cž¢cž£cž¤cž¥cž¦cž–cž§cž¨cž©cžªcž«cž¬cž­cž®cž¯cž°cž±cž²cž³cž´cžµcž¶cž·cž¸cž¹cžºcž»cž¼cž½cž¾cž¿cžÀcžÁcžÂcžÃcÄÅcÄÆcÄÇcÄÈcÄÉcÄÊcÄËcÄÌcÄÍcÄÎcÄÏcÄÐcÄÑcÄÒcÄÓcÄÔcÄÕcÄÖcÄ×cÄØcÄÙcÄÚcÄÛcÄÜcÄÜcÄÝcÄÞcÄßcÄàcdácdâcdãcdäcdåcdæcdçcdçcdècdécêëcê½ììíîïðñòÑóôõö÷øùúû   üý)* þÿ    ü)* ýþ#$ $ $$ $ý$)$*$$ $$þ$$))Š)Š)****++++ +!+"+"+#+#+$,%,&,',(,),*,+,,,-,.,(,/,0,1,2,3,4,4,5,6,6,7,8,9,:,;,<,<,=,>,?,?,@,A,B,C,D,E,F,G, , ,H,I-h-J--K-L-M-h-N.O.P.P.Q.Q.Š.Š.R.S.T.U.V.W.2.X.Y.Z.[.\.\.].^._.`.a.b.c.c.d.d.e.e.f.f.g.g.h.i.j.k.l.m.k.n.o.p.q/Š/Š/r/s/t/ /u/v/k/n/w/x0¥0y0z0{0|0}060q0~01¦1€11‚1ƒ1}161q1~1„2­2…2†2‡2ˆ2‰2Š2‹2Œ2}2c2q2~22Ž222‘2’2“±”²•–—˜Ž™š›3œ33ž3Ÿ3 3¡3¢3£¤'eventstore-1.0.0-2rxxBG4DZp05rmEX5MfZ4i!Database.EventStore.Internal.TestDatabase.EventStore$Database.EventStore.Internal.Prelude#Database.EventStore.Internal.Logger%Database.EventStore.Internal.EndPoint&Database.EventStore.Internal.Discovery%Database.EventStore.Internal.Callback%Database.EventStore.Internal.Settings$Database.EventStore.Internal.Control&Database.EventStore.Internal.Stopwatch#Database.EventStore.Internal.Stream"Database.EventStore.Internal.Utils$Database.EventStore.Internal.Command"Database.EventStore.Internal.Types1Database.EventStore.Internal.Subscription.Message/Database.EventStore.Internal.Subscription.Types?Database.EventStore.Internal.Operation.ReadStreamEvents.Message8Database.EventStore.Internal.Operation.ReadEvent.MessageGHC.BasememptymappendmconcatIsString GHC.GenericsGeneric SemigroupMonoidbytestring-0.10.8.2Data.ByteString.Internal ByteString'hashable-1.2.6.1-JDYnvpSucMf1h1i2CUUtVbData.Hashable.ClassHashable#text-1.2.2.2-EakMpasry3jA6OIwSZhq9MData.Text.InternalText3unordered-containers-0.2.8.0-3iSQJVS3Sio885UUC852ojData.HashMap.BaseHashMap<|>somemany AlternativestimessconcatData.List.NonEmptynonEmpty:|NonEmptyControl.Monad.IO.ClassliftIOMonadIOData.OrdDownzipWith Data.Maybe fromMaybeisJustempty,monad-control-1.0.2.2-63OFYpJUJwOBJY4WCknkL7Control.Monad.Trans.ControlMonadBaseControl'connection-0.2.8-H55SGn4361h6xgIpuJgLT3Network.Connection.Types TLSSettingscontainers-0.5.10.2Data.Sequence.InternalSeqData.Set.InternalSet)fast-logger-2.4.10-614D4p630b6GiygrAUl2jeSystem.Log.FastLogger LogCallbackLogFileLogFileNoRotate LogStderr LogStdoutLogNoneLogTypetransformers-0.5.2.0Control.Monad.Trans.Classlifthash hashWithSaltStMrestoreM liftBaseWith*monad-logger-0.3.26-9PUXRK3k415DSXlROabAwKControl.Monad.Logger LevelOther LevelError LevelWarn LevelInfo LevelDebugLogLevel/mono-traversable-1.0.6.0-GvHTbfRfBPsJxWrjxLM3WRData.MonoTraversable.Unprefixedlengthnull time-1.8.0.2(Data.Time.Clock.Internal.NominalDiffTimeNominalDiffTime atomicallytshowretrySTMwhenMunlessM LoggerRef LoggerFilter LoggerLevelloggerCallback newLoggerRef NodeEndPoints tcpEndPointsecureEndPointEndPoint endPointIp endPointPort emptyEndPointClusterSettings clusterDnsclusterMaxDiscoverAttemptsclusterExternalGossipPortclusterGossipSeedsclusterGossipTimeoutclusterDnsServer DnsServer DnsFilePath DnsHostName DnsHostPort Discovery runDiscovery GossipSeedgossipSeedHeaderDnsDiscoveryExceptionMaxDiscoveryAttemptReachedDNSDiscoveryError gossipSeedgossipSeedWithHeadergossipSeedHostgossipSeedPortstaticEndPointDiscoverysimpleDnsEndPointDiscoverygossipSeedClusterSettingsdnsClusterSettingsclusterDnsEndPointDiscoveryCallbackfulfillreject tryRetrieveretrieve fromEither newPromise newCallbackSettingss_heartbeatIntervals_heartbeatTimeouts_requireMaster s_credentialss_retrys_reconnect_delays_ssl s_loggerTypes_loggerFilters_loggerDetaileds_operationTimeouts_operationRetry s_monitoringRetryAtMost KeepRetrying Credentials credLogin credPasswordFlagNone Authenticated flagWord8 credentialsatMost keepRetryingdefaultSettingsdefaultSSLSettings msDiffTimeBusHub SubscribePublishSubsubscribeEventHandlerPub publishSTMMessage EventStore getSettings freshUUID publisherstopBus runEventStoretoMsgfromMsgpublish publishWith subscribeasSubasPubasHubbusStopbusProcessedEverythingnewBusmonitorIncrPkgCountmonitorIncrConnectionDropmonitorAddDataTransmittedmonitorIncrForceReconnectmonitorIncrHeartbeatTimeouts StreamName AllStream StreamTypeAll RegularStreamCommandcmdWord8cmdDescheartbeatRequestCmdheartbeatResponseCmdwriteEventsCmdwriteEventsCompletedCmdtransactionStartCmdtransactionStartCompletedCmdtransactionWriteCmdtransactionWriteCompletedCmdtransactionCommitCmdtransactionCommitCompletedCmddeleteStreamCmddeleteStreamCompletedCmd readEventCmdreadEventCompletedCmdreadStreamEventsForwardCmd#readStreamEventsForwardCompletedCmdreadStreamEventsBackwardCmd$readStreamEventsBackwardCompletedCmdreadAllEventsForwardCmd readAllEventsForwardCompletedCmdreadAllEventsBackwardCmd!readAllEventsBackwardCompletedCmdsubscribeToStreamCmdsubscriptionConfirmationCmdstreamEventAppearedCmdunsubscribeFromStreamCmdsubscriptionDroppedCmd"connectToPersistentSubscriptionCmd%persistentSubscriptionConfirmationCmd,persistentSubscriptionStreamEventAppearedCmdcreatePersistentSubscriptionCmd(createPersistentSubscriptionCompletedCmddeletePersistentSubscriptionCmd(deletePersistentSubscriptionCompletedCmd"persistentSubscriptionAckEventsCmd"persistentSubscriptionNakEventsCmdupdatePersistentSubscriptionCmd(updatePersistentSubscriptionCompletedCmd badRequestCmd notHandledCmdauthenticateCmdauthenticatedCmdnotAuthenticatedCmdidentifyClientCmdclientIdentifiedCmd unknownCmd getCommand_cmdDictDurationPersistentSubscriptionSettingspsSettingsResolveLinkTospsSettingsStartFrompsSettingsExtraStatspsSettingsMsgTimeoutpsSettingsMaxRetryCountpsSettingsLiveBufSizepsSettingsReadBatchSizepsSettingsHistoryBufSizepsSettingsCheckPointAfterpsSettingsMinCheckPointCountpsSettingsMaxCheckPointCountpsSettingsMaxSubsCountpsSettingsNamedConsumerStrategySystemConsumerStrategyDispatchToSingle RoundRobinStreamMetadataResultNotFoundStreamMetadataResultDeletedStreamMetadataResultstreamMetaResultStreamstreamMetaResultVersionstreamMetaResultDataStreamMetadataBuilderStreamACLBuilderBuilderStreamMetadatastreamMetadataMaxCountstreamMetadataMaxAgestreamMetadataTruncateBeforestreamMetadataCacheControlstreamMetadataACLstreamMetadataCustom StreamACLstreamACLReadRolesstreamACLWriteRolesstreamACLDeleteRolesstreamACLMetaReadRolesstreamACLMetaWriteRolesPackage packageCmdpackageCorrelation packageData packageCred ReadDirectionForwardBackward ResolvedEventresolvedEventRecordresolvedEventLinkresolvedEventPosition RecordedEventrecordedEventStreamIdrecordedEventIdrecordedEventNumberrecordedEventTyperecordedEventDatarecordedEventMetadatarecordedEventIsJsonrecordedEventCreatedPositionpositionCommitpositionPrepareResolvedEventBufresolvedEventBufEventresolvedEventBufLinkresolvedEventBufCommitPositionresolvedEventBufPreparePosition NotHandledBufnotHandledReasonnotHandledAdditionalInfo MasterInfomasterExternalTcpAddrmasterExternalTcpPortmasterExternalHttpAddrmasterExternalHttpPortmasterExternalSecureTcpAddrmasterExternalSecureTcpPort MasterInfoBufbufMasterExternalTcpAddrbufMasterExternalTcpPortbufMasterExternalHttpAddrbufMasterExternalHttpPortbufMasterExternalSecureTcpAddrbufMasterExternalSecureTcpPortNotHandledReason N_NotReady N_TooBusy N_NotMasterResolvedIndexedEventresolvedIndexedRecordresolvedIndexedLink EventRecordeventRecordStreamIdeventRecordNumber eventRecordIdeventRecordTypeeventRecordDataTypeeventRecordMetadataTypeeventRecordDataeventRecordMetadataeventRecordCreatedeventRecordCreatedEpochNewEvent newEventId newEventTypenewEventDataTypenewEventMetadataType newEventDatanewEventMetadataExpectedVersionAnyNoStream EmptyStreamExact StreamExists EventDataJsonBinaryEvent eventTypeeventId eventData EventTypeStreamDeletedTypeStatsCollectionType LinkToTypeStreamMetadataType SettingsType UserDefinedInternalExceptionConnectionClosedByServer eventTypeTexteventTypeFromStr createEvent eventDataTypeeventMetadataTypewithJson withBinarywithJsonAndMetadatawithBinaryAndMetadataeventDataByteseventMetadataBytesexpVersionInt32 anyVersionnoStreamVersionemptyStreamVersionexactEventVersion streamExistsnewEvent masterInfomasterInfoNodeEndPoints positionStart positionEndrecordedEventDataAsJsontoUTCnewRecordedEventnewResolvedEventnewResolvedEventFromBufresolvedEventOriginalresolvedEventDataAsJsonisEventResolvedLinkresolvedEventOriginalStreamIdresolvedEventOriginalId resolvedEventOriginalEventNumberpackageDataAsTextheartbeatRequestPackageheartbeatResponsePackageemptyStreamACLgetCustomPropertyValuegetCustomPropertyemptyStreamMetadatacustomMetaToPairs streamACLJSONstreamMetadataJSON p_readRoles p_writeRoles p_deleteRolesp_metaReadRolesp_metaWriteRolesp_maxAge p_maxCountp_truncateBeforep_cacheControlp_aclinternalMetaPropertieskeepUserPropertiesparseNominalDiffTimeparseStreamACLparseStreamMetadatabuild setReadRoles setReadRole setWriteRoles setWriteRolesetDeleteRoles setDeleteRolesetMetaReadRolessetMetaReadRolesetMetaWriteRolessetMetaWriteRolebuildStreamACLmodifyStreamACL setMaxCount setMaxAgesetTruncateBeforesetCacheControlsetACL modifyACLsetCustomPropertybuildStreamMetadatamodifyStreamMetadata strategyTextstrategyFromText%defaultPersistentSubscriptionSettings msDuration secsDuration NakAction NA_UnknownNA_ParkNA_RetryNA_SkipNA_Stop DropReasonD_UnsubscribedD_AccessDenied D_NotFoundD_PersistentSubscriptionDeletedD_SubscriberMaxCountReachedPersistActionExceptionPersistActionFailPersistActionAlreadyExistPersistActionDoesNotExistPersistActionAccessDeniedPersistActionAborted SubDetailsSubscriptionIdSubscriptionClosed SubDropReasonSubUnsubscribedSubAccessDenied SubNotFoundSubPersistDeleted SubAbortedSubNotAuthenticatedSubServerError SubNotHandledSubClientErrorSubSubscriberMaxCountReachedAllSlice StreamSliceSliceLoc sliceEventssliceDirectionsliceEOS sliceFrom sliceNexttoSlice ReadResult ReadSuccess ReadNoStreamReadStreamDeletedReadNotModified ReadErrorReadAccessDeniedOperationErrorWrongExpectedVersion StreamDeletedInvalidTransaction AccessDeniedInvalidServerResponseProtobufDecodingError ServerErrorInvalidOperationStreamNotFoundNotAuthenticatedOpAborted WriteResultwriteNextExpectedVersion writePosition writeEventstransactionStarttransactionWritetransactionCommitreadStreamEvents ReadEventReadEventNotFoundreadEventStreamreadEventNumberreadEventResolved readEventreadMetaStream setMetaStream readAllEvents createPersist updatePersist deletePersist DeleteResult deleteStreamCatchupOpResultcatchupReadEventscatchupEndOfStreamcatchupCheckpoint CatchupStateRegularCatchup AllCatchup CheckpointCheckpointNumberCheckpointPositioncatchup SendPackageNewTimerServiceTerminatedSubmitOperationFatalExceptionFatalCondition InitFailed InitializedServiceConnectionManager TimerServiceSystemShutdown SystemInit SubscriptionnextEventMaybeSTMgetSubscriptionDetailsSTMsubscriptionStream unsubscribe nextEventnextEventMaybewaitConfirmationunsubscribeConfirmedSTMunsubscribeConfirmedwaitUnsubscribeConfirmedisSubscribedToAllgetSubscriptionIdConnectionEstablishedConnectionClosedConnectionErrorPackageArrived Connection connectionIdconnectionEndPointenqueuePackagedispose ConnectionRefmaybeConnection RecvOutcome ResetByPeerRecv WrongFraming ParsingErrorConnectionBuilderconnect getConnectionconnectionErrorconnectionBuilderOperationMaxAttemptReachedExec execSettingsexecWaitTillClosed TerminatednewExecRegularSubscriptionPersistentSubscriptionnotifyEventsProcessed acknowledgeacknowledgeEventsfailed eventsFailednotifyEventsFailedCatchupSubscription hasCaughtUpwaitTillCatchuphasCaughtUpSTM TransactionId TransactionConnectionTypeStaticClusterDnswaitTillClosedconnectionSettingsshutdown sendEvent sendEvents transactionIdstartTransactiontransactionRollbackreadStreamEventsForwardreadStreamEventsBackwardreadAllEventsForwardreadAllEventsBackwardsubscribeToAll subscribeFromsubscribeToAllFromsetStreamMetadatagetStreamMetadatacreatePersistentSubscriptionupdatePersistentSubscriptiondeletePersistentSubscriptionconnectToPersistentSubscription$fEqTransactionId$fOrdTransactionId$fShowTransactionId GHC.Conc.Syncghc-prim GHC.TypesTrueFalse 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 Applicativepure<*>*><*liftA2 Data.FoldableFoldabletoListfoldMapfoldl'Data.Traversable TraversabletraversemapM sequenceAsequenceBoolDoubleFloatIntGHC.IntInt8Int16Int32Int64 integer-gmpGHC.Integer.TypeIntegerMaybeNothingJustOrderingLTEQGTIOWordGHC.WordWord8Word16Word32Word64 Data.EitherEitherLeftRightTyConideither Data.Functor<$> Data.Time.Clock.Internal.UTCTimeUTCTimeutctDay utctDayTimeThreadId$async-2.1.1.1-H3j65XcXMHtBvmNwGCQ80GControl.Concurrent.Async waitBothSTMwaitEitherSTM_ waitEitherSTMwaitEitherCatchSTM waitAnySTMwaitAnyCatchSTMpollSTM waitCatchSTMwaitSTMAsync asyncThreadId MonadPlusmzeromplusControl.ConcurrentrtsSupportsBoundThreadsControl.Concurrent.ChanChanControl.Concurrent.QSemQSemControl.Concurrent.QSemNQSemN Control.MonadunlessfoldM_foldMforever<=<foldMapDefault fmapDefault mapAccumR mapAccumLforMfor GHC.Conc.IO registerDelay writeTVarreadTVar readTVarIO newTVarIOnewTVaralwaysalwaysSucceedscatchSTMthrowSTMorElseSTMTVarGHC.IO.ExceptionSomeAsyncException GHC.IORefIORefGHC.IOFilePath IOException GHC.Exception Exception toException fromExceptiondisplayException Data.TypeabletypeOf7typeOf6typeOf5typeOf4typeOf3typeOf2typeOf1 rnfTypeReptypeRepFingerprint typeRepTyCon typeRepArgs splitTyConAppmkFunTy funResultTygcast2gcast1gcasteqTcast showsTypeReptypeReptypeOfTypeRep Typeable1 Typeable2 Typeable3 Typeable4 Typeable5 Typeable6 Typeable7rnfTyContyConFingerprint tyConName tyConModule tyConPackageforM_for_ traverse_ Data.ProxyProxyData.Type.Equality:~:Refl:~~:HRefl byteSwap64 byteSwap32 byteSwap16maybeGHC.MVarMVarflip.constapwhen=<<GHC.Err undefinederror SomeException&&||not!Data.Time.Clock.Internal.DiffTimeDiffTime'exceptions-0.8.3-6TQSgd6QYnC83Uf6EwjUmsControl.Monad.Catch handleIOError catchIOErroruninterruptibleMask_mask_ MonadThrowthrowM MonadCatchcatch MonadMaskmaskuninterruptibleMaskHandler+lifted-async-0.9.3.2-5YKE5kXqNgK4zXE4a6zBdHControl.Concurrent.Async.LiftedreplicateConcurrently_replicateConcurrentlyforConcurrently_forConcurrentlymapConcurrently_mapConcurrently concurrently_ concurrentlyrace_racelink2linkwaitBoth waitEither_waitEitherCatchCancelwaitEitherCancelwaitEitherCatch waitEitherwaitAnyCatchCancel waitAnyCancel waitAnyCatchwaitAny waitCatch cancelWithcancelpollwaitwithAsyncOnWithUnmaskwithAsyncWithUnmask withAsyncOnwithAsyncBound withAsyncasyncOnWithUnmaskasyncWithUnmaskasyncOn asyncBoundasync ConcurrentlyrunConcurrently liftBaseOp_+lifted-base-0.2.3.11-5mrB3u458gwFrnCkvjm5RmData.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 writeChannewChan.transformers-base-0.4.4-HMTAN97NeP1DRzglZsXc77Control.Monad.Base MonadBaseliftBase liftThroughliftBaseOpDiscardliftBaseDiscard liftBaseOpcaptureMcaptureTcontroldefaultRestoreMdefaultLiftBaseWithdefaultRestoreT2defaultLiftWith2defaultRestoreTdefaultLiftWithMonadTransControlStTliftWithrestoreTRun RunDefault RunDefault2 RunInBase ComposeStRunInBaseDefaultData.SequencesrepackunpackpacksortOn catMaybessortreplaceSeqLazyTextsplitSeqLazyTextreplaceSeqStrictTextsplitSeqStrictTextstripSuffixLazyBSstripPrefixLazyBSsplitSeqLazyBSstripSuffixStrictBSstripPrefixStrictBSsplitElemStrictBSdeleteBydeletegroupAll isInfixOf isSuffixOf isPrefixOf ensureSuffix ensurePrefix 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 decodeUtf8 encodeUtf8Data.Containers SetContainer ContainerKeymemberunion notMemberunions difference intersectionkeysPolyMap differenceMapintersectionMapintersectionWithMap BiPolyMapBPMKeyConstraint mapKeysWithIsMapMapValuelookup insertWithupdateLookupWithKeyfindWithDefault insertWithKeyinsertLookupWithKey adjustWithKey updateWithKey unionsWith unionWith unionWithKey mapWithKey insertMap deleteMap singletonMap mapFromList mapToList adjustMap updateMapalterMap omapKeysWithIsSet insertSet deleteSet singletonSet setFromList setToListMonoZipozipWithozipounzip HasKeysSetKeySetkeysSet.safe-exceptions-0.1.6.0-1VkSINJxvotE27w2r2N3zQControl.Exception.Safe catchesAsync catchesDeepcatchesisAsyncExceptionisSyncExceptiontoAsyncExceptiontoSyncExceptionbracketOnError_bracketOnErrorfinallybracket_bracket withException onExceptiontryJusttryAsync tryAnyDeeptryDeeptryAnytryIOtry handleJust handleAsync handleAnyDeep handleDeep handleAnyhandleIO catchJust catchAsync catchAnyDeep catchDeepcatchAnycatchIO impureThrowthrowTo throwStringthrowIOthrowStringExceptionSyncExceptionWrapperAsyncExceptionWrapper"stm-2.4.4.1-6AExGOUG8NB2Rzejnay0wwControl.Concurrent.STM.TArrayTArrayControl.Concurrent.STM.TVar mkWeakTVarswapTVar modifyTVar' modifyTVarControl.Concurrent.STM.TQueue isEmptyTQueue unGetTQueue tryPeekTQueue peekTQueue 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 unGetTBQueuetryPeekTBQueue peekTBQueuetryReadTBQueue readTBQueue writeTBQueue newTBQueueIO newTBQueueTBQueue(stm-chans-3.0.0.4-JmlXOhqXqKZBLHhCbheqPbControl.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.DaysdiffDaysaddDaysDayModifiedJulianDaytoModifiedJulianDayliftBaseDefaultwithTimedFastLoggernewTimedFastLoggerwithFastLogger newFastLogger rmLoggerSetrenewLoggerSet flushLogStr pushLogStrLn pushLogStr newLoggerSetnewStderrLoggerSetnewStdoutLoggerSetnewFileLoggerSet LoggerSet FastLoggerTimedFastLoggerSystem.Log.FastLogger.IOdefaultBufSizeBufSizeSystem.Log.FastLogger.LogStr fromLogStr logStrLengthLogStrToLogStrtoLogStrSystem.Log.FastLogger.Filerotate FileLogSpeclog_file log_file_sizelog_backup_numberSystem.Log.FastLogger.DatesimpleTimeFormat'simpleTimeFormat newTimeCache FormattedTime TimeFormattemplate-haskellLanguage.Haskell.TH.Syntax loc_filename loc_package loc_module loc_startloc_end(interpolate-0.1.1-5WN7PPab2slDz6d88fqjTd Data.String.Interpolate.IsStringi logOtherCS logErrorCS logWarnCS logInfoCS logDebugCS logOtherNS logErrorNS logWarnNS logInfoNS logDebugNS logOtherN logErrorNlogWarnNlogInfoN logDebugN logWithoutLoc defaultLoc filterLoggerwithChannelLoggerunChanLoggingTrunChanLoggingTrunStdoutLoggingTrunStderrLoggingTrunFileLoggingT defaultLogStr logOtherS logErrorSlogWarnSlogInfoS logDebugSliftLoc logOtherSH logErrorSH logWarnSH logInfoSH logDebugSHlogOtherlogErrorlogWarnlogInfologDebug LogSource MonadLoggermonadLoggerLog MonadLoggerIO askLoggerIO NoLoggingT runNoLoggingTLoggingT runLoggingTNoLoggergossipEndpointAState ClusterInfomembers MemberInfo _instanceId_state_isAlive_internalTcpIp_internalTcpPort_externalTcpIp_externalTcpPort_internalHttpIp_internalHttpPort_externalHttpIp_externalHttpPort_lastCommitPosition_writerCheckpoint_chaserCheckpoint_epochPosition _epochNumber_epochId _nodePriorityGUUID VNodeState InitializingUnknown PreReplica CatchingUpCloneSlave PreMasterMasterManager ShuttingDownShutdownStageFulfillRejectRetrieve runCallback Monitoring _pkgCount _connDrops_dataTx _forceReco _heartTimeout _busLoggerRef _busSettings_busEventHandlers _busQueue _workerAsync _monitoring EventHandlerGetType FromTypeable FromProxyType unEventStoreEnv__logRef __settings__bus __monitor Stopwatch newStopwatchstopwatchElapsedInternal _lastTime_acc streamNameRaw prettyWord8'uuid-types-1.0.3-GEk5A9yxnAvAJBMA1xZ10hData.UUID.Types.InternalUUID$aeson-1.2.3.0-IKViWrdpe5qGW36sSFwXh7Data.Aeson.Types.InternalObjectPair'protobuf-0.2.1.1-IGZXjChgBm7APES9B0XnXSData.ProtocolBuffers.TypesValue)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 subCommitPossubIdtoSubDropReasoncreateRExceptiondeleteRExceptionupdateRExceptionResponseResultRequest newRequest_error _endOfStream _lastNumber _nextNumber_result_events ACCESS_DENIEDERROR NOT_MODIFIEDSTREAM_DELETED NO_STREAMSUCCESS_requireMaster_resolveLinkTos _maxCount _eventNumber _streamId _indexedEvent NOT_FOUND_Error_Result_NextPreparePosition_NextCommitPosition_Events_PreparePosition_CommitPosition_preparePosition_commitPosition SomeSlice__next__from__dir__eos__eventsLocationStreamPositionStreamEventNumber_saEOS _saEvents_saDir_saNext_saFrom_ssEOS _ssEvents_ssNext_ssFrom_ssDir sliceLast sliceStreamcreateConnectRegularPackagecreateConnectPersistPackagecreatePersistActionPackagecreateAckPackagecreateNakPackagecreateUnsubscribePackageErrorMsg UnknownMsgNotAuthenticatedMsg NotHandledMsg BadRequestMsgConfirmationMsgPersistentConfirmationMsgRegularConfirmationMsgLiveMsg DroppedMsgPersistentEventAppearedMsgEventAppearedMsg ServerMessageconfirmationCommitPosconfirmationLastEventNumconfirmationPersistentSubIddecodeServerMessagemaybeDecodeMessageCode OperationOpResultfreshIdfailureretrysendrequest runFirstMatchwaitFor waitForOr%machines-0.6.3-5ALksL8Ub381a2vFl16nI0Data.Machine.Planstop wrongVersion streamDeletedinvalidTransaction accessDeniedprotobufDecodingError serverErrorinvalidServerResponseData.Machine.WyecapWyecapYcapXaddYaddXwyeYXZWyeWyeTData.Machine.MealylogMealy unfoldMealyMealyrunMealyData.Machine.Moore unfoldMoorelogMooreMooreData.Machine.TeezippingzipWithTcapTcapRcapLaddRaddLteeTteeTRLTeeTeeTData.Machine.SourceunfoldTunfoldenumerateFromTo replicatediteratedplugcapsourcecycledrepeatedSourceSourceTData.Machine.ProcessstrippingPrefixshowingreading traversingmapping sequencingsmallestlargestfinalOrfinalautoM sinkPart_ flattenedasPartsfold1foldscanMapscan1scanprocesssupply~><~buffered droppingWhile takingWhiletakingdroppingfiltered prependedechoProcessProcessT Automatonauto AutomatonMautoTData.Machine.Type finishWithtagDone deconstructstoppedstarvepasspreplanbefore unfoldPlan repeatedly constructfitMfitrunrunTrunT_ stepMachineencased runMachineStepStopYieldAwaitMachineT runMachineTMachine Applianceappliedexhaustawaitsawait maybeYieldyieldrunPlanPlanTrunPlanTPlanData.Machine.IsIsExpectNeedNeedUUID NeedRemote WaitRemote ExecutionFailedProceed OP_SUCCESSOP_PREPARE_TIMEOUTOP_COMMIT_TIMEOUTOP_FORWARD_TIMEOUTOP_WRONG_EXPECTED_VERSIONOP_STREAM_DELETEDOP_INVALID_TRANSACTIONOP_ACCESS_DENIED _firstNumber_message_expectedVersioneventToNewEventvolatile CommittedCommitWrittenWriteStartedStartnewStartnewWrite newCommit _ccMessage _ccResult _ccTransId_cRequireMaster _cTransId _wwMessage _wwResult _wwTransId_wRequireMaster _wTransId_transIdpersist _hardDelete timerService_stoppedsubmitdropped confirmedsubUnsubscribe putPackage mandatorySize ProtocolErrorWrongFramingErrorPackageParsingErrorConnectionResetByPeerConnectionState _sendQueueDecisionHandled ReconnectRegistry newRegistryregisterabortPendingRequests handlePackage checkAndRetrystartAwaitings _regConnRef _regPendings _regAwaitings _stopwatch _sessionsAwaitingAwaitingRequestPending_pendingRequest_pendingSession_pendingRetries_pendingLastTry_pendingConnIdSessionssessionsNextId sessionsMapSession sessionId sessionOp sessionStacksessionCallbackSuspendRequiredOptionalResolved _requestCmd_requestPayloadnewhandlecleanupcheck_regconnectionManagerServerHeartbeatTimeoutForceReconnect_disc_builder_stage_last_sending_opMgr _lastCheck_lastConnected_tracker _lastPkgNumHeartbeatTracker_pkgNum_heartbeatStage _startedSinceHeartbeatStageIntervalTimeoutTickCloseConnectionEstablishConnectionConnectionMaxAttemptReachedAttempts attemptCountattemptLastStartConnectingState ReconnectingEndpointDiscoveryConnectionEstablishingInit Connecting ConnectedClosed_initRef _finishRef _stageVar_execPub _internal AvailableErrored_regNext _regPhase _regStream_regExecPhaseRunningnewRegularSubscription_perNext _perPhase _perStream_perExecnewPersistentSubscription _catchupNext _catchupTrack _catchupPhase_catchupStream _catchupExec CatchupTrack CatchupAllCatchupRegular catchupTrackreceivedAlready updateTrack streamName streamTextnewCatchupSubscription throwClosed _unTransId_tStream _tTransId_tExpVer_tConn_exec _settings_typeversion getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileName