`eventstoredb.events`#

Module Contents#

Classes#

`ContentType`	str(object='') -> str
`EventData`
`JsonEvent`
`BinaryEvent`
`RecordedEvent`
`JsonRecordedEvent`
`BinaryRecordedEvent`
`ReadEvent`
`CaughtUp`
`FellBehind`
`PersistentSubscriptionEvent`

class eventstoredb.events.ContentType[source]#

Bases: str, enum.Enum

str(object=’’) -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Create a new string object from the given object. If encoding or errors is specified, then the object must expose a data buffer that will be decoded using the given encoding and error handler. Otherwise, returns the result of object.__str__() (if defined) or repr(object). encoding defaults to sys.getdefaultencoding(). errors defaults to ‘strict’.

BINARY = 'application/octet-stream'#

JSON = 'application/json'#

class eventstoredb.events.EventData[source]#

type: str#

content_type: ContentType#

id: uuid.UUID#

data: bytes | None#

metadata: bytes | None#

class eventstoredb.events.JsonEvent[source]#

Bases: EventData

content_type: Literal[ContentType]#

class eventstoredb.events.BinaryEvent[source]#

Bases: EventData

content_type: Literal[ContentType]#

class eventstoredb.events.RecordedEvent[source]#

stream_name: str#

id: uuid.UUID#

type: str#

content_type: ContentType#

revision: eventstoredb.types.StreamRevision#

created: int#

position: eventstoredb.types.AllPosition#

data: bytes | None#

metadata: bytes | None#

class eventstoredb.events.JsonRecordedEvent[source]#: Bases: RecordedEvent

class eventstoredb.events.BinaryRecordedEvent[source]#: Bases: RecordedEvent

class eventstoredb.events.ReadEvent[source]#

event: RecordedEvent | None#

link: RecordedEvent | None#

commit_position: eventstoredb.types.Position | None#

class eventstoredb.events.CaughtUp[source]#

class eventstoredb.events.FellBehind[source]#

class eventstoredb.events.PersistentSubscriptionEvent[source]#

Bases: ReadEvent

retry_count: int | None#