addHandler | MessageDb.Handlers |
addIdentityToCategory | MessageDb.StreamName |
addMaybeIdentityToCategory | MessageDb.StreamName |
addProjectionHandler | MessageDb.Handlers |
addSubscriptionHandler | MessageDb.Handlers |
BatchSize | MessageDb.Functions, MessageDb.Projection |
CategoryName | MessageDb.StreamName |
categoryName | |
1 (Function) | MessageDb.StreamName |
2 (Function) | MessageDb.Subscription |
categoryNameToText | MessageDb.StreamName |
categoryOfStream | MessageDb.StreamName |
Condition | |
1 (Type/Class) | MessageDb.Functions |
2 (Data Constructor) | MessageDb.Functions |
condition | MessageDb.Subscription |
conditionToText | MessageDb.Functions |
ConsumerGroup | |
1 (Type/Class) | MessageDb.Functions |
2 (Data Constructor) | MessageDb.Functions |
consumerGroup | MessageDb.Subscription |
consumerGroupMember | MessageDb.Functions |
consumerGroupSize | MessageDb.Functions |
Correlation | |
1 (Type/Class) | MessageDb.Functions |
2 (Data Constructor) | MessageDb.Functions |
correlation | MessageDb.Subscription |
correlationToText | MessageDb.Functions |
CreatedAt | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
createdAtToUTCTime | MessageDb.Message |
CurrentPosition | MessageDb.Subscription.PositionStrategy |
DoesExist | MessageDb.Functions |
DoesNotExist | MessageDb.Functions |
dontSave | MessageDb.Subscription.PositionStrategy |
emptyHandlers | MessageDb.Handlers |
expectedToStreamVersion | MessageDb.Functions |
ExpectedVersion | |
1 (Type/Class) | MessageDb.Functions |
2 (Data Constructor) | MessageDb.Functions |
ExpectedVersionViolation | |
1 (Type/Class) | MessageDb.Functions |
2 (Data Constructor) | MessageDb.Functions |
expectedVersionViolationToSqlError | MessageDb.Functions |
FailedMessage | |
1 (Type/Class) | MessageDb.Subscription.FailedMessage |
2 (Data Constructor) | MessageDb.Subscription.FailedMessage |
failedMetadataReason | MessageDb.Message |
failedPayloadReason | MessageDb.Message |
FailureReason | MessageDb.Subscription.FailureStrategy |
FailureStrategy | |
1 (Type/Class) | MessageDb.Subscription.FailureStrategy |
2 (Data Constructor) | MessageDb.Subscription.FailureStrategy |
failureStrategy | MessageDb.Subscription |
fetch | MessageDb.Projection |
FixedSize | MessageDb.Functions, MessageDb.Projection |
fromHandler | MessageDb.Handlers |
fromPositionUpdateInterval | MessageDb.Subscription.PositionStrategy |
getCategoryMessages | MessageDb.Functions |
getLastStreamMessage | MessageDb.Functions |
getMessage | MessageDb.Handlers |
getParsedMessage | MessageDb.Handlers |
getStreamMessages | MessageDb.Functions |
GlobalPosition | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
globalPositionToInteger | MessageDb.Message |
handle | MessageDb.Handlers |
HandleError | MessageDb.Handlers |
HandleFailure | MessageDb.Subscription.FailureStrategy |
handleFailures | MessageDb.Subscription.FailedMessage |
Handler | |
1 (Type/Class) | MessageDb.Handlers |
2 (Data Constructor) | MessageDb.Handlers |
HandlerNotFound | MessageDb.Handlers |
HandlerParseFailure | MessageDb.Handlers |
Handlers | MessageDb.Handlers |
handlers | |
1 (Function) | MessageDb.Subscription |
2 (Function) | MessageDb.Projection |
IdentityName | |
1 (Type/Class) | MessageDb.StreamName |
2 (Data Constructor) | MessageDb.StreamName |
identityNameToText | MessageDb.StreamName |
identityOfStream | MessageDb.StreamName |
ignoreFailures | MessageDb.Subscription.FailureStrategy |
initial | MessageDb.Projection |
LastPositionSaved | MessageDb.Subscription.PositionStrategy |
listToHandlers | MessageDb.Handlers |
logFailure | MessageDb.Subscription.FailureStrategy |
logMessages | MessageDb.Subscription |
lookupById | MessageDb.Functions |
lookupByPosition | MessageDb.Functions |
Message | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
message | |
1 (Function) | MessageDb.Subscription.FailedMessage |
2 (Function) | MessageDb.Projection |
messageCreatedAt | MessageDb.Message |
messageGlobalPosition | MessageDb.Message |
MessageId | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
messageId | MessageDb.Message |
messageIdToUUID | MessageDb.Message |
messageMetadata | MessageDb.Message |
messagePayload | MessageDb.Message |
messagesPerTick | MessageDb.Subscription |
messageStream | MessageDb.Message |
messageStreamPosition | MessageDb.Message |
MessageType | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
messageType | |
1 (Function) | MessageDb.Message |
2 (Function) | MessageDb.Subscription.FailedMessage |
messageTypeOf | MessageDb.Message |
messageTypeToText | MessageDb.Message |
Metadata | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
metadataToValue | MessageDb.Message |
Microseconds | |
1 (Type/Class) | MessageDb.Units |
2 (Data Constructor) | MessageDb.Units |
microsecondsToNatural | MessageDb.Units |
newMessageId | MessageDb.Message |
nullMetadata | MessageDb.Message |
nullPayload | MessageDb.Message |
NumberOfMessages | |
1 (Type/Class) | MessageDb.Units |
2 (Data Constructor) | MessageDb.Units |
numberOfMessagesToNatural | MessageDb.Units |
ParsedMessage | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
parsedMetadata | MessageDb.Message |
parsedPayload | MessageDb.Message |
parseExpectedVersionViolation | MessageDb.Functions |
parseMessage | MessageDb.Message |
ParseMessageFailure | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
parseMetadata | MessageDb.Message |
parsePayload | MessageDb.Message |
Payload | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
payloadToValue | MessageDb.Message |
PositionSaved | MessageDb.Subscription.PositionStrategy |
PositionStrategy | |
1 (Type/Class) | MessageDb.Subscription.PositionStrategy |
2 (Data Constructor) | MessageDb.Subscription.PositionStrategy |
positionStrategy | MessageDb.Subscription |
PositionUpdateInterval | MessageDb.Subscription.PositionStrategy |
PositioUpdateInterval | MessageDb.Subscription.PositionStrategy |
project | MessageDb.Projection |
Projected | |
1 (Type/Class) | MessageDb.Projection |
2 (Data Constructor) | MessageDb.Projection |
Projection | |
1 (Type/Class) | MessageDb.Projection |
2 (Data Constructor) | MessageDb.Projection |
projectionHandle | MessageDb.Handlers |
ProjectionHandler | MessageDb.Handlers |
projectionHandler | MessageDb.Handlers |
ProjectionHandlers | MessageDb.Handlers |
reason | |
1 (Function) | MessageDb.Subscription.FailedMessage |
2 (Function) | MessageDb.Projection |
removeHandler | MessageDb.Handlers |
restore | MessageDb.Subscription.PositionStrategy |
runHandler | MessageDb.Handlers |
save | MessageDb.Subscription.PositionStrategy |
start | MessageDb.Subscription |
state | MessageDb.Projection |
StreamName | |
1 (Type/Class) | MessageDb.StreamName |
2 (Data Constructor) | MessageDb.StreamName |
streamNameToText | MessageDb.StreamName |
StreamPosition | |
1 (Type/Class) | MessageDb.Message |
2 (Data Constructor) | MessageDb.Message |
streamPositionToNatural | MessageDb.Message |
StreamVersion | MessageDb.Functions |
streamVersion | MessageDb.Functions |
subscribe | MessageDb.Subscription |
Subscription | |
1 (Type/Class) | MessageDb.Subscription |
2 (Data Constructor) | MessageDb.Subscription |
subscriptionHandle | MessageDb.Handlers |
SubscriptionHandler | MessageDb.Handlers |
subscriptionHandler | MessageDb.Handlers |
SubscriptionHandlers | MessageDb.Handlers |
tickInterval | MessageDb.Subscription |
UnknownFailure | MessageDb.Subscription.FailureStrategy |
Unlimited | MessageDb.Functions, MessageDb.Projection |
unprocessed | MessageDb.Projection |
UnprocessedMessage | |
1 (Type/Class) | MessageDb.Projection |
2 (Data Constructor) | MessageDb.Projection |
version | MessageDb.Projection |
versionIncludingUnprocessed | MessageDb.Projection |
WithConnection | MessageDb.Functions |
writeAllToCategory | MessageDb.Subscription.FailureStrategy |
writeMessage | MessageDb.Functions |
writeToCategory | MessageDb.Subscription.FailureStrategy |
writeToStream | MessageDb.Subscription.PositionStrategy |
writeUnknownFailuresToCategory | MessageDb.Subscription.FailureStrategy |