checkOperationResult
|
- |
handles OperationResult.AccessDenied
|
- |
handles OperationResult.CommitTimeout
|
- |
handles OperationResult.ForwardTimeout
|
- |
handles OperationResult.InvalidTransaction
|
- |
handles OperationResult.PrepareTimeout
|
- |
handles OperationResult.StreamDeleted
|
- |
handles OperationResult.WrongExpectedVersion
|
- |
handles OperationResult.Unspecific
|
- |
checkTimeout
|
- |
throws timed out promises
|
- |
logs errors on timeout
|
- |
disconnect
|
- |
throws on empty port or host
|
- |
Gossip connection info
|
- |
returns empty array on dns error
|
- |
returns null on error
|
- |
returns same settings
|
- |
handleReadAllEventsCompleted
|
- |
handles ReadEventResult.AccessDenied
|
- |
handles ReadEventResult.NotModified
|
- |
handles ReadEventResult.UnspecificError
|
- |
handleReadEventCompleted
|
- |
handles ReadEventResult.NotFound
|
- |
handles ReadEventResult.NoStream
|
- |
handles ReadEventResult.StreamDeleted
|
- |
handleReadStreamEventsCompleted
|
- |
handles ReadStreamResult.NoStream
|
- |
handles ReadStreamResult.NotModified
|
- |
handles ReadStreamResult.StreamDeleted
|
- |
handles ReadStreamResult.AccessDenied
|
- |
TCPConnection
|
- |
handleMultiPacketResponseData
|
- |
returns null when param is null
|
- |
handleNewResponseData
|
- |
throws on invalid command length
|
- |
handleSingleResponseData
|
- |
throws on invalid command length
|
- |
Test position class
|
- |
creates a new instance from numbers
|
- |
creates a new instance from Long
|
- |
sendCommand
|
- |
throws on maximum
|
- |
throws on socket error
|
- |
tryToConnect
|
- |
throws on empty port or host
|
- |
Event class base tests
|
- |
creates a event instance
|
- |
creates a event instance with eventData
|
- |
creates a event instance with eventData and metadata
|
- |
Existing event instance tests
|
- |
returns false on existing event
|
- |
throws on changing name
|
- |
throws on changing eventId
|
- |
throws on changing eventData
|
- |
throws on changing eventMetadata
|
- |
throws on changing eventCorrelationId
|
- |
event from raw
|
- |
returns event instance with full metadata
|
- |
returns event instance without metadata
|
- |
returns event instance without created information
|
- |
sets metadata on setting correlationId
|
- |
deletes correlationId also from metadata
|
- |
deletes correlationId
|
- |
returns null for correlationId if not set
|
- |
throw on missing raw event or link
|
- |
New event instance tests
|
- |
returns true on new event
|
- |
can change name
|
- |
can change eventId
|
- |
can change eventData
|
- |
converts json string to eventData
|
- |
can change eventMetadata
|
- |
converts json string to eventMetadata
|
- |
can change eventCorrelationId
|
- |
returns model.eventstore.proto.NewEvent instance
|
- |
returns Event instance with correlationId set to parents correlationId
|
- |
returns Event instance with correlationId set to parents id if correlation id not set
|
- |
Eventstore error class
|
- |
creates an error instance
|
- |
can have a causing error instance
|
- |
Eventstore error types
|
- |
test/1_unitTests/5_errors/eventstoreError.test.ts |
- |
test/1_unitTests/5_errors/eventstoreError.test.ts |
- |
test/1_unitTests/5_errors/eventstoreError.test.ts |
- |
Async iterator test
|
- |
can iterate through
|
- |
can filter events
|
- |
can reduce events to single value
|
- |
can transform to array
|
- |
can test all entries and return global result true
|
- |
can test all entries and return global result true
|
- |
can combine filter and forEach
|
- |
can combine filter, map and to array
|
- |
throws on none function at filter
|
- |
throws on none function at map
|
- |
throws on none function at forEach
|
- |
throws on none function at reduce
|
- |
throws on none function at every
|
- |
uuid to buffer
|
- |
converts a uuid to formated buffer
|
- |
returns a buffer for id=null
|
- |
throws on uuid size
|
- |
throws on invalid uuid format
|
- |
buffer to uuid
|
- |
converts buffer to uuid
|
- |
converts buffer to uuid
|
- |
throws on invalid buffer size
|
- |
Connection test
|
- |
creates an instance without config
|
- |
creates an instance with eventstore settings object
|
- |
returns false if not connected
|
- |
does nothing if not connected
|
- |
set a logger
|
- |
can connect to eventstore single node unsecure
|
- |
can connect to eventstore single node to default port
|
- |
can connect to eventstore cluster unsecure
|
- |
can connect to eventstore cluster secure tcp
|
- |
can ssl connect to eventstore with cert & strict validation
|
- |
throws on invalid secure context
|
- |
finds cluster node over dns (require master)
|
- |
finds cluster node over dns
|
- |
finds cluster node from seed list
|
- |
it throws on invalid credentials
|
- |
Basic connection test
|
- |
returns clientId - name of connection
|
- |
can ping eventstore
|
- |
Read all events
|
- |
reads a slice from all events forward
|
- |
reads a slice from all events backward
|
- |
throws on access denied (forward)
|
- |
throws on access denied (backward)
|
- |
Read all events
|
- |
reads all events forward
|
- |
reads all events backward
|
- |
matches end/start entries
|
- |
reads all links forward
|
- |
reads all links backward
|
- |
get stream names by category
|
- |
returns all stream names for category
|
- |
walkEventsByCorrelationId
|
- |
returns all resolved events for given uuid
|
- |
returns all linked events for given uuid
|
- |
walkEventsByStreamCategory
|
- |
returns all resolved events for category
|
- |
returns all linked events for category
|
- |
walkEventsByType
|
- |
returns all resolved events of type LookUpEvent1
|
- |
returns all resolved events of type LookUpEvent2
|
- |
returns all linked events of type LookUpEvent1
|
- |
returns all linked events of type LookUpEvent2
|
- |
Stream tests
|
- |
Basic tests
|
- |
returns a stream name
|
- |
returns a stream instance for function stream
|
- |
returns a stream instance for function fromStream
|
- |
returns a stream instance for function atStream
|
- |
returns same stream on requiresMaster
|
- |
returns same stream on withCredentials
|
- |
returns same stream on resolveAllLinks
|
- |
can soft delete a stream
|
- |
can soft delete a stream on master node
|
- |
can hard delete a stream
|
- |
throws on delete metastream
|
- |
Stream tests
|
- |
Get stream metadata
|
- |
returns null for existing stream with no metadata
|
- |
reads metadata for stream on master node
|
- |
returns null for not existing stream
|
- |
throws on metadata stream
|
- |
throws on invalid access rights
|
- |
Set stream metadata
|
- |
writes stream metadata
|
- |
writes stream metadata (require master)
|
- |
throws on metadata stream
|
- |
Read stream basic tests
|
- |
Read one event
|
- |
returns a event by given eventNumber
|
- |
returns a event by given eventNumber from master
|
- |
returns a event by given eventNumber from master (as parameter)
|
- |
returns first event of stream
|
- |
returns last event of stream
|
- |
Walk stream tests
|
- |
can walk to stream forward
|
- |
can walk to stream forward with master required
|
- |
can walk to stream backward
|
- |
Event emit tests
|
- |
appends single new event
|
- |
appends single new event with require master
|
- |
appends single new event with require master
|
- |
appends single new event without require master
|
- |
appends multiple new event
|
- |
throws when emitting events already stored in eventstore
|
- |
throws on wrong expected version
|
- |
Read events from stream
|
- |
reads a slice forward
|
- |
reads a slice backward
|
- |
Linked event
|
- |
resolves linked event
|
- |
returns same event if not link
|
- |
throws NotFoundError
|
- |
throws ProtocolError
|
- |
Transaction tests
|
- |
creates a new transaction
|
- |
appends events to transaction
|
- |
appends events to transaction requiered master
|
- |
it throws on re-commiting
|
- |
it throws on writing to already committed transactions
|
- |
it throws on writing of already stored events
|
- |
it throws on commiting roled back transactions
|
- |
it throws on writing to roled back transactions
|
- |
it throws on invalid transaction
|
- |
it throws on metastreams
|
- |
Persistent subscription test
|
- |
with admin user rights
|
- |
creates a persistent subscription
|
- |
updates a persistent subscription with object
|
- |
updates a persistent subscription with given subscription config and credentials
|
- |
throws on creating persistent subscription with same names again
|
- |
deletes a persistent subscription
|
- |
throws on delete
|
- |
without admin user rights
|
- |
throws on create
|
- |
throws on update
|
- |
throws on delete
|
- |
Persistent subscription get events
|
- |
can start a subscription on none empty stream
|
- |
can notAck single event
|
- |
notAck single event with unknown by default
|
- |
notAck events with unknown by default
|
- |
Stream subscription tests
|
- |
subscribes and unsubscribes to a stream
|
- |
returns subscription name
|
- |
returns true for resolve links
|
- |
returns false for not resolve links
|
- |
logs on error
|
- |
receives events
|
- |