References
| summary | ||
| public |
Stream walker |
|
errors
| summary | ||
| public |
Eventstore error base class |
|
| public |
F newAccessDeniedError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreAccessDeniedError |
|
| public |
F newAlreadyExistError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreAlreadyExistError |
|
| public |
F newBadRequestError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreBadRequestError |
|
| public |
F newCommitTimeoutError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreCommitTimeoutError |
|
| public |
F newConnectionError(message: , rootCause: Error | null) |
|
| public |
F newDoesNotExistError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreDoesNotExistError |
|
| public |
F newForwardTimeoutError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreForwardTimeoutError |
|
| public |
F newImplementationError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreImplementationError |
|
| public |
F newInvalidTransactionError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreInvalidTransactionError |
|
| public |
F newNoStreamError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreNoStreamError |
|
| public |
F newNotAuthenticatedError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreNotAuthenticatedError |
|
| public |
F newNotFoundError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreNotFoundError |
|
| public |
F newNotHandledError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreNotHandledError |
|
| public |
F newNotModifiedError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreNotModifiedError |
|
| public |
F newOperationError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreOperationError |
|
| public |
F newPrepareTimeoutError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstorePrepareTimeoutError |
|
| public |
F newProtocolError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreProtocolError |
|
| public |
F newStreamDeletedError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreStreamDeletedError |
|
| public |
F newTimeoutError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreTimeoutError |
|
| public |
F newUnspecificError(message: string, rootCause: Error | null) Returns new EventstoreError type of EventstoreUnspecificError |
|
| public |
F newWrongExpectedVersionError(message: , rootCause: Error | null) Returns new EventstoreError type of EventstoreWrongExpectedVersionError |
|
event
| summary | ||
| public |
C Event Represents a single event |
|
eventstore
| summary | ||
| public |
Base class to communicate with eventstore @emits{connected} emitted as soon as connection is established @emits{secureConnect} emitted when connection is secured connected @emits{ready} emitted after connected after authentication and identify client @emits{reconnect} emitted as soon as lib tries to reconnect (param: reconnect count) @emits{close} emitted as soon as connection is closed @emits{drain} emitted when connection drains existing requests before connection close @emits{error} emitted on connection errors (param: error) |
|
| public |
C Position Represents a position in eventstore global log file |
|
| public |
Raw tcp communication to eventstore This class handles basic communication with eventstore |
|
| public |
F setConnectionSettings(customSettings: object | EventstoreSettings) Generates settings for connecting to eventstore |
|
| public |
F async fetchgossipJson(host: , port: , useHttps: , timeout: , log: bunyan) tries to fetch gossip json information from given ip and port |
|
| public |
F async getIpAndPort(currentSettings: EventstoreSettings, log: bunyan) Updates connection information depending on given settings |
|
| public |
F async getIpListFromDns(dnsServer: , log: bunyan) |
|
| public |
F getMasterNodeInfo(gossipInfo: ) Searches for master node inside of gossip json |
|
| public |
F getRandomNodeInfo(gossipInfo: ) Gets a random cluster node from gossip json |
|
| public |
|
|
| public |
|
|
| public |
|
|
| public |
E Long |
|
| public |
E bunyan |
|
protobuf
| summary | ||
| public |
F uuidFromBuffer(buffer: Buffer) Converts a uuid as string from buffer It returns an empty string for uuid set to null or throws EventstoreProtocolError for invalid buffer length |
|
| public |
F uuidToBuffer(uuid: string | null) Converts a uuid string to buffer representation throws EventstoreProtocolError for invalid input string length |
|
| public |
V $root: * |
|
| public |
|
|
stream
| summary | ||
| public |
C Stream Base class for handling a stream |
|
| public |
Base class for handling transaction writes to stream |
|
| public |
|
|
subscription
| summary | ||
| public |
Represents a persistent subscription |
|
| public |
|
|
| public |
F setPersistentSubscriptionConfig(customSettings: object | PersistentSubscriptionConfig) merges given settings with default settings |
|
| public |
V SystemConsumerStrategies: {"DispatchToSingle": string, "RoundRobin": string, "Pinned": string} constant definition of consumer strategies |
|