h&      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~5(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/ eventstoreGeneralized version of . eventstore1Only perform the action if the predicate returns . eventstore1Only perform the action if the predicate returns .    (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/    (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/  eventstore Gathers both an IPv4 and a port. (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/%  eventstoreMonitoring backend abstraction. Gathers all the metrics currently tracked by the client. Used only by the TCP interface. Be careful as  is used in a very tight loop. Each function must not throw any exception or the client will end in a broken state. eventstoreCalled every time a TCP package is sent. We mean high-level TCP package, used in EventStore TCP protocol. eventstore5Called every time the client has lost the connection. eventstoreWhen the client sends a TCP package, it calls that function by passing the size of the payload. The goal is to have a distrubtion of the amount of data exchanged with the server. eventstoreCalled every time the client is asked by a node to connect to another node. It happens only in cluster connection setting. eventstoreCalled every time the client detects a heartbeat timeout from the server. eventstoreGlobal  Connection settings eventstoreMaximum delay of inactivity before the client sends a heartbeat request. eventstore;Maximum delay the server has to issue a heartbeat response. eventstoreOn a cluster settings. Requires the master node when performing a write operation. eventstore'Retry strategy when failing to connect. eventstore.Delay before issuing a new connection request. eventstore SSL settings. eventstoreType of logging to use.  eventstore$Restriction of what would be logged.! eventstoreDetailed logging output. Currently, it also indicates the location where the log occurred." eventstoreDelay in which an operation will be retried if no response arrived.# eventstore)Retry strategy when an operation timeout.$ eventstoreMonitoring backend abstraction. You could implement one targetting `ekg-core` for example. We will expose an `ekg-core` implementation as soon as `ekg-core` supports GHC 8.8.*.% eventstoreDefault connection name.& eventstore(# to use for operations where other ( are not explicitly supplied.' eventstore!Represents reconnection strategy.( eventstore%Holds login and password information.  eventstoreIndicates either a Package contains ( data or not.  eventstoreMaps a   into a  understandable by the server.) eventstore Creates a ( given a login and a password.* eventstoreIndicates how many times we should try to reconnect to the server. A value less than or equal to 0 means no retry.+ eventstoreIndicates we should try to reconnect to the server until the end of the Universe., eventstoreDefault global settings. = 750 ms = 1500 ms =  = * 3 = 3 seconds =  =    =   ! = " = 10 seconds# = * 3$ = /% = & = - eventstoreDefault SSLsettings based on ,.. eventstoreMillisecond timespan/ eventstoreA  that does nothing.) eventstoreLogin eventstorePassword)&%$#"! ' ( )*+,-./(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/6&%$#"! ' ( )*+,-./ (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/6;&0 eventstore7Contains settings related to a connection to a cluster.2 eventstore.The DNS name to use for discovering endpoints.3 eventstore9The maximum number of attempts for discovering endpoints.4 eventstore>The well-known endpoint on which cluster managers are running.5 eventstore.Endpoints for seeding gossip if not using DNS.6 eventstoreTimeout for cluster gossip.7 eventstore4Indicates a specific DNS server should be contacted.8 eventstore-Tells how the DNS server should be contacted.  eventstore&Procedure used to discover an network  .< eventstore&Represents a source of cluster gossip.  eventstoreThe endpoint for the external HTTP endpoint of the gossip seed. The HTTP endpoint is used rather than the TCP endpoint because it is required for the client to exchange gossip with the server. standard port which should be used here in 2113.= eventstore2The host header to be sent when requesting gossip.> eventstore Creates a <.? eventstore Creates a < with a specific HTTP header.@ eventstoreReturns < host IP address.A eventstoreReturns < port.B eventstore Configures a 0 for connecting to a cluster using gossip seeds. clusterDns = "" clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipTimeout = 1sC eventstore Configures a 0 for connecting to a cluster using DNS discovery. clusterMaxDiscoverAttempts = 10 clusterExternalGossipPort = 0 clusterGossipSeeds = Nothing clusterGossipTimeout = 1s! 0123456789:; <= >?@A BC  (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/'U  (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/(  (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/(D eventstore Internal command representation.4D  (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/16;^@E eventstore/Gathers every persistent subscription property.G eventstoreWhether or not the persistent subscription should resolve linkTo events to their linked events.H eventstore4Where the subscription should start from (position).I eventstoreWhether or not in depth latency statistics should be tracked on this subscription.J eventstoreThe amount of time after which a message should be considered to be timeout and retried.K eventstoreThe maximum number of retries (due to timeout) before a message get considered to be parked.L eventstoreThe size of the buffer listening to live messages as they happen.M eventstore;The number of events read at a time when paging in history.N eventstore;The number of events to cache when paging through history.O eventstore+The amount of time to try checkpoint after.P eventstore-The minimum number of messages to checkpoint.Q eventstoreThe maximum number of message to checkpoint. If this number is reached, a checkpoint will be forced.R eventstore*The maximum number of subscribers allowed.S eventstoreThe strategy to use for distributing events to client consumers.T eventstoreSystem supported consumer strategies for use with persistent subscriptions.U eventstoreDistributes events to a single client until the bufferSize is reached. After which the next client is selected in a round robin style, and the process is repeated.V eventstoreDistributes events to all clients evenly. If the client buffer-size is reached the client is ignored until events are acknowledged/not acknowledged.W eventstoreFor use with an indexing projection such as the system $by_category projection. Event Store inspects event for its source stream id, hashing the id to one of 1024 buckets assigned to individual clients. When a client disconnects it's buckets are assigned to other clients. When a client connects, it is assigned some of the existing buckets. This naively attempts to maintain a balanced workload. The main aim of this strategy is to decrease the likelihood of concurrency and ordering issues while maintaining load balancing. This is not a guarantee, and you should handle the usual ordering and concurrency issues.X eventstoreRepresents stream metadata as a series of properties for system data and a b object for user metadata.Z eventstore3When the stream is either not found or 'no stream'.[ eventstore When the stream is soft-deleted.\ eventstoreThe name of the stream.] eventstore#The version of the metadata format.^ eventstoreA b$ containing user-specified metadata._ eventstoreA a applies to b.` eventstoreA a applies to j.a eventstore"Allows to build a structure using  functions.b eventstoreRepresents stream metadata with strongly typed properties for system values and a dictionary-like interface for custom values.d eventstore3The maximum number of events allowed in the stream.e eventstore0The maximum age of events allowed in the stream.f eventstoreThe event number from which previous events can be scavenged. This is used to implement soft-deletion of streams.g eventstore9The amount of time for which the stream head is cachable.h eventstore'The access control list for the stream.i eventstoreAn enumerable of key-value pairs of keys to JSON text for user-provider metadata.j eventstore/Represents an access control list for a stream.l eventstore-Roles and users permitted to read the stream.m eventstore1Roles and users permitted to write to the stream.n eventstore2Roles and users permitted to delete to the stream.o eventstore2Roles and users permitted to read stream metadata.p eventstore3Roles and users permitted to write stream metadata.  eventstoreRepresents a package exchanged between the client and the server.q eventstoreRepresents the direction of read operation (both from $all an usual streams).r eventstoreFrom beginning to ends eventstoreFrom end to beginningt eventstoreA structure representing a single event or an resolved link event.v eventstore.The event, or the resolved link event if this t is a link event.w eventstoreThe link event if this t is a link event.x eventstore Possible  of that event.y eventstore&Represents a previously written event.{ eventstore-The event stream that this event belongs to.| eventstore*Unique identifier representing this event.} eventstore#Number of this event in the stream.~ eventstoreType of this event. eventstore$Representing the data of this event. eventstore5Representing the metadada associated with this event. eventstore;Indicates whether the content is internally marked as json. eventstore7Representing when this event was created in the system. eventstoreA structure referring to a potential logical record position in the EventStore transaction file. eventstoreCommit position of the record eventstorePrepare position of the record  eventstoreRepresents a serialized event sent by the server in a subscription context.  eventstoreRepresents a serialized event representiong either an event or a link event.  eventstore5Represents a serialized event coming from the server.  eventstoreSerializes form of an . eventstoreDetermines whether any link event encountered in the stream will be resolved. See the discussion for more information: https://eventstore.com/docs/dotnet-api/reading-events/index.html#resolvedevent eventstore-Represents an event position within a stream. eventstore,Constants used for expected version control.The use of expected version can be a bit tricky especially when discussing idempotency assurances given by the EventStore.The EventStore will assure idempotency for all operations using any value in  except for  anyStream . When using  anyStream the EventStore will do its best to assure idempotency but will not guarantee idempotency. eventstoreHolds event data. eventstoreContains event information like its type and data. Only used for write queries. eventstore!Constants for System event types. eventstoreEvent type for stream deleted. eventstoreEvent type for statistics. eventstoreEvent type for linkTo. eventstoreEvent type for stream metadata. eventstore#Event type for the system settings. eventstoreEvent defined by the user.  eventstoreRepresent a class of error where the user is not at fault. It could be either the client or the server.  eventstoreHappens when the server deliberately close the connection. This probably happens if the client didn't respect EventStore communication error. For instance, the client takes too much time to respond to a heartbeat request. eventstore Create an  meant to be persisted.  eventstoreMaps  inner data type to an  understandable by the server.  eventstoreMaps  inner metadata type to an ! understandable by the server. eventstore"Creates an event using JSON format eventstore'Creates an event using a binary format. eventstore1Creates an event with metadata using JSON format. eventstore3Creates an event with metadata using binary format.  eventstore Serializes  EventData's data to a raw .  eventstore Serializes  metadata to a raw .  eventstoreMaps a  to an  understandable by the server. eventstoreThis write should not conflict with anything and should always succeed. eventstoreThe stream being written to should not yet exist. If it does exist treat that as a concurrency problem. eventstoreThe stream should exist and should be empty. If it does not exist or is not empty, treat that as a concurrency problem. eventstoreStates that the last event written to the stream should have a sequence number matching your expected value. eventstoreThe stream should exist. If it or a metadata stream does not exist treat that as a concurrency problem. eventstoreThe first event in a stream. eventstoreThe last event in the stream. eventstorethe Nth event of a stream. eventstore"Returns a 'EventNumber from a raw . eventstoreReturns a raw  from an .  eventstore  smart constructor. eventstore/Representing the start of the transaction file. eventstore-Representing the end of the transaction file. eventstore*Tries to parse JSON object from the given y.  eventstoreConverts a raw  into an  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)  eventstore Constructs a y from an  .  eventstore Constructs a t from a  .  eventstore Constructs a t from a  . eventstoreReturns the event that was read or which triggered the subscription.If this t represents a link event, the link will be the original event, otherwise it will be the event. eventstoreTries to desarialize  data as JSON. eventstoreIndicates whether this t is a resolved link event. eventstore&The stream name of the original event. eventstoreThe ID of the original event. eventstore'The event number of the original event.  eventstore*Constructs a heartbeat response given the   of heartbeat request. eventstorej" with no role or users whatsoever. eventstore+Gets a custom property value from metadata. eventstore*Get a custom property value from metadata. eventstoreb with everything set to , using  and an empty  .  eventstoreMaps an   to a list of   to ease the b.  eventstoreGets rid of null-ed properties. If a value is an array and that array only has one element, that function simplifies that array of JSON to a single JSON value.  eventstore Serialized a j to   for serialization purpose.  eventstore Serialized a b to   for serialization purpose.  eventstoreRead ACL property.  eventstoreWrite ACL property.  eventstoreDelete ACL property.  eventstoreMetadata read ACL property.  eventstoreMetadata write ACL property.  eventstoreMax age metadata property.  eventstoreMax count metadata property.  eventstore#truncated before metadata property.  eventstore Cache control metadata property.  eventstoreACL metadata property.  eventstore2Gathers every internal metadata properties into a . It used to safely b in JSON.  eventstore,Only keeps the properties the users has set.  eventstore Parses a   from an   given a JSON property.  eventstoreParses j.  eventstoreParses b.  eventstoreBuild a structure given a a and an initial value. eventstore4Sets role names with read permission for the stream. eventstoreSets a single role name with delete permission for the stream. eventstore=Sets role names with metadata read permission for the stream. eventstoreSets a single role name with metadata read permission for the stream. eventstore>Sets role names with metadata write permission for the stream. eventstoreSets a single role name with metadata write permission for the stream. eventstore Builds a j from a `. eventstore Modifies a j using a `. eventstore8Sets the maximum number of events allowed in the stream. eventstore5Sets the maximum age of events allowed in the stream. eventstoreSets the event number from which previous events can be scavenged. eventstore>Sets the amount of time for which the stream head is cachable. eventstoreOverwrites any previous j by the given one in a _. eventstore Updates a StreamMetadata's j given a `. eventstore Sets a custom metadata property. eventstore Builds a b from a _. eventstore Modifies a b using a _  eventstoreMaps a T to a  understandable by the server.  eventstoreTries to parse a T given a raw . eventstore0System default persistent subscription settings. eventstore Event type eventstoreEvent ID, generated if  eventstore Event data  eventstore Event type eventstoreEvent ID eventstoreData content type eventstoreMetadata content type eventstore Event data eventstoreMetadata ESRQPONMLKJIHGFTVUWX^]\[ZY_`abihgfedcjponmlk qsrtxwvuy~}|{z               (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;g  eventstoreAvalaible event sent by the server in the context of a persistent subscription..  eventstore/Connection to persistent subscription response.  eventstoreNak processed events request. eventstore#Gathers every possible Nak actions.  eventstoreAck processed events request.  eventstore-Connect to a persistent subscription request.  eventstore(Update persistent subscription response.  eventstore'Update persistent subscription outcome.  eventstore'Update persistent subscription request.  eventstore(Delete persistent subscription response.  eventstore'Delete persistent subscription outcome.  eventstore'Delete persistent subscription request.  eventstore(Create persistent subscription response.  eventstore'Create persistent subscription outcome.  eventstore'Create persistent subscription request.  eventstoreA message sent to the server to indicate the user asked to end a subscription.  eventstoreA message sent by the server when a subscription has been dropped. eventstore1Represents the reason subscription drop happened.  eventstoreSerialized event sent by the server when a new event has been appended to a stream.  eventstore(Stream subscription connection response.  eventstore'Stream subscription connection request.  eventstore  smart constructor.  eventstore  smart constructor.  eventstore  smart construction.  eventstore  smart constructor.  eventstore  smart constructor.  eventstore  smart constructor.  eventstore  smart constructor.   (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/6m eventstore,Enumerates all persistent action exceptions. eventstoreThe action failed. eventstoreHappens when creating a persistent subscription on a stream with a group name already taken. eventstoreAn operation tried to do something on a persistent subscription or a stream that don't exist. eventstoreThe current user is not allowed to operate on the supplied stream or persistent subscription. eventstoreThat action has been aborted because the user shutdown the connection to the server or the connection to the server is no longer possible.  eventstoreType of persistent action. eventstoreSubscription runtime details. Not useful for the user but at least it makes Haddock documentation generation less ugly.  eventstoreRepresents a subscription id. eventstore.Indicates why a subscription has been dropped. eventstore4Subscription connection has been closed by the user. eventstoreThe current user is not allowed to operate on the supplied stream. eventstore Given stream name doesn't exist. eventstoreGiven stream is deleted. eventstoreOccurs when the user shutdown the connection from the server or if the connection to the server is no longer possible. eventstore!Unexpected error from the server.'   (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/1og eventstore0Represents a regular stream name or $all stream. eventstore!If the stream is the $all stream. (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/6r* eventstore%Returns the stream of a subscription. eventstore.Common operations supported by a subscription. eventstoreAsks for the next subcription event. If that function is called after a SubDropped event, expect it to hang indefinitely. eventstore/Asynchronously unsubscribe from a subscription. eventstoreStreams a subscription events. The stream will end when hitting ! event but will still emit it. eventstoreLike streamSubEvent but will only emit t.(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/s eventstore#Returned after writing to a stream. eventstore$Next expected version of the stream. eventstore of the write.  eventstore Constructs a   from an . (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;uS  eventstore&Batch read on regular stream response.  eventstoreEnumeration detailing the possible outcomes of reading a slice of a stream  eventstore%Batch read on regular stream request.  eventstore  smart constructor. (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;w#  eventstore(Read event on a regular stream response.  eventstoreEnumeration representing the status of a single event read operation.  eventstore'Read event on a regular stream request.  eventstore  smart constructor. (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;x  eventstore#Batch read on $all stream response.  eventstoreEnumeration detailing the possible outcomes of reading a slice of $all stream.  eventstore"Batch read on $all stream request.  eventstore  smart constructor. (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/1{q eventstore&Represents a slice of the $all stream. eventstoreRegular stream slice. eventstore Gathers common slice operations. eventstoreEnumeration detailing the possible outcomes of reading a stream. eventstore Empty slice. eventstore Gets slice's ResolvedEventss. eventstore/If the slice has reached the end of the stream. eventstore%Gets the next location of this slice.(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/|  eventstore Creates Ack  .  eventstore Create Nak  .  eventstoreCreate an unsubscribe  . (C) 2016 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/}g (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  experimental non-portable Safe-Inferred"%&/1;~< (C) 2018 Yorick Laupa(see the file LICENSE)!Yorick Laupa  experimental non-portable Safe-Inferred"%&/~ (C) 2020 Yorick Laupa(see the file LICENSE)!Yorick Laupa  experimental non-portable Safe-Inferred"%&/5o  eventstore$Operation result sent by the server. eventstore=Operation exception that can occurs on an operation response. eventstoreStream and Expected Version eventstoreStream eventstoreStream eventstoreExpected, Found eventstoreReason eventstore7Invalid operation state. If happens, it's a driver bug. eventstoreOccurs when the user asked to close the connection or if the connection can't reconnect anymore.*  (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;W  eventstoreWrite events response.  eventstoreWrite events request.  eventstore  smart constructor.  eventstoreStream eventstoreExpected version eventstoreEvents eventstoreRequire master   (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;  eventstoreCommit transaction response. eventstoreCommit transaction request. eventstore$Write transactional events response. eventstore#Write transactional events request. eventstoreStart transaction response. eventstoreStart transaction request. eventstore smart constructor. eventstore smart constructor. eventstore smart constructor.$(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1;) eventstoreDelete stream response. eventstoreDelete stream request. eventstore smart constructor. (C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/6;(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/ (C) 2020 Yorick Laupa(see the file LICENSE)!Yorick Laupa  experimental non-portable Safe-Inferred"%&/ eventstoreI'm bad at naming thing however, we are going to use that datastructure so we could lookup and delete in one single pass..!(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/6 eventstore Serializes a   into raw bytes. eventstoreThe minimun size a   should have. It's basically a command byte, correlation bytes ( ) and a   byte."(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&(/6#(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/6V$(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/ %(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/&(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/_ eventstoreAlso referred as volatile subscription. For example, if a stream has 100 events in it when a subscriber connects, the subscriber can expect to see event number 101 onwards until the time the subscription is closed or dropped.'(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/1 eventstoreStart transaction operation. eventstoreTransactional write operation. eventstoreTransactional commit operation.((C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1 eventstore+Batch read from a regular stream operation.)(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/1 eventstoreRepresents the result of looking up a specific event number from a stream. eventstore3Read a specific event given event number operation.*(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/1 eventstoreRead stream metadata operation. eventstoreSet stream metadata operation.+(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/ eventstore$Batch read on $all stream operation.,(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/-(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/4.(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/ eventstoreThe server remembers the state of the subscription. This allows for many different modes of operations compared to a regular or catchup subscription where the client holds the subscription state. (Need EventStore >= v3.1.0). eventstore>Acknowledges those event ids have been successfully processed. eventstoreAcknowledges that t! has been successfully processed. eventstoreAcknowledges those t#s have been successfully processed. eventstoreMark a message that has failed processing. The server will take action based upon the action parameter. eventstoreMark messages that have failed processing. The server will take action based upon the action parameter. eventstoreAcknowledges those event ids have failed to be processed successfully./(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/11 eventstore"Returned after deleting a stream.  of the write.0(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/11(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&)*/ eventstoreThis kind of subscription specifies a starting point, in the form of an event number or transaction file position. The given function will be called for events from the starting point until the end of the stream, and then for subsequently written events.For example, if a starting point of 50 is specified when a stream has 100 events in it, the subscriber can expect to see events 51 through 100, and then any events subsequently written until such time as the subscription is dropped or closed. 2(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/h3(C) 2017 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/<          &%$#"! ' ( )*+,-./ 076543128;9: <= >?@A BC D ESRQPONMLKJIHFGTVWUX^]\[YZ_`abihgfecdjponmkl qrstxwuvy~}|z{              4(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/16n eventstoreWhen batch-reading a stream, this type-level function maps the result you will have whether you read a regular stream or $all stream. When reading a regular stream, some read-error can occur like the stream got deleted. However read-error cannot occur when reading $all stream (because $all cannot get deleted). eventstore The id of a . eventstore;Represents a multi-request transaction with the EventStore. eventstore4Represents a connection to a single EventStore node. eventstore4Gathers every connection type handled by the client. eventstoreHostName and Port. eventstore*Domain name, optional DNS server and port. eventstoreCreates 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. eventstore Waits the  to be closed. eventstore Returns a  's . eventstoreAsynchronously closes the . eventstoreSends a single  to given stream. eventstoreSends a list of  to given stream. eventstoreDeletes given stream. eventstoreGets the id of a . eventstore%Starts a transaction on given stream. eventstore9Asynchronously writes to a transaction in the EventStore. eventstore(Asynchronously commits this transaction. eventstoreThere isn't such of thing in EventStore parlance. Basically, if you want to rollback, you just have to not  a . eventstore'Reads a single event from given stream. eventstore#Reads events from a stream forward. eventstore$Reads events from a stream backward. eventstoreSubscribes to a stream. eventstoreSubscribes to a stream. If last checkpoint is defined, this will readStreamEventsForward from that event number, otherwise from the beginning. Once last stream event reached up, a subscription request will be sent using . eventstore.Asynchronously sets the metadata for a stream. eventstore-Asynchronously gets the metadata of a stream. eventstoreAsynchronously create a persistent subscription group on a stream. eventstoreAsynchronously update a persistent subscription group on a stream. eventstoreAsynchronously delete a persistent subscription group on a stream. eventstoreAsynchronously connect to a persistent subscription given a group on a stream. eventstore Hard delete eventstore Stream name eventstore Batch size eventstore Batch size eventstore Batch size,(C) 2019 Yorick Laupa(see the file LICENSE)!Yorick Laupa  provisional non-portable Safe-Inferred"%&/n   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTWUVXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~( !"#$%&'*+),-0123456789:;<>?@=ABCXYZ[\]^jklmnopbcdefghia`_EFGHIJKLMNOPQRSTWUVyz{|}~qrstuvwx  /D. (C) 2018 Yorick Laupa(see the file LICENSE)!Yorick Laupa  experimental non-portable Safe-Inferred"%&)*/5 eventstoreReturns an iterator able to consume a stream entirely. When reading forward, the iterator ends when the last stream's event is reached. eventstoreReturns an iterator able to consume a stream entirely. When reading backward, the iterator ends when the first stream's event is reached. eventstoreThrows an exception in case  is a . eventstore6Returns an iterator able to consume a stream entirely.5 Safe-Inferred"%&/67867967:6;<=>?@ABCDECDFCDGCDHCDICDJKLMNNOPPQRSTUVVWXYZ[\]^_`abcdefghijklmnnopqrstuvwxyz{|}~                                                                                                                                               &)))))).......//14444444444444444444444444444444666676767666666666666666666666666666767676767676766666666666666666676767676767666666666667676767676767666666666666666K676767KKKK666767676767676767666666666666666666666666666666666666666666666666666666666666666666666666666666666666666666676767676666KK K K K K K  K K  K K K K K K  K K  K  K K K K K K K K  K K K K K  K K  K K K K K K K K  K K K  K K K K K K K K K K K K K K K  K K K  K K K K K K K K K  K K  K K K K K K K K  K  K K KL KL KL K K K K  K  K  K  K  K  K  K  K K K K K K K K K K K K K K K K K  K K K K  K  K K K K  K K  K K K K K K      @A @A @A @A @A @A @A @A @A @A @A @A @A @A @A @ @ @ @ @ @ @ @ @ @ @ @ @ @ @  @ @ @ @ @ @  @ @ @  @ @  @ @ @ @  @ @  @  @ @  @ @ @  @  @ CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD CD                     f                                                                                                                                                                                                                                                                               !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!"######$%&&&&&&'''()**+,,,-........./011111111444444444444455555555'eventstore-1.4.3-FUCkFNE2HrDLXMrR8U5ZtIDatabase.EventStoreDatabase.EventStore.Streaming$Database.EventStore.Internal.Prelude#Database.EventStore.Internal.Logger%Database.EventStore.Internal.EndPoint%Database.EventStore.Internal.Settings$Database.EventStore.Internal.Control&Database.EventStore.Internal.Discovery&Database.EventStore.Internal.Stopwatch"Database.EventStore.Internal.Utils$Database.EventStore.Internal.Command"Database.EventStore.Internal.Types1Database.EventStore.Internal.Subscription.Message/Database.EventStore.Internal.Subscription.Types#Database.EventStore.Internal.Stream-Database.EventStore.Internal.Subscription.Api3Database.EventStore.Internal.Operation.Write.Common?Database.EventStore.Internal.Operation.ReadStreamEvents.Message8Database.EventStore.Internal.Operation.ReadEvent.MessageNonEmpty:|Data.List.NonEmptynonEmpty.crypton-connection-0.3.1-h78AcTf3dv2cngdCLYV4JNetwork.Connection.Types TLSSettings(fast-logger-3.2.2-BaWkm4LkaPH3f9zoBy2JGVSystem.Log.FastLoggerLogType*monad-logger-0.3.40-Gji10LR1ukp4MlzO3M49LCControl.Monad.Logger LevelOther LevelError LevelWarn LevelInfo LevelDebugLogLevel time-1.11.1.1(Data.Time.Clock.Internal.NominalDiffTimeNominalDiffTime LoggerFilter LoggerLevelMonitoringBackendmonitoringBackendIncrPkgCount#monitoringBackendIncrConnectionDrop#monitoringBackendAddDataTransmitted#monitoringBackendIncrForceReconnect&monitoringBackendIncrHeartbeatTimeoutsSettingss_heartbeatIntervals_heartbeatTimeouts_requireMasters_retrys_reconnect_delays_ssl s_loggerTypes_loggerFilters_loggerDetaileds_operationTimeouts_operationRetry s_monitorings_defaultConnectionNames_defaultUserCredentialsRetry Credentials credentialsatMost keepRetryingdefaultSettingsdefaultSSLSettings msDiffTimenoopMonitoringBackendClusterSettings clusterDnsclusterMaxDiscoverAttemptsclusterExternalGossipPortclusterGossipSeedsclusterGossipTimeoutclusterDnsServer DnsServer DnsFilePath DnsHostName DnsHostPort GossipSeedgossipSeedHeader gossipSeedgossipSeedWithHeadergossipSeedHostgossipSeedPortgossipSeedClusterSettingsdnsClusterSettingsCommandPersistentSubscriptionSettingspsSettingsResolveLinkTospsSettingsStartFrompsSettingsExtraStatspsSettingsMsgTimeoutpsSettingsMaxRetryCountpsSettingsLiveBufSizepsSettingsReadBatchSizepsSettingsHistoryBufSizepsSettingsCheckPointAfterpsSettingsMinCheckPointCountpsSettingsMaxCheckPointCountpsSettingsMaxSubsCountpsSettingsNamedConsumerStrategySystemConsumerStrategyDispatchToSingle RoundRobinPinnedStreamMetadataResultNotFoundStreamMetadataResultDeletedStreamMetadataResultstreamMetaResultStreamstreamMetaResultVersionstreamMetaResultDataStreamMetadataBuilderStreamACLBuilderBuilderStreamMetadatastreamMetadataMaxCountstreamMetadataMaxAgestreamMetadataTruncateBeforestreamMetadataCacheControlstreamMetadataACLstreamMetadataCustom StreamACLstreamACLReadRolesstreamACLWriteRolesstreamACLDeleteRolesstreamACLMetaReadRolesstreamACLMetaWriteRoles ReadDirectionForwardBackward ResolvedEventresolvedEventRecordresolvedEventLinkresolvedEventPosition RecordedEventrecordedEventStreamIdrecordedEventIdrecordedEventNumberrecordedEventTyperecordedEventDatarecordedEventMetadatarecordedEventIsJsonrecordedEventCreatedPositionpositionCommitpositionPrepare ResolveLink NoResolveLink EventNumberExpectedVersion EventDataEvent EventTypeStreamDeletedTypeStatsCollectionType LinkToTypeStreamMetadataType SettingsType UserDefined createEventwithJson withBinarywithJsonAndMetadatawithBinaryAndMetadata anyVersionnoStreamVersionemptyStreamVersionexactEventVersion streamExists streamStart streamEnd eventNumberrawEventNumbereventNumberToInt64 positionStart positionEndrecordedEventDataAsJsonresolvedEventOriginalresolvedEventDataAsJsonisEventResolvedLinkresolvedEventOriginalStreamIdresolvedEventOriginalId resolvedEventOriginalEventNumberemptyStreamACLgetCustomPropertyValuegetCustomPropertyemptyStreamMetadata setReadRoles setReadRole setWriteRoles setWriteRolesetDeleteRoles setDeleteRolesetMetaReadRolessetMetaReadRolesetMetaWriteRolessetMetaWriteRolebuildStreamACLmodifyStreamACL setMaxCount setMaxAgesetTruncateBeforesetCacheControlsetACL modifyACLsetCustomPropertybuildStreamMetadatamodifyStreamMetadata%defaultPersistentSubscriptionSettings NakAction NA_UnknownNA_ParkNA_RetryNA_SkipNA_Stop DropReasonD_UnsubscribedD_AccessDenied D_NotFoundD_PersistentSubscriptionDeletedD_SubscriberMaxCountReached SubActionSubmitDropped ConfirmedPersistActionExceptionPersistActionFailPersistActionAlreadyExistPersistActionDoesNotExistPersistActionAccessDeniedPersistActionAborted SubDetailsSubscriptionClosed SubDropReasonSubUnsubscribedSubAccessDenied SubNotFoundSubPersistDeleted SubAbortedSubNotAuthenticatedSubServerError SubNotHandledSubClientErrorSubSubscriberMaxCountReached StreamNameStreamIdAll isAllStreamSubscriptionStreamsubscriptionStream Subscription nextSubEvent unsubscribestreamSubEventsstreamSubResolvedEvents WriteResultwriteNextExpectedVersion writePositionAllSlice StreamSliceSliceSliceEndOfStream ReadResult ReadSuccess ReadNoStreamReadStreamDeletedReadNotModified ReadErrorReadAccessDenied emptySlice sliceEventssliceEOS sliceNextOperationErrorWrongExpectedVersion StreamDeletedInvalidTransaction AccessDeniedInvalidServerResponseProtobufDecodingError ServerErrorInvalidOperationStreamNotFoundNotAuthenticatedOpAbortedConnectionHasDroppedRegularSubscription ReadEventReadEventNotFoundreadEventStreamreadEventNumberreadEventResolvedPersistentSubscriptionnotifyEventsProcessed acknowledgeacknowledgeEventsfailed eventsFailednotifyEventsFailed DeleteResultCatchupSubscription BatchResult TransactionId Transaction ConnectionConnectionTypeStaticClusterDnsconnectwaitTillClosedconnectionSettingsshutdown sendEvent sendEvents deleteStream transactionIdstartTransactiontransactionWritetransactionCommittransactionRollback readEventreadEventsForwardreadEventsBackward subscribe subscribeFromsetStreamMetadatagetStreamMetadatacreatePersistentSubscriptionupdatePersistentSubscriptiondeletePersistentSubscriptionconnectToPersistentSubscriptionReadResultHandlerrunReadResultHandlerFetch FetchErrorNoStreamdefaultReadResultHandleronRegularStreamreadThroughForwardreadThroughBackward throwOnError readThrough$fExceptionReadError$fShowReadError atomically GHC.Conc.SyncwhenMghc-prim GHC.TypesTrueunlessMFalseGHC.Listzip System.IOprint otherwiseassert$GHC.Real fromIntegral realToFracGHC.EnumBoundedminBoundmaxBoundEnumsuccpredtoEnumfromEnumenumFrom enumFromThen enumFromToenumFromThenTo GHC.ClassesEq==/= Fractionalrecip fromRational/IntegralremquotRemquotmoddivMod toIntegerdivMonad>>=return>>Functorfmap<$GHC.NumNumsignumabs*+negate fromInteger-Ord<<=>maxmin>=compare toRationaltruncateGHC.ShowShowshowListshow showsPrecData.Typeable.InternalTypeable Data.StringIsString fromString ApplicativeliftA2<*pure*><*> Data.FoldableFoldablefoldMaptoListfoldl'Data.Traversable Traversablesequence sequenceAtraversemapM GHC.GenericsGeneric SemigroupsconcatstimesMonoidmconcatmappendmemptyBoolDoubleFloatIntGHC.IntInt8Int16Int32Int64 ghc-bignumGHC.Num.IntegerInteger GHC.MaybeMaybeNothingJustOrderingGTLTEQIOWordGHC.WordWord8Word16Word32Word64 Data.EitherEitherLeftRightTyCon'hashable-1.4.2.0-D6EOHOGayLdHLpjCLzeHpLData.Hashable.ClassHashablehash hashWithSalt Data.Functor<$>Data.Time.Calendar.TypesYearconst.id Data.Time.Clock.Internal.UTCTimeUTCTime utctDayTimeutctDaybytestring-0.11.3.1Data.ByteString.Internal ByteString text-1.2.5.0Data.Text.InternalText3unordered-containers-0.2.19.1-IxllGDxiwx4nPRh3Oq5LRData.HashMap.InternalHashMapforM_ThreadId!async-2.2.4-BynBTfyCgtT3jUuK6dAuwControl.Concurrent.Async waitBothSTMwaitEitherSTM_ waitEitherSTMwaitEitherCatchSTM waitAnySTMwaitAnyCatchSTMpollSTM waitCatchSTMwaitSTM compareAsyncsAsync asyncThreadIdAsyncCancelledExceptionInLinkedThread Alternativeempty<|>somemany MonadPlusmzeromplusControl.ConcurrentrtsSupportsBoundThreadsControl.Concurrent.ChanChanControl.Concurrent.QSemQSemControl.Concurrent.QSemNQSemNControl.Monad.IO.ClassMonadIOliftIO Control.MonadunlessforeverfoldM_foldM<=< mapAccumR mapAccumLforMforfoldMapDefault fmapDefault GHC.Conc.IO registerDelayTVarSTM writeTVarthrowSTM readTVarIOreadTVarorElse newTVarIOnewTVarcatchSTMGHC.IO.ExceptionSomeAsyncException GHC.IORefIORefGHC.IOFilePath IOExceptionGHC.Exception.Type Exception toExceptiondisplayException fromException Data.TypeableTypeRep typeRepTyContypeRepFingerprint typeRepArgstypeReptypeOf7typeOf6typeOf5typeOf4typeOf3typeOf2typeOf1typeOf splitTyConApp showsTypeRep rnfTypeRepmkFunTygcast2gcast1gcast funResultTyeqTcast tyConPackage tyConName tyConModuletyConFingerprint trLiftedReprnfTyCon traverse_for_Data.OrdDowngetDowneither Data.ProxyProxyData.Type.Equality:~~:HRefl:~:Refl byteSwap64 byteSwap32 byteSwap16 bitReverse8 bitReverse64 bitReverse32 bitReverse16zipWith Data.MaybemaybeisJust fromMaybeGHC.MVarMVarwhenflipap=<<GHC.Err undefinederror SomeException&&not||transformers-0.5.6.2Control.Monad.Trans.Classliftexceptions-0.10.4Control.Monad.Catch MonadThrowthrowMcontainers-0.6.5.1Data.Sequence.InternalSeqData.Set.InternalSet!Data.Time.Clock.Internal.DiffTimeDiffTime MonadMaskgeneralBracketmaskuninterruptibleMask MonadCatchcatchHandleruninterruptibleMask_mask_ handleIOError catchIOError,monad-control-1.0.3.1-8cTxnktplxILi7bGYZXxIVControl.Monad.Trans.ControlStM+lifted-async-0.10.2.4-8FAJcCXSj0nyPvD1brF55Control.Concurrent.Async.LiftedreplicateConcurrently_replicateConcurrentlyforConcurrently_forConcurrentlymapConcurrently_mapConcurrently concurrently_ concurrentlyrace_racelink2linkwaitBoth waitEither_waitEitherCatchCancelwaitEitherCancelwaitEitherCatch waitEitherwaitAnyCatchCancel waitAnyCancel waitAnyCatchwaitAny waitCatchuninterruptibleCancel cancelWithcancelpollwaitwithAsyncOnWithUnmaskwithAsyncWithUnmask withAsyncOnwithAsyncBound withAsyncasyncOnWithUnmaskasyncWithUnmaskasyncOn asyncBoundasync ConcurrentlyrunConcurrently liftBaseOp_*lifted-base-0.2.3.12-JcU3whhTmzogXbhlqZY8dData.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.6-5VZy9sqBO20CnKLMVEm4MZControl.Monad.Base MonadBaseliftBase liftThroughliftBaseOpDiscardliftBaseDiscard liftBaseOpcaptureMcaptureTcontrolTcontroldefaultRestoreMdefaultLiftBaseWithdefaultRestoreT2defaultLiftWith2defaultRestoreTdefaultLiftWithStTMonadTransControlrestoreTliftWithRun RunDefault RunDefault2MonadBaseControl liftBaseWithrestoreM RunInBase ComposeStRunInBaseDefault0mono-traversable-1.0.15.3-L4RmTwqJZbV5C32lAoXj9hData.SequencesrepackunpackpacksortOn catMaybessortreplaceSeqLazyTextsplitSeqLazyTextreplaceSeqStrictTextsplitSeqStrictTextstripSuffixLazyBSstripPrefixLazyBSsplitSeqLazyBSstripSuffixStrictBSstripPrefixStrictBSsplitElemStrictBSdeleteBydeletegroupAll isInfixOf isSuffixOf isPrefixOf ensureSuffix ensurePrefix dropSuffix dropPrefix stripSuffix stripPrefix replaceSeqsplitSeq splitEleminitDeftailDef defaultSnoc defaultCons vectorSort vectorSortBydefaultSplitWhen defaultSortBydefaultReversedefaultIntersperse defaultFind singletonIndex SemiSequencesnoccons interspersefindreversesortBy IsSequence splitWhenindexExinitMayinitExtailMaytailEx groupAllOn unsafeSplitAt lengthIndex unsafeTail unsafeInitdropEnd unsafeDrop unsafeTakeunsnoc replicateMfilterM subsequences permutations partitiongroupBy unsafeIndexunconssplitAtspan replicate dropWhiledropbreaktake takeWhileindexfromListfilterTextual breakWord toCaseFold breakLinewordsunwordsunlineslinestoUppertoLower LazySequencetoChunkstoStrict fromChunks fromStrictUtf8 encodeUtf8 decodeUtf8Data.MonoTraversable.UnprefixedlengthnullData.Containers ContainerKey SetContainerunions notMemberkeys intersectionunion differencememberPolyMapintersectionWithMap differenceMapintersectionMapBPMKeyConstraint BiPolyMap mapKeysWithMapValueIsMap filterMap omapKeysWithalterMap updateMap adjustMap mapToList mapFromList singletonMap deleteMap insertMap updateWithKey unionsWithfindWithDefault adjustWithKey insertWithKeyinsertLookupWithKeyupdateLookupWithKey unionWithKey unionWith mapWithKey insertWithlookupIsSet filterSet setToList setFromList singletonSet insertSet deleteSetMonoZipounzipozipWithozipKeySet HasKeysSetkeysSet.safe-exceptions-0.1.7.4-3hh842Tpfqc7ZZ6pspmXRSControl.Exception.Safe catchesAsync catchesDeepcatchesisAsyncExceptionisSyncExceptiontoAsyncExceptiontoSyncExceptionbracketWithErrorbracketOnError_bracketOnErrorfinallybracket_bracket withException onExceptiontryJusttryAsync tryAnyDeeptryDeeptryAnytryIOtry handleJust handleAsync handleAnyDeep handleDeep handleAnyhandleIO catchJust catchAsync catchAnyDeep catchDeepcatchAnycatchIO impureThrowthrowTo throwStringthrowIOthrowStringExceptionSyncExceptionWrapperAsyncExceptionWrapper stm-2.5.0.2Control.Concurrent.STM.TArrayTArrayControl.Concurrent.STM.TVarswapTVar stateTVar modifyTVar' modifyTVar mkWeakTVarControl.Concurrent.STM.TQueueTQueue writeTQueue unGetTQueue tryReadTQueue tryPeekTQueue readTQueue peekTQueue newTQueueIO newTQueue isEmptyTQueue flushTQueueControl.Concurrent.STM.TMVarTMVar tryTakeTMVar tryReadTMVar tryPutTMVar takeTMVar swapTMVar readTMVarputTMVar newTMVarIOnewTMVarnewEmptyTMVarIO newEmptyTMVar mkWeakTMVar isEmptyTMVarControl.Concurrent.STM.TChanTChan writeTChan unGetTChan tryReadTChan tryPeekTChan readTChan peekTChan newTChanIOnewTChannewBroadcastTChanIOnewBroadcastTChan isEmptyTChandupTChan cloneTChanControl.Concurrent.STM.TBQueueTBQueue writeTBQueue unGetTBQueuetryReadTBQueuetryPeekTBQueue readTBQueue peekTBQueue newTBQueueIO newTBQueue lengthTBQueue isFullTBQueueisEmptyTBQueue flushTBQueue(stm-chans-3.0.0.9-I1znjmTARYF7WSsuBD2GScControl.Concurrent.STM.TBMQueuefreeSlotsTBMQueueestimateFreeSlotsTBMQueueisFullTBMQueueisEmptyTBMQueueisClosedTBMQueue closeTBMQueue unGetTBMQueuetryWriteTBMQueue writeTBMQueuetryPeekTBMQueue peekTBMQueuetryReadTBMQueue readTBMQueue newTBMQueueIO newTBMQueueTBMQueueData.Time.Format.Parse readSTime readPTimeparseTimeOrErrorparseTimeMultipleM parseTimeM&Data.Time.LocalTime.Internal.ZonedTime ZonedTime zonedTimeZonezonedTimeToLocalTimezonedTimeToUTCutcToZonedTimeutcToLocalZonedTime getZonedTimeData.Time.Format.Format.Class FormatTime formatTimeData.Time.Format.Parse.Class ParseTimeData.Time.Format.Locale TimeLocaleknownTimeZones time12FmttimeFmtdateFmt dateTimeFmtamPmmonthswDaysrfc822DateFormatiso8601DateFormatdefaultTimeLocale&Data.Time.LocalTime.Internal.LocalTime LocalTimelocalTimeOfDaylocalDayutcToLocalTimeut1ToLocalTimelocalTimeToUTClocalTimeToUT1 diffLocalTime addLocalTime&Data.Time.LocalTime.Internal.TimeOfDay TimeOfDaytodSectodMintodHourutcToLocalTimeOfDaytimeToTimeOfDaytimeToDaysAndTimeOfDaytimeOfDayToTimetimeOfDayToDayFraction sinceMidnight pastMidnightmidnightmiddaymakeTimeOfDayValidlocalToUTCTimeOfDaydaysAndTimeOfDayToTimedayFractionToTimeOfDay%Data.Time.LocalTime.Internal.TimeZoneTimeZonetimeZoneSummerOnly timeZoneNametimeZoneMinutesutctimeZoneOffsetString'timeZoneOffsetStringminutesToTimeZonehoursToTimeZone getTimeZonegetCurrentTimeZone-Data.Time.LocalTime.Internal.CalendarDiffTimeCalendarDiffTimectTimectMonthsscaleCalendarDiffTimecalendarTimeTimecalendarTimeDays Data.Time.Clock.Internal.UTCDiff diffUTCTime addUTCTimeData.Time.Clock.POSIXgetCurrentTime&Data.Time.Clock.Internal.UniversalTime UniversalTime ModJulianDategetModJulianDate#Data.Time.Clock.Internal.SystemTimegetTime_resolutionsecondsToNominalDiffTimenominalDiffTimeToSeconds nominalDaysecondsToDiffTimepicosecondsToDiffTimediffTimeToPicosecondsData.Time.Calendar.Week DayOfWeekSaturdayFridayThursday WednesdayTuesdaySundayMondayfirstDayOfWeekOnAfter dayOfWeekDiff dayOfWeekData.Time.Calendar.Gregorian toGregorian showGregoriangregorianMonthLengthfromGregorianValid fromGregoriandiffGregorianDurationRollOverdiffGregorianDurationClipaddGregorianYearsRollOveraddGregorianYearsClipaddGregorianMonthsRollOveraddGregorianMonthsClipaddGregorianDurationRollOveraddGregorianDurationClip YearMonthDayData.Time.Calendar.OrdinalDate isLeapYear MonthOfYear DayOfMonthData.Time.Calendar.DaysDayModifiedJulianDaytoModifiedJulianDaydiffDaysaddDays#Data.Time.Calendar.CalendarDiffDaysCalendarDiffDayscdMonthscdDaysscaleCalendarDiffDays calendarYear calendarWeek calendarMonth calendarDayliftBaseDefault'uuid-types-1.0.5-GeXzgK1qcUxGLXwXVnBwH4Data.UUID.Types.InternalUUIDtshowretrySTMnewUUIDwithTimedFastLoggernewTimedFastLoggerwithFastLoggernewFastLogger1 newFastLogger FastLoggerTimedFastLoggerLogType' LogCallbackLogFileTimedRotateLogFileLogFileNoRotate LogStderrLogNone LogStdoutSystem.Log.FastLogger.LoggerSetreplaceLoggerSet rmLoggerSetrenewLoggerSet flushLogStr pushLogStrLn pushLogStrnewFDLoggerSet newLoggerSetnewStderrLoggerSetNnewStderrLoggerSetnewStdoutLoggerSetNnewStdoutLoggerSetnewFileLoggerSetNnewFileLoggerSet LoggerSetSystem.Log.FastLogger.DatesimpleTimeFormat'simpleTimeFormat newTimeCacheSystem.Log.FastLogger.File prefixTimerotate FileLogSpeclog_backup_number log_file_sizelog_fileTimedFileLogSpectimed_post_processtimed_same_timeframe timed_timefmttimed_log_fileSystem.Log.FastLogger.Types FormattedTime TimeFormatSystem.Log.FastLogger.IOdefaultBufSizeBufSizeSystem.Log.FastLogger.LogStr fromLogStr logStrLengthLogStrToLogStrtoLogStr(interpolate-0.2.1-5NXeddvoiik843q5qd1qys Data.String.Interpolate.IsStringi logOtherCS logErrorCS logWarnCS logInfoCS logDebugCS logOtherNS logErrorNS logWarnNS logInfoNS logDebugNS logOtherN logErrorNlogWarnNlogInfoN logDebugN logWithoutLoc defaultLoc mapNoLoggingT mapLoggingT filterLoggerwithChannelLoggerunChanLoggingTrunChanLoggingTrunStdoutLoggingTrunStderrLoggingTrunFileLoggingT defaultLogStr defaultOutputexecWriterLoggingTrunWriterLoggingT logOtherS logErrorSlogWarnSlogInfoS logDebugSliftLoc logOtherSH logErrorSH logWarnSH logInfoSH logDebugSHlogOtherlogErrorlogWarnlogInfologDebug LogSource MonadLoggermonadLoggerLog MonadLoggerIO askLoggerIO NoLoggingT runNoLoggingTLogLineWriterLoggingTunWriterLoggingTLoggingT runLoggingTtemplate-haskellLanguage.Haskell.TH.SyntaxLocloc_end loc_filename loc_module loc_package loc_start LoggerRefloggerCallback newLoggerRefEndPoint NodeEndPointssecureEndPoint tcpEndPoint endPointPort endPointIp emptyEndPointFlag flagWord8 KeepRetryingAtMost credPassword credLogin AuthenticatedNoneBusHub SubscribePublishSubsubscribeEventHandlerPub publishSTMMessage EventStore getSettings freshUUID publisherstopBus runEventStoretoMsgfromMsgpublish publishWithasSubasPubasHubbusStopbusProcessedEverythingnewBusmonitorIncrPkgCountmonitorIncrConnectionDropmonitorAddDataTransmittedmonitorIncrForceReconnectmonitorIncrHeartbeatTimeouts DiscoverygossipEndpoint runDiscoveryDnsDiscoveryExceptionMaxDiscoveryAttemptReachedDNSDiscoveryErrorstaticEndPointDiscoverysimpleDnsEndPointDiscoveryclusterDnsEndPointDiscovery Stopwatch newStopwatchstopwatchElapsed prettyWord8cmdDesccmdWord8heartbeatRequestCmdheartbeatResponseCmdwriteEventsCmdwriteEventsCompletedCmdtransactionStartCmdtransactionStartCompletedCmdtransactionWriteCmdtransactionWriteCompletedCmdtransactionCommitCmdtransactionCommitCompletedCmddeleteStreamCmddeleteStreamCompletedCmd readEventCmdreadEventCompletedCmdreadStreamEventsForwardCmd#readStreamEventsForwardCompletedCmdreadStreamEventsBackwardCmd$readStreamEventsBackwardCompletedCmdreadAllEventsForwardCmd readAllEventsForwardCompletedCmdreadAllEventsBackwardCmd!readAllEventsBackwardCompletedCmdsubscribeToStreamCmdsubscriptionConfirmationCmdstreamEventAppearedCmdunsubscribeFromStreamCmdsubscriptionDroppedCmd"connectToPersistentSubscriptionCmd%persistentSubscriptionConfirmationCmd,persistentSubscriptionStreamEventAppearedCmdcreatePersistentSubscriptionCmd(createPersistentSubscriptionCompletedCmddeletePersistentSubscriptionCmd(deletePersistentSubscriptionCompletedCmd"persistentSubscriptionAckEventsCmd"persistentSubscriptionNakEventsCmdupdatePersistentSubscriptionCmd(updatePersistentSubscriptionCompletedCmd badRequestCmd notHandledCmdauthenticateCmdauthenticatedCmdnotAuthenticatedCmdidentifyClientCmdclientIdentifiedCmd unknownCmd getCommand_cmdDictPackageResolvedEventBufResolvedIndexedEvent EventRecordNewEventInternalExceptionConnectionClosedByServer eventDataTypeeventMetadataTypeeventDataByteseventMetadataBytesexpVersionInt64newEventtoUTCnewRecordedEventnewResolvedEventnewResolvedEventFromBufheartbeatResponsePackage$aeson-2.1.2.1-4QFSJ9mRhdxDvTHHXtJzK8Data.Aeson.Types.InternalObjectcustomMetaToPairsPair cleanPairs streamACLJSON'protobuf-0.2.1.3-BIGe7zxmwTT94c3n3Jmz8wData.ProtocolBuffers.TypesValuestreamMetadataJSON p_readRoles p_writeRoles p_deleteRolesp_metaReadRolesp_metaWriteRolesp_maxAge p_maxCountp_truncateBeforep_cacheControlp_aclinternalMetaPropertieskeepUserPropertiesparseNominalDiffTimeparseStreamACLparseStreamMetadatabuild strategyTextstrategyFromTextDuration packageCred packageDatapackageCorrelation packageCmdresolvedEventBufPreparePositionresolvedEventBufCommitPositionresolvedEventBufLinkresolvedEventBufEvent NotHandledBufnotHandledAdditionalInfonotHandledReason MasterInfomasterExternalSecureTcpPortmasterExternalSecureTcpAddrmasterExternalHttpPortmasterExternalHttpAddrmasterExternalTcpPortmasterExternalTcpAddr MasterInfoBufbufMasterExternalSecureTcpPortbufMasterExternalSecureTcpAddrbufMasterExternalHttpPortbufMasterExternalHttpAddrbufMasterExternalTcpPortbufMasterExternalTcpAddrNotHandledReason N_NotMaster N_TooBusy N_NotReadyresolvedIndexedLinkresolvedIndexedRecordeventRecordCreatedEpocheventRecordCreatedeventRecordMetadataeventRecordDataeventRecordMetadataTypeeventRecordDataTypeeventRecordType eventRecordIdeventRecordNumbereventRecordStreamIdnewEventMetadata newEventDatanewEventMetadataTypenewEventDataType newEventType newEventId StreamExists EmptyStreamExactAnyJsonBinary eventDataeventId eventType eventTypeTexteventTypeFromStrresolveLinkToBool masterInfomasterInfoNodeEndPointspackageDataAsTextheartbeatRequestPackageparseSingleOrMultiple msDuration secsDuration)PersistentSubscriptionStreamEventAppeared"PersistentSubscriptionConfirmationPersistentSubscriptionNakEventsPersistentSubscriptionAckEventsConnectToPersistentSubscription%UpdatePersistentSubscriptionCompleted"UpdatePersistentSubscriptionResultUpdatePersistentSubscription%DeletePersistentSubscriptionCompleted"DeletePersistentSubscriptionResultDeletePersistentSubscription%CreatePersistentSubscriptionCompleted"CreatePersistentSubscriptionResultCreatePersistentSubscriptionUnsubscribeFromStreamSubscriptionDroppedStreamEventAppearedSubscriptionConfirmationSubscribeToStreamsubscribeToStream_createPersistentSubscription_deletePersistentSubscription_updatePersistentSubscription _connectToPersistentSubscriptionpersistentSubscriptionAckEventspersistentSubscriptionNakEventspsseaEvtpscLastEvtNumberpscIdpscLastCommitPos psneActionpsneMsgpsneProcessedEvtIdspsneIdpsaeProcessedEvtIdspsaeIdctsAllowedInFlightMsgs ctsStreamIdctsId upscReason upscResultUPS_AccessDeniedUPS_FailUPS_DoesNotExist UPS_SuccessupsNamedConsStrategyupsSubMaxCountupsChkPtMinCountupsChkPtMaxCountupsChkPtAfterTimeupsPreferRoundRobinupsMaxRetryCount upsBufSizeupsReadBatchSizeupsLiveBufSizeupsRecordStats upsMsgTimeout upsStartFromupsResolveLinkTos upsStreamId upsGroupName dpscReason dpscResultDPS_AccessDeniedDPS_FailDPS_DoesNotExist DPS_Success dpsStreamId dpsGroupName cpscReason cpscResultCPS_AccessDeniedCPS_FailCPS_AlreadyExists CPS_SuccesscpsNamedConsStrategycpsSubMaxCountcpsChkPtMinCountcpsChkPtMaxCountcpsChkPtAfterTimecpsPreferRoundRobincpsMaxRetryCount cpsBufSizecpsReadBatchSizecpsLiveBufSizecpsRecordStats cpsMsgTimeout cpsStartFromcpsResolveLinkTos cpsStreamId cpsGroupName dropReasonstreamResolvedEventsubscribeLastEventNumbersubscribeLastCommitPossubscribeResolveLinkTossubscribeStreamId PersistActionSubscriptionId PersistDelete PersistUpdate PersistCreatesubSubIdsubLastEventNum subCommitPossubIdtoSubDropReasoncreateRExceptiondeleteRExceptionupdateRException streamIdRaweventToNewEventIOResponseResultRequest newRequest_error _endOfStream _lastNumber _nextNumber_result_events_lastCommitPosition ACCESS_DENIEDERROR NOT_MODIFIEDSTREAM_DELETED NO_STREAMSUCCESS_requireMaster_resolveLinkTos _maxCount _eventNumber _streamId _indexedEvent NOT_FOUND_Error_Result_NextPreparePosition_NextCommitPosition_Events_PreparePosition_CommitPosition_preparePosition_commitPositioncreateAckPackagecreateNakPackagecreateUnsubscribePackagecreateAuthPackageErrorMsg UnknownMsgNotAuthenticatedMsg NotHandledMsg BadRequestMsgConfirmationMsgPersistentConfirmationMsgRegularConfirmationMsgLiveMsg DroppedMsgPersistentEventAppearedMsgEventAppearedMsg ServerMessageconfirmationCommitPosconfirmationLastEventNumconfirmationPersistentSubIddecodeServerMessagemaybeDecodeMessagenewIdentifyPkgnewAuthenticatePkgOpResultLoopSBreakSLoopBreakLifetimeOneTime KeepAliveOP_ACCESS_DENIEDOP_INVALID_TRANSACTIONOP_STREAM_DELETEDOP_WRONG_EXPECTED_VERSIONOP_FORWARD_TIMEOUTOP_COMMIT_TIMEOUTOP_PREPARE_TIMEOUT OP_SUCCESSMailboxmailboxSendPkg mailboxFail mailboxReadmailboxReadDecoded mailboxNew createPkg decodePkg keepLooping keepLoopingS _firstNumber_message_expectedVersion CommittedCommitWrittenWriteStartedStartnewStartnewWrite newCommit _ccMessage _ccResult _ccTransId_cRequireMaster _cTransId _wwMessage _wwResult _wwTransId_wRequireMaster _wTransId_transId _hardDeleteTransmit SendPackageNewTimerServiceTerminatedFatalExceptionFatalCondition InitFailed InitializedService TimerServiceConnectionManagerSystemShutdown SystemInit timerServiceBlobCRStatecrsPkgscrsStateRegistryregistryStopwatch registryState Registry'registryMaxRetryregistryTimeoutregistryWaitingsregistryRequestsRequestsWaitingwaitingMailbox waitingPkgwaitingLifetimerequestLifetimerequestMailboxrequestStartedrequestRetries requestConnIdrequestOriginalrequestIsKeepAliverequestToWaitingwaitingToRequest registryClearregistryRemoveRequest registryNewregistryRegisterregistryPostponeregistryHandle crsStateNewcrsStateDeleteReqcrsStateRegisterReqcrsStateAddPkgregistryCheckAndRetry registryAbort putPackage mandatorySizeConnectionEstablishedConnectionClosedConnectionErrorPackageArrived connectionIdconnectionEndPointenqueuePackagedispose ConnectionRefmaybeConnection RecvOutcome ResetByPeerRecv WrongFraming ParsingErrorConnectionBuilder getConnectionconnectionErrorconnectionBuilderconnectionManagerExec execSettingsexecWaitTillClosed TerminatednewExec writeEventsvolatile_regChan _regStream _regSubId_regExecnewRegularSubscriptiontransactionStartreadStreamEventsreadMetaStream setMetaStream readAllEvents createPersist updatePersist deletePersistpersist_perChan _perSubKey_perCred _perStream _perSubId_perExecnewPersistentSubscriptionpersistentGetSubKeycatchup _catchupChan _catchupSub_catchupStream _catchupExecreceivedAlready nextTargetnewCatchupSubscription _unTransId_tConn_tExpVer _tTransId_tStream_type _settings_execreadEventsCommonsubscribeFromCommonControl.Monad.Trans.ExceptExceptTversiongetDataFileName getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDir