AnK      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJ5(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]QKGeneralized version of L.M1Only perform the action if the predicate returns N.O1Only perform the action if the predicate returns P. QRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~PN      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOKPQMOR(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]#vSTUVWXYZ[\]^_`ab cdefghijklmnopqrstuvwxyz{|}~ (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]( Gathers both an IPv4 and a port. (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+16<>?FKQTV]?7Contains settings related to a connection to a cluster..The DNS name to use for discovering endpoints.9The maximum number of attempts for discovering endpoints.>The well-known endpoint on which cluster managers are running..Endpoints for seeding gossip if not using DNS.Timeout for cluster gossip.4Indicates a specific DNS server should be contacted.-Tells how the DNS server should be contacted.&Procedure used to discover an network ."&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.$ Creates a ".% Creates a " with a specific HTTP header.&Returns " host IP address.'Returns " port.( Configures a  for connecting to a cluster using gossip seeds. clusterDns = "" clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipTimeout = 1s) Configures a  for connecting to a cluster using DNS discovery. clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipSeeds = Nothing clusterGossipTimeout = 1s! !"#$%&'()   !"#(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+<>?FQTV]C(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]^I*Global  Connection settings,KMaximum delay of inactivity before the client sends a heartbeat request.-;Maximum delay the server has to issue a heartbeat response..UOn a cluster settings. Requires the master node when performing a write operation./'Retry strategy when failing to connect.0.Delay before issuing a new connection request.1 SSL settings.2Type of logging to use.3$Restriction of what would be logged.4]Detailed logging output. Currently, it also indicates the location where the log occurred.5CDelay in which an operation will be retried if no response arrived.6)Retry strategy when an operation timeout.7EKG metric store.8Default connection name.9;# to use for operations where other ; are not explicitly supplied.:!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., = 750 ms- = 1500 ms. = N/ = = 30 = 3 seconds1 = 2 =  3 =  4 = P5 = 10 seconds6 = = 37 = 8 = 9 = @Default SSLsettings based on ?.AMillisecond timespan<LoginPassword!*+9876543210/.-,:;    <=>?@A*+,-./0123456789:;    (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+1<>?FKQTV]a@*+,-./0123456789:;    <=>?@A  !"#$%&'()*+ ,-./012 3456789:;<=>?@ABCDEFGHIJKL (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]eMNOMPQRST (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-<>?FQTV]iB0Represents a regular stream name or $all stream.E3A stream can either point to $all or a regular one.BDCEGFUBCDEFG (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]lrV (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FKQTV]oXH Internal command representation.4HWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~HWYX (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-16<>?FKQTV]zI/Gathers every persistent subscription property.KbWhether or not the persistent subscription should resolve linkTo events to their linked events.L4Where the subscription should start from (position).MUWhether or not in depth latency statistics should be tracked on this subscription.N[The amount of time after which a message should be considered to be timeout and retried.O_The maximum number of retries (due to timeout) before a message get considered to be parked.PAThe size of the buffer listening to live messages as they happen.Q;The number of events read at a time when paging in history.R;The number of events to cache when paging through history.S+The amount of time to try checkpoint after.T-The minimum number of messages to checkpoint.UgThe maximum number of message to checkpoint. If this number is reached, a checkpoint will be forced.V*The maximum number of subscribers allowed.W@The strategy to use for distributing events to client consumers.XKSystem supported consumer strategies for use with persistent subscriptions.Y_Distributes events to a single client until it is full. Then round robin to the next client.Z;Distributes events to each client in a round robin fashion.[NRepresents stream metadata as a series of properties for system data and a e 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.aA e$ containing user-specified metadata.bA d applies to e.cA d applies to m.d"Allows to build a structure using  functions.eRepresents stream metadata with strongly typed properties for system values and a dictionary-like interface for custom values.g3The maximum number of events allowed in the stream.h0The maximum age of events allowed in the stream.itThe event number from which previous events can be scavenged. This is used to implement soft-deletion of streams.j9The amount of time for which the stream head is cachable.k'The access control list for the stream.lTAn enumerable of key-value pairs of keys to JSON text for user-provider metadata.m/Represents an access control list for a stream.o-Roles and users permitted to read the stream.p1Roles and users permitted to write to the stream.q2Roles and users permitted to delete to the stream.r2Roles and users permitted to read stream metadata.s3Roles and users permitted to write stream metadata.ARepresents a package exchanged between the client and the server.tPRepresents the direction of read operation (both from $all an usual streams).uFrom beginning to endvFrom end to beginningwBA structure representing a single event or an resolved link event.y.The event, or the resolved link event if this w is a link event.zThe link event if this w is a link event.{ Possible  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.cA structure referring to a potential logical record position in the EventStore transaction file.Commit position of the recordPrepare position of the recordKRepresents a serialized event sent by the server in a subscription context.ORepresents a serialized event representiong either an event or a link event.5Represents a serialized event coming from the server.Serializes form of an .,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.Holds event data.RContains event information like its type and data. Only used for write queries.!Constants for System event types.Event type for stream deleted.Event 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  meant to be persisted.Maps  inner data type to an  understandable by the server.Maps  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  metadata to a raw .Maps a  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. 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 . Constructs a w from a . Constructs a w from a .DReturns the event that was read or which triggered the subscription.If this wa 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 w 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 O of heartbeat request.m" with no role or users whatsoever.+Gets a custom property value from metadata.*Get a custom property value from metadata.e with everything set to , using  and an empty .Maps an  to a list of  to ease the e. Serialized a m to  for serialization purpose. Serialized a e to  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 U. It used to safely e in JSON.,Only keeps the properties the users has set. Parses a  from an  given a JSON property.Parses m.Parses e.Build a structure given a d 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 m from a c. Modifies a m using a c.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 m by the given one in a b. Updates a StreamMetadata's m given a c. Sets a custom metadata property. Builds a e from a b. Modifies a e using a bMaps a X to a  understandable by the server.Tries to parse a X given a raw .0System default persistent subscription settings. Event typeEvent ID, generated if  Event data Event typeEvent IDData content typeMetadata content type Event dataMetadataIJWVUTSRQPONMLKXZY[^]\a`_bcdeflkjihgmnsrqpotvuwx{zy|}~IJKLMNOPQRSTUVWXYZ[\]^_`a__efghijklmnopqrstuvwxyz{| }~ (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]zSAvalaible event sent by the server in the context of a persistent subscription../Connection to persistent subscription response.Nak processed events request.#Gathers every possible Nak actions.Ack processed events request.-Connect to a persistent subscription request.(Update persistent subscription response.'Update persistent subscription outcome.'Update persistent subscription request.(Delete persistent subscription response. 'Delete persistent subscription outcome. 'Delete persistent subscription request. (Create persistent subscription response. 'Create persistent subscription outcome. 'Create persistent subscription request.QA message sent to the server to indicate the user asked to end a subscription.BA message sent by the server when a subscription has been dropped.1Represents the reason subscription drop happened.VSerialized event sent by the server when a new event has been appended to a stream.(Stream subscription connection response.'Stream subscription connection request. smart constructor.  smart constructor.  smart construction. smart constructor. smart constructor. smart constructor. smart constructor.} !"#$%&'()*+,-./0123456789:;<=>?@ABCDEF GHIJ KLM NOP QRST UVWXYZ[\]^_`abcdefghijklmnop $#"!%'&(+*),.-210/3CBA@?>=<;:987654DFE JIHG KML NPO TSRQ Uedcba`_^]\[ZYXWVfghijkmlnpo(C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]/q,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.qType 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.(rstuvqwxyz{|}~rvutsqyxwz~}|{ (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]5&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];(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]A~#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]J| &Represents a slice of the $all stream.Regular stream slice. Gathers common slice operations. Gets slice's ws.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]O 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]Qq(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> experimental non-portableNone"#+-6<>?FQTV]To(C) 2018 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> experimental non-portableNone"#+<>?FQTV]V(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#&'+-1<>?FKQTV]jcInstruction that composed an .=Operation exception that can occurs on an operation response.Stream and Expected VersionStreamStreamExpected, 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.$Operation result sent by the server.Asks for a unused O. Raises an .5Asks to resume the interpretation from the beginning.Like B except it discards the correlation id of the network exchange.&Runs the first expection that matches.Sends a message to remote server. It returns the expected deserialized message along with the correlation id of the network exchange.Like  but will  if the connection reset.$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.Raises  exception. Raises  exception. Raises  exception. Raises  exception. Raises  exception. Raises  exception.Raises  exception. !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-6<>?FQTV]qWrite 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]v#Returned after writing to a stream.$Next expected version of the stream. of the write. Constructs a  from an .(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]yWrite events operation.(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]F 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]FStart 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]JRepresents 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]mRead 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]$(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] "Returned after deleting a stream.  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]%Catchup operation state.BIndicates the stream name and the next event number to start from.YIndicates the commit and prepare position. Used when catching up from the $all stream.Represents 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 .Stream catching up operation. ((C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]!  )(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+16<>?CFQTV]           *(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?CFQTV]+(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]  .Common operations supported by a subscription. &Asks for the next incoming event like ! while still being in the the . .Returns the runtime details of a subscription.Get subscription stream./Asynchronously unsubscribe from the the stream.Awaits for the next event.Non blocking version of .Waits until the   has been confirmed.Like  but lives in  monad.Non blocking version of .;Wait until unsubscription has been confirmed by the server.*If the subscription is on the $all stream. Gets the ID of the subscription.      ,(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV] Serializes a  into raw bytes.The minimun size a C should have. It's basically a command byte, correlation bytes (O) and a  byte. !"#$%&'()*+,-./01234567 89:;< !"#=>?$%&'()*+,-./01234-(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?CFQTV] 4Occurs when an operation has been retried more than 6. @ABCDEFGHI @ABCJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijkl.(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]: @ABmnopqrmst/(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#%+1<>?FQTV]u vwxyz {|}~0(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+1<>?FQTV]1(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]ҲeQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~PN      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcSTUVWXYZ[\]^_`ab cdefghijklmnopqrstuvwxyz{|defghijklmnopqrstuvwxyz{|}~}~       !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOKPQMOR !"#$%&'()*+,-./0123456789:;    <=>?@A  !"#$%&'()*+HWYXZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~IJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~        !"#$%&'()*+,-./012345672(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]LAlso 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. 3(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+<>?FQTV]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 w! has been successfully processed.Acknowledges those w#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. !4(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  monad."#$%"(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone"#+-1<>?CFQTV]5!& 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 *.0Asynchronously closes the (.1Sends a single  to given stream.2Sends a list of  to given stream.3Deletes given stream.4Gets the id of a '.5%Starts a transaction on given stream.69Asynchronously writes to a transaction in the EventStore.7(Asynchronously commits this transaction.8nThere isn't such of thing in EventStore parlance. Basically, if you want to rollback, you just have to not 7 a '.9'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 >.ASame as @ but applied to $all stream.B.Asynchronously sets the metadata for a stream.C-Asynchronously gets the metadata of a stream.DBAsynchronously create a persistent subscription group on a stream.EBAsynchronously update a persistent subscription group on a stream.FBAsynchronously delete a persistent subscription group on a stream.GQAsynchronously connect to a persistent subscription given a group on a stream. 3 Hard delete5 Stream name9 Event numberResolve Link Tos:From event number Batch sizeResolve Link Tos;From event number Batch sizeResolve Link Tos< Batch sizeResolve Link Tos= Batch sizeResolve Link Tos>Resolve Link Tos?Resolve Link Tos@Resolve Link TosLast checkpoint Batch sizeAResolve Link TosLast checkpoint Batch sizeH   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGQ()*+,;*+,-./0123456789:=><?@-0./ !"#$%&#'()[\]^_`a__9=<;:Cmnopqrsefghijkl312Bdcb'&54786     >?"@A$#%IJKLMNOPQRSTUVWXYZ !DEFG  |}~EFGtuvwxyz{BCD HA&'()*+,5None"#+<>?FQTV]AG67869:69;69<=>?@AB@AC@AD@AE@AF@AG@AHIJKIJLIJMIJNIJOIJPQRSTTUVVWXYZ[\]^_`abcdefghiijklmnopqrstuvwxyz{|}~                                                  !"#$%&'()*+,-./01234456 7 8 7 9 : ;&<&<+=+>+?+@+A+B+C+D+E+F+G+H+I-J-J2K3L3M3N3O3P3Q3R4S4T4U4VWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|6}|~666666666666666666666666666666666666666666666666666666666666666666666666676767666666666666666666 6 6   6QQQQ6} !"#!"$!"%!"&!"'!"(!")!"*!"+!",!"-6.6/6061626364656676896:;6<=6>?6>@6AB6AC6AD6AE6AF6G6H6I6J6K6L6MN6}O6}P6}Q6}R6}S6}T6}U6}V6}W6}X6}Y6}Z6[\6[\6]^6_`6[a6bc6bd6be6bf6gh6gi6gj6gk6gl6gm6gn6go6gp6gq6gr6gs6gt6gu6gv6gw6gx6gy6gz6g{6g|6g}6g~6g6g6g6g6g6g6g666666666666666666666666666666666b6bQ      !"#$%&'()*+,+-+.+/+0+12345675689:;<=>?@ABCDEFGHIJKLMNOPQRPQSPQTPQUPQVPQWPQXPQYPQZPQ[PQ\PQ]PQ^PQ_PQ`PQaPQbPQcPQdPQePQfPQgPQhPQiPQjPQkPQlPQmPQnPQoPQpPQqPQrPQsPQtPQuPQvPQwPQxPQyPQzPQ{PQ|PQ}PQ~PQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPQPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPP      !"!#!$!%&'&(&)&*&+&,&-&.&/&012131415161718191:1;1<1=1>1?@A@B@C@D@E@F@G@H@I@J@K@L@M@NOPOQOROSOTOUOVOWOXOYOZ[\][\^[\_[\`[\a[\b[\c[\d[\e[\f[\g[\h[\i[\j[\k[\lQmnQmoQmpQmqQrsQrtQruQrvQrwQrxQryQrzQr{Q|}Q|~Q|Q|Q|Q|Q|Q|QQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQQRQQQQQQQQQQQQQQQQQQ56@A@A@A@A@A@A@A@A@A@A@A@A@A@A@A@A@@@@@@@@@@@@@@@@@@ IJ IJ IJ IJ IJIJIJIJIJIJIJIJIJIJIJIJIJIJIJIJIJIJIJ IJ!IJ"IJ#IJ$IJ%IJ&IJ'IJ(IJ)IJ*IJ+IJ,IJ-IJ.IJ/IJ0IJ1IJ2IJ3IJ4IJ5IJ6IJ7IJ8IJ9IJ:IJ:IJ;IJ<IJ<IJ=IJ>IJ>IJ?@AB@CDEEFGDHIJKLKMNOPQRSTTUUVWWXYZ[\]^_`abcdefghijjklmnopqrstuvawxyz{|}~wyo                                                                                                ! " # $ % & ' ( ) )  * + , -  . / 0 1 2 2 3 4 5 5 6 7 8 9 : ; < < = > ? @ 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 [ \ ] ^ _  ` a b c d e f g h i jklmnopqrstuvwxyz{|}~klmnoprsuvxyz{|}  c      !"#$%&'()*+,-./0123456789:;<=>?@7AB7AC7AD7AE7AF7AG7AH7AI7AH7AJ7AK7AL7MN7MO7MP7MP7MQ7RS7RT7RU7RU7VW7V7VX7VY7VZ7V[7V\7V]7V^7V_7V`7Va7Vb7Vc7Vd7ef7eg7eh7ei7ej7ek7el7em7en7eo7ep7eq7rs7rt7ru7rv7rw7rx7ry7rz7r7r{7r|7r}7r~7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r7r777777777777777777777777777777878787878787878787877xgh j!!"###$%%%%%%%%%%%%%&d'''''''''''')))))))))))))))))) ) ) ) ) * *** ++++,,,,,,,,,,,Y,Y,,,,,,,,,, ,!,",#,#,^,$,%,&,',(,),*,*,+,+,,---.-/-0-1-2-3-4-5-6-0-7-8-9-:-;-<-<-=->->-?-@-A-B-C-D-D-E-F-G-G-H-I-J-K-L-M-N-O---P-Q-R.t.S..T.U.V.t.W/X/Y/Y/Z/Z///[/\/]/^/_/`/:/a/b/c/d/e/e/f/g/h/i/j/k/l/l/m/m/n/n/o/o/p/p/q/q/r/s/t/u/v/w/x/y//z/{/|/}0~00000000000~0000z002K222222>2}223L3333333>3}334S4444444444o4}44444444WXY55555555&eventstore-1.1.1-w9FX31J4MFFAoJFb44fXhDatabase.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.MessageData.List.NonEmptynonEmpty:|NonEmpty'connection-0.2.8-HkuhGN81b877GqmTlBgLC7Network.Connection.Types TLSSettings)fast-logger-2.4.10-614D4p630b6GiygrAUl2jeSystem.Log.FastLogger LogCallbackLogFileLogFileNoRotate LogStderr LogStdoutLogNoneLogType+monad-logger-0.3.28.1-6GXO9O79dRSNxhcZ7lAdXControl.Monad.Logger LevelOther LevelError LevelWarn LevelInfo LevelDebugLogLevel time-1.8.0.2(Data.Time.Clock.Internal.NominalDiffTimeNominalDiffTime LoggerFilter LoggerLevelClusterSettings clusterDnsclusterMaxDiscoverAttemptsclusterExternalGossipPortclusterGossipSeedsclusterGossipTimeoutclusterDnsServer DnsServer DnsFilePath DnsHostName DnsHostPort GossipSeedgossipSeedHeader gossipSeedgossipSeedWithHeadergossipSeedHostgossipSeedPortgossipSeedClusterSettingsdnsClusterSettingsSettingss_heartbeatIntervals_heartbeatTimeouts_requireMasters_retrys_reconnect_delays_ssl s_loggerTypes_loggerFilters_loggerDetaileds_operationTimeouts_operationRetry s_monitorings_defaultConnectionNames_defaultUserCredentialsRetry Credentials credentialsatMost keepRetryingdefaultSettingsdefaultSSLSettings msDiffTime StreamName AllStream StreamTypeAll RegularStreamCommandPersistentSubscriptionSettingspsSettingsResolveLinkTospsSettingsStartFrompsSettingsExtraStatspsSettingsMsgTimeoutpsSettingsMaxRetryCountpsSettingsLiveBufSizepsSettingsReadBatchSizepsSettingsHistoryBufSizepsSettingsCheckPointAfterpsSettingsMinCheckPointCountpsSettingsMaxCheckPointCountpsSettingsMaxSubsCountpsSettingsNamedConsumerStrategySystemConsumerStrategyDispatchToSingle RoundRobinStreamMetadataResultNotFoundStreamMetadataResultDeletedStreamMetadataResultstreamMetaResultStreamstreamMetaResultVersionstreamMetaResultDataStreamMetadataBuilderStreamACLBuilderBuilderStreamMetadatastreamMetadataMaxCountstreamMetadataMaxAgestreamMetadataTruncateBeforestreamMetadataCacheControlstreamMetadataACLstreamMetadataCustom StreamACLstreamACLReadRolesstreamACLWriteRolesstreamACLDeleteRolesstreamACLMetaReadRolesstreamACLMetaWriteRoles ReadDirectionForwardBackward ResolvedEventresolvedEventRecordresolvedEventLinkresolvedEventPosition RecordedEventrecordedEventStreamIdrecordedEventIdrecordedEventNumberrecordedEventTyperecordedEventDatarecordedEventMetadatarecordedEventIsJsonrecordedEventCreatedPositionpositionCommitpositionPrepareExpectedVersion EventDataEvent EventTypeStreamDeletedTypeStatsCollectionType LinkToTypeStreamMetadataType SettingsType UserDefined createEventwithJson withBinarywithJsonAndMetadatawithBinaryAndMetadata anyVersionnoStreamVersionemptyStreamVersionexactEventVersion streamExists 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 SubNotHandledSubClientErrorSubSubscriberMaxCountReachedAllSlice StreamSliceSliceLoc sliceEventssliceDirectionsliceEOS sliceFrom sliceNexttoSlice ReadResult ReadSuccess ReadNoStreamReadStreamDeletedReadNotModified ReadErrorReadAccessDeniedOperationErrorWrongExpectedVersion StreamDeletedInvalidTransaction AccessDeniedInvalidServerResponseProtobufDecodingError ServerErrorInvalidOperationStreamNotFoundNotAuthenticatedOpAborted WriteResultwriteNextExpectedVersion writePosition ReadEventReadEventNotFoundreadEventStreamreadEventNumberreadEventResolved DeleteResult SubscriptionnextEventMaybeSTMgetSubscriptionDetailsSTMsubscriptionStream unsubscribe nextEventnextEventMaybewaitConfirmationunsubscribeConfirmedSTMunsubscribeConfirmedwaitUnsubscribeConfirmedisSubscribedToAllgetSubscriptionIdOperationMaxAttemptReachedRegularSubscriptionPersistentSubscriptionnotifyEventsProcessed acknowledgeacknowledgeEventsfailed eventsFailednotifyEventsFailedCatchupSubscription hasCaughtUpwaitTillCatchuphasCaughtUpSTM TransactionId Transaction ConnectionConnectionTypeStaticClusterDnsconnectwaitTillClosedconnectionSettingsshutdown sendEvent sendEvents deleteStream transactionIdstartTransactiontransactionWritetransactionCommittransactionRollback readEventreadStreamEventsForwardreadStreamEventsBackwardreadAllEventsForwardreadAllEventsBackward subscribesubscribeToAll subscribeFromsubscribeToAllFromsetStreamMetadatagetStreamMetadatacreatePersistentSubscriptionupdatePersistentSubscriptiondeletePersistentSubscriptionconnectToPersistentSubscription$fEqTransactionId$fOrdTransactionId$fShowTransactionId atomically GHC.Conc.SyncwhenMghc-prim GHC.TypesTrueunlessMFalseGHC.Listzip System.IOprintGHC.Base 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 Applicativepure<*>*><*liftA2 Data.FoldableFoldabletoListfoldMapfoldl'Data.Traversable TraversabletraversemapM sequenceAsequence GHC.GenericsGeneric SemigroupsconcatstimesMonoidmemptymappendmconcatBoolDoubleFloatIntGHC.IntInt8Int16Int32Int64 integer-gmpGHC.Integer.TypeIntegerMaybeNothingJustOrderingLTEQGTIOWordGHC.WordWord8Word16Word32Word64 Data.EitherEitherLeftRightTyConideitherbytestring-0.10.8.2Data.ByteString.Internal ByteString Data.Functor<$>'hashable-1.2.6.1-JDYnvpSucMf1h1i2CUUtVbData.Hashable.ClassHashablehash hashWithSalt#text-1.2.2.2-EakMpasry3jA6OIwSZhq9MData.Text.InternalText Data.Time.Clock.Internal.UTCTimeUTCTimeutctDay utctDayTime3unordered-containers-0.2.8.0-3iSQJVS3Sio885UUC852ojData.HashMap.BaseHashMapThreadId$async-2.1.1.1-H3j65XcXMHtBvmNwGCQ80GControl.Concurrent.Async waitBothSTMwaitEitherSTM_ waitEitherSTMwaitEitherCatchSTM waitAnySTMwaitAnyCatchSTMpollSTM waitCatchSTMwaitSTMAsync asyncThreadId Alternativeemptymanysome<|> MonadPlusmzeromplusControl.ConcurrentrtsSupportsBoundThreadsControl.Concurrent.ChanChanControl.Concurrent.QSemQSemControl.Concurrent.QSemNQSemNControl.Monad.IO.ClassMonadIOliftIO 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.OrdDown Data.ProxyProxyData.Type.Equality:~:Refl:~~:HRefl byteSwap64 byteSwap32 byteSwap16zipWith Data.Maybe fromMaybeisJustmaybeGHC.MVarMVarflip.constapwhen=<<GHC.Err undefinederror SomeException&&||not,monad-control-1.0.2.2-63OFYpJUJwOBJY4WCknkL7Control.Monad.Trans.ControlMonadBaseControlStM liftBaseWithrestoreMcontainers-0.5.10.2Data.Sequence.InternalSeqData.Set.InternalSet!Data.Time.Clock.Internal.DiffTimeDiffTime'exceptions-0.8.3-6TQSgd6QYnC83Uf6EwjUmsControl.Monad.Catch handleIOError catchIOErroruninterruptibleMask_mask_ MonadThrowthrowM MonadCatchcatch MonadMaskmaskuninterruptibleMaskHandler+lifted-async-0.9.3.3-EEJbkQeF2EACTsCnGxakziControl.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 writeChannewChantransformers-0.5.2.0Control.Monad.Trans.Classlift.transformers-base-0.4.4-HMTAN97NeP1DRzglZsXc77Control.Monad.Base MonadBaseliftBase liftThroughliftBaseOpDiscardliftBaseDiscard liftBaseOpcaptureMcaptureTcontroldefaultRestoreMdefaultLiftBaseWithdefaultRestoreT2defaultLiftWith2defaultRestoreTdefaultLiftWithMonadTransControlStTliftWithrestoreTRun RunDefault RunDefault2 RunInBase ComposeStRunInBaseDefault/mono-traversable-1.0.8.1-6EWdxe3PQoV4mIHxn2pmI4Data.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 decodeUtf8 encodeUtf8Data.MonoTraversable.UnprefixedlengthnullData.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.7.0-FORWPwxehgu1NAeYvfe2GoControl.Exception.Safe catchesAsync catchesDeepcatchesisAsyncExceptionisSyncExceptiontoAsyncExceptiontoSyncExceptionbracketWithErrorbracketOnError_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.DaysdiffDaysaddDaysDayModifiedJulianDaytoModifiedJulianDayliftBaseDefault'uuid-types-1.0.3-GEk5A9yxnAvAJBMA1xZ10hData.UUID.Types.InternalUUIDtshowretrySTMnewUUIDwithTimedFastLoggernewTimedFastLoggerwithFastLogger 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-7Lx8O4DnHoSHduKapPGt2t Data.String.Interpolate.IsStringi logOtherCS logErrorCS logWarnCS logInfoCS logDebugCS logOtherNS logErrorNS logWarnNS logInfoNS logDebugNS logOtherN logErrorNlogWarnNlogInfoN logDebugN logWithoutLoc defaultLoc filterLoggerwithChannelLoggerunChanLoggingTrunChanLoggingTrunStdoutLoggingTrunStderrLoggingTrunFileLoggingT defaultLogStrexecWriterLoggingTrunWriterLoggingT logOtherS logErrorSlogWarnSlogInfoS logDebugSliftLoc logOtherSH logErrorSH logWarnSH logInfoSH logDebugSHlogOtherlogErrorlogWarnlogInfologDebug LogSource MonadLoggermonadLoggerLog MonadLoggerIO askLoggerIO NoLoggingT runNoLoggingTWriterLoggingTunWriterLoggingTLoggingT runLoggingT LoggerRefloggerCallback newLoggerRefNoLoggerEndPoint NodeEndPointssecureEndPoint tcpEndPoint endPointPort endPointIp emptyEndPoint DiscoverygossipEndpoint runDiscoveryDnsDiscoveryExceptionMaxDiscoveryAttemptReachedDNSDiscoveryErrorstaticEndPointDiscoverysimpleDnsEndPointDiscoveryclusterDnsEndPointDiscoveryAState 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 ShuttingDownShutdownCallbackfulfillreject tryRetrieveretrieve fromEither newPromise newCallbackStageFulfillRejectRetrieve runCallbackFlag flagWord8 KeepRetryingAtMost credPassword credLogin AuthenticatedNoneBusHub SubscribePublishSubsubscribeEventHandlerPub publishSTMMessage EventStore getSettings freshUUID publisherstopBus runEventStoretoMsgfromMsgpublish publishWithasSubasPubasHubbusStopbusProcessedEverythingnewBusmonitorIncrPkgCountmonitorIncrConnectionDropmonitorAddDataTransmittedmonitorIncrForceReconnectmonitorIncrHeartbeatTimeouts 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 prettyWord8cmdDesccmdWord8heartbeatRequestCmdheartbeatResponseCmdwriteEventsCmdwriteEventsCompletedCmdtransactionStartCmdtransactionStartCompletedCmdtransactionWriteCmdtransactionWriteCompletedCmdtransactionCommitCmdtransactionCommitCompletedCmddeleteStreamCmddeleteStreamCompletedCmd readEventCmdreadEventCompletedCmdreadStreamEventsForwardCmd#readStreamEventsForwardCompletedCmdreadStreamEventsBackwardCmd$readStreamEventsBackwardCompletedCmdreadAllEventsForwardCmd readAllEventsForwardCompletedCmdreadAllEventsBackwardCmd!readAllEventsBackwardCompletedCmdsubscribeToStreamCmdsubscriptionConfirmationCmdstreamEventAppearedCmdunsubscribeFromStreamCmdsubscriptionDroppedCmd"connectToPersistentSubscriptionCmd%persistentSubscriptionConfirmationCmd,persistentSubscriptionStreamEventAppearedCmdcreatePersistentSubscriptionCmd(createPersistentSubscriptionCompletedCmddeletePersistentSubscriptionCmd(deletePersistentSubscriptionCompletedCmd"persistentSubscriptionAckEventsCmd"persistentSubscriptionNakEventsCmdupdatePersistentSubscriptionCmd(updatePersistentSubscriptionCompletedCmd badRequestCmd notHandledCmdauthenticateCmdauthenticatedCmdnotAuthenticatedCmdidentifyClientCmdclientIdentifiedCmd unknownCmd getCommand_cmdDictPackageResolvedEventBufResolvedIndexedEvent EventRecordNewEventInternalExceptionConnectionClosedByServer eventDataTypeeventMetadataTypeeventDataByteseventMetadataBytesexpVersionInt64newEventtoUTCnewRecordedEventnewResolvedEventnewResolvedEventFromBufheartbeatResponsePackage$aeson-1.2.4.0-BCbjHKPmbhgK9ldqys4mc6Data.Aeson.Types.InternalObjectcustomMetaToPairsPair streamACLJSON'protobuf-0.2.1.1-AAPOk3OLKjd9d340KxRepLData.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 EmptyStreamExactNoStreamAnyJsonBinary eventDataeventId eventType eventTypeTexteventTypeFromStr masterInfomasterInfoNodeEndPointspackageDataAsTextheartbeatRequestPackage 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 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 sliceStreamcreateAckPackagecreateNakPackagecreateUnsubscribePackagecreateAuthPackageErrorMsg UnknownMsgNotAuthenticatedMsg NotHandledMsg BadRequestMsgConfirmationMsgPersistentConfirmationMsgRegularConfirmationMsgLiveMsg DroppedMsgPersistentEventAppearedMsgEventAppearedMsg ServerMessageconfirmationCommitPosconfirmationLastEventNumconfirmationPersistentSubIddecodeServerMessagemaybeDecodeMessagenewIdentifyPkg_version_namenewAuthenticatePkgCode OperationOpResultfreshIdfailureretrysendrequest runFirstMatchwaitFor waitForOr%machines-0.6.3-HO04m0MjUvRLvQWbqvADZjData.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_expectedVersioneventToNewEvent writeEventsvolatile CommittedCommitWrittenWriteStartedStartnewStartnewWrite newCommit _ccMessage _ccResult _ccTransId_cRequireMaster _cTransId _wwMessage _wwResult _wwTransId_wRequireMaster _wTransId_transIdtransactionStartreadStreamEventsreadMetaStream setMetaStream readAllEvents createPersist updatePersist deletePersistpersist _hardDelete CatchupStateRegularCatchup AllCatchup CheckpointcatchupCatchupOpResultcatchupReadEventscatchupEndOfStreamcatchupCheckpointCheckpointNumberCheckpointPosition SendPackageNewTimerServiceTerminatedSubmitOperationFatalExceptionFatalCondition InitFailed InitializedService TimerServiceConnectionManagerSystemShutdown SystemInit timerService_stoppedsubmitdropped confirmedsubUnsubscribe putPackage mandatorySizeConnectionEstablishedConnectionClosedConnectionErrorPackageArrived connectionIdconnectionEndPointenqueuePackagedispose ConnectionRefmaybeConnection RecvOutcome ResetByPeerRecv WrongFraming ParsingErrorConnectionBuilder getConnectionconnectionErrorconnectionBuilder ProtocolErrorWrongFramingErrorPackageParsingErrorConnectionResetByPeerConnectionState _sendQueueDecisionHandled ReconnectRegistry newRegistryregisterabortPendingRequests handlePackage checkAndRetrystartAwaitings _regConnRef _regPendings _regAwaitings _stopwatch _sessionsAwaitingAwaitingRequestPending_pendingRequest_pendingSession_pendingRetries_pendingLastTry_pendingConnIdSessionssessionsNextId sessionsMapSession sessionId sessionOp sessionStacksessionCallbackSuspendRequiredOptionalResolved _requestCmd_requestPayload _requestCrednewhandlecleanupcheck_regconnectionManagerServerHeartbeatTimeoutForceReconnect_disc_builder_stage_last_sending_opMgr _lastCheck_lastConnected_tracker _lastPkgNumHeartbeatTracker_pkgNum_heartbeatStage _startedSinceHeartbeatStageIntervalTimeoutTickCloseConnectionEstablishConnectionIdentificationTimeoutConnectionMaxAttemptReachedAttempts attemptCountattemptLastStartConnectingState ReconnectingEndpointDiscoveryConnectionEstablishingAuthenticationIdentificationInit Connecting ConnectedClosedExecexecWaitTillClosed execSettings TerminatednewExec_initRef _finishRef _stageVar_execPub _internal AvailableErrored_regNext _regPhase _regStream_regExecPhaseRunningnewRegularSubscription_perNext _perPhase_perCred _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