Test

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

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