Index

A

AbstractEventHandler (class in eventbus.domain.eventbus) ActualOccasion (class in eventbus.domain.whitehead)

add() (eventbus.example.entity.Example method) ASTERISK (eventbus.domain.eventbus.AbstractEventHandler attribute) AttributeChangedEvent (class in eventbus.domain.events)

B

b64str_from_bytes() (in module eventbus.util.transcoding) BaseAggregateRoot (class in eventbus.domain.aggregate) BaseAggregateRoot.AttributeChanged (class in eventbus.domain.aggregate)

BaseAggregateRoot.Created (class in eventbus.domain.aggregate) BaseAggregateRoot.Discarded (class in eventbus.domain.aggregate) BaseAggregateRoot.Event (class in eventbus.domain.aggregate) bytes_from_b64str() (in module eventbus.util.transcoding)

C

clear_event_handlers() (in module eventbus.application.eventbus)

ConsistencyError CreatedEvent (class in eventbus.domain.events)

D

decode_bytes() (in module eventbus.util.transcoding) decode_date() (in module eventbus.util.transcoding) decode_datetime() (in module eventbus.util.transcoding) decode_decimal() (in module eventbus.util.transcoding) decode_deque() (in module eventbus.util.transcoding) decode_dict() (in module eventbus.util.transcoding) decode_enum() (in module eventbus.util.transcoding) decode_frozenset() (in module eventbus.util.transcoding) decode_object() (in module eventbus.util.transcoding) decode_set() (in module eventbus.util.transcoding) decode_time() (in module eventbus.util.transcoding) decode_tuple() (in module eventbus.util.transcoding)

decode_type() (in module eventbus.util.transcoding) decode_uuid() (in module eventbus.util.transcoding) decoder() (in module eventbus.util.transcoding) decoderpolicy() (in module eventbus.util.transcoding) DiscardedEvent (class in eventbus.domain.events) DomainEntity (class in eventbus.domain.entity) DomainEntity.AttributeChanged (class in eventbus.domain.entity) DomainEntity.Created (class in eventbus.domain.entity) DomainEntity.Discarded (class in eventbus.domain.entity) DomainEntity.Event (class in eventbus.domain.entity) DomainEvent (class in eventbus.domain.events) DomainEventError

E

encode() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_bytes() (in module eventbus.util.transcoding) encode_container() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_date() (in module eventbus.util.transcoding) encode_datetime() (in module eventbus.util.transcoding) encode_decimal() (in module eventbus.util.transcoding) encode_deque() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_dict() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_dict_state() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_enum() (in module eventbus.util.transcoding) encode_frozenset() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_function() (in module eventbus.util.transcoding) encode_instance() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_iterable() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_list() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_method() (in module eventbus.util.transcoding) encode_object() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_set() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_time() (in module eventbus.util.transcoding) encode_tuple() (eventbus.util.transcoding.ObjectJSONEncoder method) encode_type() (in module eventbus.util.transcoding) encode_uuid() (in module eventbus.util.transcoding) encoder() (in module eventbus.util.transcoding) encoderpolicy() (in module eventbus.util.transcoding) EncoderTypeError EnduringObject (class in eventbus.domain.whitehead) EntityIsDiscarded

Event (class in eventbus.domain.whitehead) event_type (eventbus.domain.eventbus.AbstractEventHandler attribute) eventbus (module) eventbus.application (module) eventbus.application.eventbus (module) eventbus.domain (module) eventbus.domain.aggregate (module) eventbus.domain.decorators (module) eventbus.domain.entity (module) eventbus.domain.eventbus (module) eventbus.domain.events (module) eventbus.domain.exceptions (module) eventbus.domain.whitehead (module) eventbus.example (module) eventbus.example.entity (module) eventbus.util (module) eventbus.util.hashing (module) eventbus.util.topic (module) eventbus.util.transcoding (module) EventWithOriginatorID (class in eventbus.domain.events) EventWithOriginatorVersion (class in eventbus.domain.events) EventWithTimestamp (class in eventbus.domain.events) Example (class in eventbus.example.entity) Example.Event (class in eventbus.example.entity) Example.ExampleInternalAdded (class in eventbus.example.entity) ExampleInternal (class in eventbus.example.entity) ExampleInternal.Event (class in eventbus.example.entity)

F

filter() (eventbus.domain.eventbus.AbstractEventHandler method)

G

get_entity() (in module eventbus.util.topic)

get_topic() (in module eventbus.util.topic)

H

handler() (eventbus.domain.eventbus.AbstractEventHandler method)

hash_object() (in module eventbus.util.hashing)

I

id (eventbus.domain.entity.DomainEntity attribute)

is_event_handlers_empty() (in module eventbus.application.eventbus)

M

MetaDomainEntity (class in eventbus.domain.entity) MismatchedOriginatorError

mutate() (eventbus.domain.events.DomainEvent method) (eventbus.example.entity.Example.ExampleInternalAdded method)

N

name (eventbus.domain.events.AttributeChangedEvent attribute)

O

ObjectJSONDecoder (class in eventbus.util.transcoding) ObjectJSONEncoder (class in eventbus.util.transcoding) originator_id (eventbus.domain.events.EventWithOriginatorID attribute)

originator_topic (eventbus.domain.entity.DomainEntity.Created attribute) originator_version (eventbus.domain.events.EventWithOriginatorVersion attribute) OriginatorIDError OriginatorVersionError

P

predicate() (eventbus.domain.eventbus.AbstractEventHandler method)

publish() (in module eventbus.application.eventbus)

R

resolve_attr() (in module eventbus.util.topic)

resolve_topic() (in module eventbus.util.topic)

S

subclassevents() (in module eventbus.domain.decorators)

subscribe() (in module eventbus.application.eventbus) summ (eventbus.example.entity.Example attribute)

T

timestamp (eventbus.domain.events.EventWithTimestamp attribute) TimestampedEntity (class in eventbus.domain.entity) TimestampedEntity.AttributeChanged (class in eventbus.domain.entity) TimestampedEntity.Created (class in eventbus.domain.entity) TimestampedEntity.Discarded (class in eventbus.domain.entity) TimestampedEntity.Event (class in eventbus.domain.entity)

TimestampedVersionedEntity (class in eventbus.domain.entity) TimestampedVersionedEntity.AttributeChanged (class in eventbus.domain.entity) TimestampedVersionedEntity.Created (class in eventbus.domain.entity) TimestampedVersionedEntity.Discarded (class in eventbus.domain.entity) TimestampedVersionedEntity.Event (class in eventbus.domain.entity) TopicResolutionError

U

unsubscribe() (in module eventbus.application.eventbus)

V

value (eventbus.domain.events.AttributeChangedEvent attribute) VersionedEntity (class in eventbus.domain.entity) VersionedEntity.AttributeChanged (class in eventbus.domain.entity)

VersionedEntity.Created (class in eventbus.domain.entity) VersionedEntity.Discarded (class in eventbus.domain.entity) VersionedEntity.Event (class in eventbus.domain.entity)