YN&      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~     (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone "Classifies info-like log messages.Indicates connection Indicates connection .Indicates connection .Indicates current attempt.#Classifies error-like log messages. Indicates parsing error message. Indicates max attempt value. Logging main data structure.       (C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone i.NET TimeSpan: TimeSpan represents a duration of time. A TimeSpan can be negative or positive. Sorry.  !"#$%&'()*+,-./0 +  !"#$%&'()*+,-./0(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(+0tbWhether or not the persistent subscription should resolve linkTo events to their linked events. 4Where the subscription should start from (position).!UWhether or not in depth latency statistics should be tracked on this subscription."[The amount of time after which a message should be considered to be timeout and retried.#_The maximum number of retries (due to timeout) before a message get considered to be parked.$AThe size of the buffer listening to live messages as they happen.%;The number of events read at a time when paging in history.&;The number of events to cache when paging through history.'+The amount of time to try checkpoint after.(-The minimum number of messages to checkpoint.)gThe maximum number of message to checkpoint. If this number is reached, a checkpoint will be forced.**The maximum number of subscribers allowed.+@The strategy to use for distributing events to client consumers.,KSystem supported consumer strategies for use with persistent subscriptions.-:Distribute events to each client in a round robin fashion.._Distributes events to a single client until it is full. Then round robin to the next client./NRepresents stream metadata as a series of properties for system data and a 9 object for user metadata.0 When the stream is soft-deleted.13When the stream is either not found or 'no stream'.3The name of the stream.4#The version of the metadata format.5A 9$ containing user-specified metadata.9Represents stream metadata with strongly typed properties for system values and a dictionary-like interface for custom values.;3The maximum number of events allowed in the stream.<0The maximum age of events allowed in the stream.=tThe event number from which previous events can be scavenged. This is used to implement soft-deletion of streams.>9The amount of time for which the stream head is cachable.?'The access control list for the stream.@TAn enumerable of key-value pairs of keys to JSON text for user-provider metadata.A/Represents an access control list for a stream.C-Roles and users permitted to read the stream.D1Roles and users permitted to write to the stream.E2Roles and users permitted to delete to the stream.F2Roles and users permitted to read stream metadata.G3Roles and users permitted to write stream metadata.HGlobal  Connection settingsO In secondsQ!Represents reconnection strategy.R%Holds login and password information.S;Represents a multi-request transaction with the EventStore.1LThe ID of the transaction. This can be used to recover a transaction later.2The name of the stream.3Expected version of the stream.T(Asynchronously commits this transaction.U9Asynchronously writes to a transaction in the EventStore.VRollback this transaction.WPRepresents the direction of read operation (both from $all an usual streams).XFrom end to beginningYFrom beginning to endZBA structure representing a single event or an resolved link event.\.The event, or the resolved link event if this Z is a link event.]The link event if this Z is a link event.^&Represents a previously written event.`-The event stream that this event belongs to.a*Unique identifier representing this event.b#Number of this event in the stream.cType of this event.d$Representing the data of this event.e5Representing the metadada associated with this event.f;Indicates whether the content is internally marked as json.g7Representing when this event was created in the system.h"Returned after deleting a stream. o of the write.k#Returned after writing to a stream.m$Next expected version of the stream.no of the write.ocA structure referring to a potential logical record position in the EventStore transaction file.qCommit position of the recordrPrepare position of the records,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 s except for  . When using ` the EventStore will do its best to assure idempotency but will not guarantee idempotency.tHolds event data.uRContains event information like its type and data. Only used for write queries.xReasonzExpected, Found{Stream}Stream~Stream and Expected Version!Creates a event using JSON format.Create a event with metadata using JSON formatGThis 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./Representing the start of the transaction file.-Representing the end of the transaction file.DReturns the event that was read or which triggered the subscription.If this Za represents a link event, the link will be the original event, otherwise it will be the event.Indicates whether this Z is a resolved link event.&The stream name of the original event.The ID of the original event.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.4Millisecond timespanA" with no role or users whatsoever.+Gets a custom property value from metadata.*Get a custom property value from metadata.9 with everything set to 5, using  and an empty 6.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 A from a 7. Modifies a A using a 7.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. Sets a custom metadata property. Builds a 9 from a 6. Modifies a 9 using a 60System default persistent subscription settings.& !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQ789:;<=>R?@ABCDSE123TUVWXYZ[\]^_`abcdefghijklmnopqrFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~stuvwxyz{|}~ Event typeEvent ID, generated if 5 Event data Event typeEvent IDData content typeMetadata content type Event dataMetadataLoginPassword4 !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQ789:;<=>R?@ABCDSE123TUVWXYZ[\]^_`abcdefghijklmnopqrFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~stuvwxyz{|}~4 !"#$%&'()*+,.-/210345336789:;<=>?@ABCDEFGHIJKLMNOPQ879:;<=>R?@ABDCSE123TUVWYXZ[\]^ _`abcdefghijklmnopqrFGHIJKLMNOP QRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~stuv~}|{zyxw4(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone+M HostName Port MaxAttempt's value (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone:M$ (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0     StreamExpected versionEventsRequire master       (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0 CRepresents the result of a single read operation to the EventStore.,Representing the status of the read attempt.The name of the stream read.OThe starting point (represented as a sequence number) of the read operation.'The next event number that can be read.$The last event number in the stream.:Representing whether or not this is the end of the stream.The events read represented as Z"The direction of the read request.JEnumeration detailing the possible outcomes of reading a slice of a stream) !"#$%&'()*+,-./01234561  !"#$%&'()*+,-./0123456 (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0:Result of a single event read operation to the EventStore.Attempt status Stream name Event numberEEnumeration representing the status of a single event read operation. 789:;<=>?@ABCDResolve link TOSEFGHID 789:;<=>?@ABCDEFGHI(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(04The result of a read operation from the $all stream.,Representing the status of the read attempt.FRepresenting the position where the next slice should be read from.CRepresenting the position where the next slice should be read from.?Representing whether or not this is the end of the $all stream.The events read.The direction of read request.QEnumeration detailing the possible outcomes of reading a slice of $all stream.%JKLMNOPQRSTUVWXYZ[\]^_`a\ JKLMNOPQRSTUVWXYZ[\]^_`a(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0bcdefghijklmnopqrsto bcdefghijklmnopqrst(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone!"(+0:=KMU%Represents a persistent subscription.!Represents catch-up subscription.8Errors that could arise during a catch-up subscription. u% value represents the stream name.QRepresents a subscription to a single stream or $all stream in the EventStore.9Represents a subscription that is directly identifiable.  and  fit that description while  doesn't. Because k reads all events from a particular checkpoint and when it's finished, it issues a subscription request.vInternal use only because we all know that lawless type-classes are bad. But Haskell clearly lacks of a proper module system. So meanwhile, we use type-class as a (hacky) way to have a bit of modularity.&Represents a subscription to a stream.?The name of the stream to which the subscription is subscribed./Asynchronously unsubscribe from the the stream.Awaits for the next event.,True if this subscription is to $all stream.#Value's type returned when calling 1Represents the reason subscription drop happened. Gets the ID of the subscription.]The last commit position seen on the subscription (if this a subscription to $all stream).aThe last event number seen on the subscription (if this is a subscription to a single stream).WDetermines whether or not any link events encontered in the stream will be resolved. Waits until " subscription catch-up its stream.Non blocking version of .>Acknowledges those event ids have been successfully processed.FAcknowledges those event ids have failed to be processed successfully.wxyz{|}~v      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijkwxyz{|}~v      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVjwxyz{|~}v      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijk(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNoneM/lmnopqrstuvwxyz{|}~lmnopqrstuvwxyz{|}~(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone+=K(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone4Represents a connection to a single EventStore node.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 a SQL 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 operation 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 recommend to use it in this way.Asynchronously closes the .Sends a single u to given stream.Sends a list of u to given stream.Deletes given stream.%Starts a transaction on given stream.'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 backwardSubcribes to given stream.Subcribes to $all stream.HSubscribes to given stream. If last checkpoint is defined, this will  from that event number, otherwise from the beginning. Once last stream event reached up, a subscription request will be sent using .Same as  but applied to $all stream..Asynchronously sets the metadata for a stream. -Asynchronously gets the metadata of a stream. BAsynchronously create a persistent subscription group on a stream. BAsynchronously update a persistent subscription group on a stream. BAsynchronously delete a persistent subscription group on a stream. QAsynchronously connect to a persistent subscription given a group on a stream.HostNamePort Stream name Stream name Stream name Hard delete Stream name Stream name Event numberResolve Link Tos Stream nameFrom event number Batch sizeResolve Link Tos Stream nameFrom event number Batch sizeResolve Link Tos Batch sizeResolve Link Tos Batch sizeResolve Link Tos Stream nameResolve Link TosResolve Link Tos Stream nameResolve Link TosLast checkpoint Batch sizeResolve Link TosLast checkpoint Batch size     )  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      utRHIJKLMNOPQ/21034533 ABCDEFG9:;<=>?@876 STUVTVU !"#$%&'()*+,.-    hijklmn^_`abcdefgopqrWYXZ[\]v~}|{zyxws      !"#$%&'()*+,-./01233456789:;<=>?@ABCDEFDGHIJKLMMNOPQRSTTUVWXYZZ[\]^_`abcdefghijkklmnnopqrstuvwwxyyz{||}~                        #!"#$%&'()*+,-./0123456789:;<=>?@ABCDEFFGHIJcKLMNOdPPQRSTUUVWXXYZ[\]^_`abccdefghijkklmnnopqrrstuvvwxyzz{|}~~b                                                ! "    # $ % % & ' ( ) ) * + , - . / 0    1 233456789:;;<=>?@ABC  DEFFGHIJKKLMNOPQ  RSTUVWXXYZ[\]^__``abcdeefghijkklmnoopqrstuvuwxyz{|}~      !"#$%&'()*+,,--./00112233456789:;<=>?@ABCDEFGHIJKLMNOPQRSSTUVWXYZ[\]^_`abcdefghijklmbnopqopropsoptopuopvopwopxopyopzop{op|op}op~opopopopopopopopopopopopopopopopopopopopopopopopopeventstore-0.8.0.0Database.EventStoreDatabase.EventStore.Logging(Database.EventStore.Internal.Util.Sodium%Database.EventStore.Internal.TimeSpan"Database.EventStore.Internal.Types'Database.EventStore.Internal.Connection%Database.EventStore.Internal.Packages.Database.EventStore.Internal.Manager.Operation#Database.EventStore.Internal.Reader#Database.EventStore.Internal.Writer;Database.EventStore.Internal.Operation.WriteEventsOperation@Database.EventStore.Internal.Operation.ReadStreamEventsOperation9Database.EventStore.Internal.Operation.ReadEventOperation=Database.EventStore.Internal.Operation.ReadAllEventsOperation InfoMessage Disconnected ConnectedConnectionClosed Connecting ErrorMessagePackageParsingErrorWrongPackageFramingMaxAttemptConnectionReachedLogInfoErrorTimeSpan timeSpanTickstimeSpanHoursMinsSecstimeSpanDaysHoursMinsSecstimeSpanDaysHoursMinsSecsMillistimeSpanGetTickstimeSpanGetDaystimeSpanGetHourstimeSpanGetMinutestimeSpanGetSecondstimeSpanGetMillistimeSpanFromSecondstimeSpanFromMinutestimeSpanFromHourstimeSpanFromDaystimeSpanTotalMillisPersistentSubscriptionSettingspsSettingsResolveLinkTospsSettingsStartFrompsSettingsExtraStatspsSettingsMsgTimeoutpsSettingsMaxRetryCountpsSettingsLiveBufSizepsSettingsReadBatchSizepsSettingsHistoryBufSizepsSettingsCheckPointAfterpsSettingsMinCheckPointCountpsSettingsMaxCheckPointCountpsSettingsMaxSubsCountpsSettingsNamedConsumerStrategySystemConsumerStrategy RoundRobinDispatchToSingleStreamMetadataResultDeletedStreamMetadataResultNotFoundStreamMetadataResultstreamMetaResultStreamstreamMetaResultVersionstreamMetaResultDataStreamMetadataBuilderStreamACLBuilderBuilderStreamMetadatastreamMetadataMaxCountstreamMetadataMaxAgestreamMetadataTruncateBeforestreamMetadataCacheControlstreamMetadataACLstreamMetadataCustom StreamACLstreamACLReadRolesstreamACLWriteRolesstreamACLDeleteRolesstreamACLMetaReadRolesstreamACLMetaWriteRolesSettingss_heartbeatIntervals_heartbeatTimeouts_requireMaster s_credentialss_retrys_reconnect_delay_secss_loggerRetry Credentials TransactiontransactionCommittransactionSendEventstransactionRollback ReadDirectionBackwardForward ResolvedEventresolvedEventRecordresolvedEventLink RecordedEventrecordedEventStreamIdrecordedEventIdrecordedEventNumberrecordedEventTyperecordedEventDatarecordedEventMetadatarecordedEventIsJsonrecordedEventCreated DeleteResultdeleteStreamPosition WriteResultwriteNextExpectedVersion writePositionPositionpositionCommitpositionPrepareExpectedVersion EventDataEventOperationExceptionInvalidOperation ServerErrorProtobufDecodingErrorInvalidServerResponse AccessDeniedInvalidTransaction StreamDeletedWrongExpectedVersion createEventwithJsonwithJsonAndMetadata anyStreamnoStream emptyStream exactStream positionStart positionEndresolvedEventOriginal eventResolvedresolvedEventOriginalStreamIdresolvedEventOriginalId credentialsatMost keepRetryingdefaultSettingsemptyStreamACL$streamMetadataGetCustomPropertyValuestreamMetadataGetCustomPropertyemptyStreamMetadata setReadRoles setReadRole setWriteRoles setWriteRolesetDeleteRoles setDeleteRolesetMetaReadRolessetMetaReadRolesetMetaWriteRolessetMetaWriteRolebuildStreamACLmodifyStreamACL setMaxCount setMaxAgesetTruncateBeforesetCacheControlsetACL modifyACLsetCustomPropertybuildStreamMetadatamodifyStreamMetadata%defaultPersistentSubscriptionSettingsConnectionException MaxAttemptStreamEventsSlicestreamEventsSliceResultstreamEventsSliceStreamIdstreamEventsSliceStartstreamEventsSliceNextstreamEventsSliceLaststreamEventsSliceIsEOSstreamEventsSliceEventsstreamEventsSliceDirectionReadStreamResultRS_ACCESS_DENIEDRS_ERRORRS_NOT_MODIFIEDRS_STREAM_DELETED RS_NO_STREAM RS_SUCCESS ReadResultreadResultStatusreadResultStreamIdreadResultEventNumberreadResultResolvedEventReadEventResultRE_ACCESS_DENIEDRE_ERRORRE_STREAM_DELETED RE_NO_STREAM RE_NOT_FOUND RE_SUCCESSAllEventsSliceallEventsSliceResultallEventsSliceFromallEventsSliceNextallEventsSliceIsEOSallEventsSliceEventsallEventsSliceDirection ReadAllResultRA_ACCESS_DENIEDRA_ERRORRA_NOT_MODIFIED RA_SUCCESS PersistentCatchup CatchupErrorCatchupSubscriptionDropReasonCatchupUnexpectedStreamStatusCatchupStreamDeletedRegular Identifiable Subscription subStreamIdsubUnsubscribe subNextEventsubIsSubscribedToAll NextEvent NakActionNA_StopNA_SkipNA_RetryNA_Park NA_Unknown DropReasonD_PersistentSubscriptionDeleted D_NotFoundD_AccessDeniedD_UnsubscribedsubIdsubLastCommitPossubLastEventNumbersubResolveLinkToswaitTillCatchup hasCaughtUpnotifyEventsProcessednotifyEventsFailed Connectionconnectshutdown sendEvent sendEvents deleteStreamtransactionStart readEventreadStreamEventsForwardreadStreamEventsBackwardreadAllEventsForwardreadAllEventsBackward subscribesubscribeToAll subscribeFromsubscribeToAllFromsetStreamMetadatagetStreamMetadatacreatePersistentSubscriptionupdatePersistentSubscriptiondeletePersistentSubscriptionconnectToPersistentSubscription pushAsync pushAsync2 pushAsync3 pushAsync4uuid-types-1.0.1Data.UUID.Types.InternalUUID FormatLiteralNegativePositiveparseFormatLiteral parseDays parseHours parseMinutes parseSeconds parseMillisparseBaseTimeSpan parseTimeSpanmillisPerSecondmillisPerMinute millisPerHour millisPerDayticksPerMillisecondticksPerSecondticksPerMinute ticksPerHour ticksPerDay millisPerTick maxMillis minMillispaddedtimeSpanBuilderinterval$fFromJSONTimeSpan$fToJSONTimeSpan$fShowTimeSpan transactionIdtransactionStreamIdtransactionExpectedVersion msDiffTime Data.MaybeNothing aeson-0.9.0.1Data.Aeson.Types.InternalObject KeepRetryingAtMostPackage packageCmdpackageCorrelation packageData packageCred credLogin credPasswordFlag AuthenticatedNoneResolvedEventBufresolvedEventBufEventresolvedEventBufLinkresolvedEventBufCommitPositionresolvedEventBufPreparePositionResolvedIndexedEventresolvedIndexedRecordresolvedIndexedLink EventRecordeventRecordStreamIdeventRecordNumber eventRecordIdeventRecordTypeeventRecordDataTypeeventRecordMetadataTypeeventRecordDataeventRecordMetadataeventRecordCreatedeventRecordCreatedEpochTransactionCommitCompletedtransactionCCIdtransactionCCResulttransactionCCMessagetransactionCCFirstNumbertransactionCCLastNumbertransactionCCPreparePositiontransactionCCCommitPositionTransactionCommittransactionCommitIdtransactionCommitRequireMasterTransactionWriteCompletedtransactionWCIdtransactionWCResulttransactionWCMessageTransactionWritetransactionWriteIdtransactionWriteEventstransactionWriteRequireMasterTransactionStartCompletedtransactionSCIdtransactionSCResulttransactionSCMessageTransactionStarttransactionStartStreamIdtransactionStartExpectedVersiontransactionStartRequireMasterNewEvent newEventId newEventTypenewEventDataTypenewEventMetadataType newEventDatanewEventMetadataOpResultOP_ACCESS_DENIEDOP_INVALID_TRANSACTIONOP_STREAM_DELETEDOP_WRONG_EXPECTED_VERSIONOP_FORWARD_TIMEOUTOP_COMMIT_TIMEOUTOP_PREPARE_TIMEOUT OP_SUCCESSExact EmptyStreamNoStreamAnyJson eventTypeeventId eventDataOperationExceptionalInternalExceptionStoppedConnectionClosedByServer eventDataTypeeventMetadataTypeeventDataByteseventMetadataBytesexpVersionInt32newEventnewTransactionStartnewTransactionWritenewTransactionCommittoUTCnewRecordedEventnewResolvedEventnewResolvedEventFromBuf flagWord8 _settingsLogcustomMetaToPairs streamACLJSONstreamMetadataJSON p_readRoles p_writeRoles p_deleteRolesp_metaReadRolesp_metaWriteRolesp_maxAge p_maxCountp_truncateBeforep_cacheControlp_aclinternalMetaPropertieskeepUserPropertiesparseNominalDiffTimeparseStreamACLparseStreamMetadatabuild strategyTextstrategyFromText$fFromJSONStreamMetadata$fDecodeResolvedEventBuf$fDecodeResolvedIndexedEvent$fDecodeEventRecord"$fDecodeTransactionCommitCompleted$fEncodeTransactionCommit!$fDecodeTransactionWriteCompleted$fEncodeTransactionWrite!$fDecodeTransactionStartCompleted$fEncodeTransactionStart$fEncodeNewEvent$fExceptionOperationException$fExceptionInternalExceptionconnUUID connClose connFlushconnSendconnRecv newConnectionsecsregularConnection$fExceptionConnectionExceptionheartbeatPackageheartbeatResponsePackage putPackagecredSize mandatorySizeResponseRemoveRegisterOperationParams opSettings opRequestCmd opResponseCmd opRequest opSuccess opFailure OperationoperationCreatePackageoperationInspectDecision Subscribed Reconnection EndOperation DoNothingManager initManagercreateOperation createPackage inspectiondeeperInspectionoperationNetworkunexpectedDecisionregisterremoveresponse readerThreadgetLengthPrefix getPackagegetFlaggetCredEntryLengthgetCredentialsgetUUID writerThreadWriteEventsCompleted_writeCompletedResult_writeCompletedMessage_writeCompletedFirstNumber_writeCompletedLastNumber_writeCompletedPreparePosition_writeCompletedCommitPosition WriteEvents_writeStreamId_writeExpectedVersion _writeEvents_writeRequireMasternewWriteEventswriteEventsOperationinspectsucceedfailedeventToNewEvent$fDecodeWriteEventsCompleted$fEncodeWriteEventsReadStreamEventsCompleted_readSECEvents_readSECResult_readSECNextNumber_readSECLastNumber_readSECEndOfStream_readSECLastCommitPosition _readSECErrorReadStreamEvents _readStreamId_readStreamEventNumber_readStreamMaxCount_readStreamResolveLinkTos_readStreamRequireMasternewReadStreamEventsnewStreamEventsSlicereadStreamEventsOperation!$fDecodeReadStreamEventsCompleted$fEncodeReadStreamEventsReadEventCompletedreadCompletedResultreadCompletedIndexedEventreadCompletedError ReadEventreadEventStreamIdreadEventNumberreadEventResolveLinkTosreadEventRequireMaster newReadEvent newReadResultreadEventOperation$fDecodeReadEventCompleted$fEncodeReadEventReadAllEventsCompletedreadAECCommitPositionreadAECPreparePosition readAECEventsreadAECNextCommitPositionreadAECNextPreparePosition readAECResult readAECError ReadAllEventsreadAllEventsCommitPositionreadAllEventsPreparePositionreadAllEventsMaxCountreadAllEventsResolveLinkTosreadAllEventsRequireMasternewReadAllEventsnewAllEventsSlicereadAllEventsOperation$fDecodeReadAllEventsCompleted$fEncodeReadAllEventsDeleteStreamCompleted_deleteCompletedResult_deleteCompletedMessage_deleteCompletedPreparePosition_deleteCompletedCommitPosition DeleteStream_deleteStreamId_deleteStreamExpectedVersion_deleteStreamRequireMaster_deleteStreamHardDeletenewDeleteStreamdeleteStreamOperation$fDecodeDeleteStreamCompleted$fEncodeDeleteStream text-1.2.1.1Data.Text.InternalTextPushDropped droppedReason droppedSub droppedId SubCommandSubmitPersistAction SubscribeTo RegisterSub Subscribe_subId _subCallback _subStream_subResolveLinkTosAppeared_appSub_appEvt _pendings _ongoings_pendingPersistActionsPersistActionConfirmed_pacId _pacResult_pacCBPendingPersistAction_ppaId _ppaGroup _ppaStream_ppaTyp_ppaCBAckCmdNakCmd PersistAction PersistDelete PersistUpdate PersistCreate _persistId _persistChan _persistSubId _persistGroup_persistLastCPos_persistLastENum_persistAckCmd _catchupSub_regId_regResolveLinkTos_regLastCommitPos_regLastEventNumber_regChan_getId_getLastCommitPos_getLastEventNumber_pushEvt _subInternalOnGoing_ongTyp_ongSub Confirmed_conId_conTyp_conCB_conSubPending_penId_penSub_penCbSub PersistentSub RegularSub)PersistentSubscriptionStreamEventAppearedpsseaEvt"PersistentSubscriptionConfirmationpscLastCommitPospscIdpscLastEvtNumberPersistentSubscriptionNakEventspsneIdpsneProcessedEvtIdspsneMsg psneActionPersistentSubscriptionAckEventspsaeIdpsaeProcessedEvtIdsConnectToPersistentSubscriptionctsId ctsStreamIdctsAllowedInFlightMsgs%UpdatePersistentSubscriptionCompleted upscResult upscReason"UpdatePersistentSubscriptionResultUPS_AccessDeniedUPS_FailUPS_DoesNotExist UPS_SuccessUpdatePersistentSubscription upsGroupName upsStreamIdupsResolveLinkTos upsStartFrom upsMsgTimeoutupsRecordStatsupsLiveBufSizeupsReadBatchSize upsBufSizeupsMaxRetryCountupsPreferRoundRobinupsChkPtAfterTimeupsChkPtMaxCountupsChkPtMinCountupsSubMaxCountupsNamedConsStrategy%DeletePersistentSubscriptionCompleted dpscResult dpscReason"DeletePersistentSubscriptionResultDPS_AccessDeniedDPS_FailDPS_DoesNotExist DPS_SuccessDeletePersistentSubscription dpsGroupName dpsStreamId%CreatePersistentSubscriptionCompleted cpscResult cpscReason"CreatePersistentSubscriptionResultCPS_AccessDeniedCPS_FailCPS_AlreadyExists CPS_SuccessCreatePersistentSubscription cpsGroupName cpsStreamIdcpsResolveLinkTos cpsStartFrom cpsMsgTimeoutcpsRecordStatscpsLiveBufSizecpsReadBatchSize cpsBufSizecpsMaxRetryCountcpsPreferRoundRobincpsChkPtAfterTimecpsChkPtMaxCountcpsChkPtMinCountcpsSubMaxCountcpsNamedConsStrategyUnsubscribeFromStreamSubscriptionDropped dropReasonStreamEventAppearedstreamResolvedEventSubscriptionConfirmationsubscribeLastCommitPossubscribeLastEventNumberSubscribeToStreamsubscribeStreamIdsubscribeResolveLinkTossubscribeToStream_createPersistentSubscription_deletePersistentSubscription_updatePersistentSubscription _connectToPersistentSubscriptionpersistentSubscriptionAckEventspersistentSubscriptionNakEvents _subPushEvtmaybeDecodeMessageunsafeDecodeMessageonEventAppeared confirmSubsubscriptionNetworkcreateSubscriptionPackagecreateConnectRegularPackagecreateConnectPersistPackagecreateAckCmdPackagecreateAckPackagecreateNakPackagecreateUnsubscribePackagecreatePersistActionPkg dropError nonEmptyTextonPersistActionConfirmedpersistActionConfirmedsubscribeRequestdropped confirmednewPersistActionperistentCreationFailurepersistentCreationExistspersistentDoesNotExistpersistentAccessDenied$fPushPersistent$fIdentifiablePersistent$fExceptionCatchupError $fPushRegular$fIdentifiableRegular1$fDecodePersistentSubscriptionStreamEventAppeared*$fDecodePersistentSubscriptionConfirmation'$fEncodePersistentSubscriptionNakEvents'$fEncodePersistentSubscriptionAckEvents'$fEncodeConnectToPersistentSubscription-$fDecodeUpdatePersistentSubscriptionCompleted$$fEncodeUpdatePersistentSubscription-$fDecodeDeletePersistentSubscriptionCompleted$$fEncodeDeletePersistentSubscription-$fDecodeCreatePersistentSubscriptionCompleted$$fEncodeCreatePersistentSubscription$fEncodeUnsubscribeFromStream$fDecodeSubscriptionDropped$fDecodeStreamEventAppeared $fDecodeSubscriptionConfirmation$fEncodeSubscribeToStreamCleanupSnapshotConnectionSnapshot_conHost_conPort Reconnected ReconnectCleanupConnectStateOnline_uuidCon _packageCount_host_port_cleanupOffline ProcessorCmdConnectPersist DeletePersist UpdatePersist CreatePersistNewSub NewOperation DoShutdown DoConnectEResultResult newProcessorheartbeatRequestCmdnetworkconnectSnapshot connection recoveringreconnectSnapshotcleanupSnapshot connected reconnectedreceivedTransactionEnv_transSettings_transProcessor_transStreamId_transExpectedVersiontransactionStartOperation inspectTrans succeedTranscreateTransactiontransactionWriteOperationtransactionCommitOperation inspectWrite succeedWrite inspectCommit succeedCommit createAsyncdefaultBatchSize catchupStartcatchupAllStartreadEventsTill readAllTillkeepAwaitingSubEvent_runCmd _settingsreadStreamEventsCommonreadAllEventsCommonextractStreamMetadataResult metaStreamOf async-2.0.2Control.Concurrent.AsyncmapConcurrently concurrentlyrace_racelink2linkwaitBothwaitEitherCancel waitEither_ waitEitherwaitEitherCatchCancelwaitEitherCatch waitAnyCancelwaitAnywaitAnyCatchCancel waitAnyCatch cancelWithcancelpollSTM waitCatchSTMwaitSTMpoll waitCatchwaitwithAsyncOnWithUnmaskwithAsyncWithUnmask withAsyncOnwithAsyncBound withAsyncasyncOnWithUnmaskasyncWithUnmaskasyncOn asyncBoundasync asyncThreadIdAsyncrunConcurrently Concurrently