Index

_

_cqrs_sync_queryset() (dj_cqrs.admin.CQRSAdminMasterSyncMixin method)

B

BaseTransport (class in dj_cqrs.transport)

bulk_create() (dj_cqrs.managers.MasterManager method) bulk_update() (dj_cqrs.managers.MasterManager method)

C

call_post_bulk_create() (dj_cqrs.mixins.RawMasterMixin class method) call_post_update() (dj_cqrs.mixins.RawMasterMixin class method) clean_connection() (dj_cqrs.transport.BaseTransport static method) (dj_cqrs.transport.KombuTransport class method) (dj_cqrs.transport.RabbitMQTransport class method) consume() (dj_cqrs.transport.BaseTransport static method) (dj_cqrs.transport.KombuTransport class method) (dj_cqrs.transport.RabbitMQTransport class method) cqrs (dj_cqrs.mixins.RawMasterMixin attribute) (dj_cqrs.mixins.ReplicaMixin attribute) cqrs_create() (dj_cqrs.mixins.ReplicaMixin class method) CQRS_CUSTOM_SERIALIZATION (dj_cqrs.mixins.ReplicaMixin attribute) cqrs_delete() (dj_cqrs.mixins.ReplicaMixin class method) CQRS_FIELDS (dj_cqrs.mixins.RawMasterMixin attribute)

CQRS_ID (dj_cqrs.mixins.RawMasterMixin attribute) (dj_cqrs.mixins.ReplicaMixin attribute) CQRS_MAPPING (dj_cqrs.mixins.ReplicaMixin attribute) CQRS_META (dj_cqrs.mixins.ReplicaMixin attribute) CQRS_NO_DB_OPERATIONS (dj_cqrs.mixins.ReplicaMixin attribute) CQRS_PRODUCE (dj_cqrs.mixins.RawMasterMixin attribute) cqrs_save() (dj_cqrs.mixins.ReplicaMixin class method) cqrs_saves_count() (dj_cqrs.mixins.RawMasterMixin property) CQRS_SELECT_FOR_UPDATE (dj_cqrs.mixins.ReplicaMixin attribute) CQRS_SERIALIZER (dj_cqrs.mixins.RawMasterMixin attribute) cqrs_sync() (dj_cqrs.mixins.RawMasterMixin method) CQRS_TRACKED_FIELDS (dj_cqrs.mixins.RawMasterMixin attribute) cqrs_update() (dj_cqrs.mixins.ReplicaMixin method) CQRSAdminMasterSyncMixin (class in dj_cqrs.admin) create_instance() (dj_cqrs.managers.ReplicaManager method)

D

DELETE (dj_cqrs.constants.SignalType attribute) delete_instance() (dj_cqrs.managers.ReplicaManager method)

dj_cqrs.signals module

F

from_message() (dj_cqrs.dataclasses.TransportPayload class method)

G

get_cqrs_meta() (dj_cqrs.mixins.RawMasterMixin method) get_custom_cqrs_delete_data() (dj_cqrs.mixins.RawMasterMixin method)

get_model_by_cqrs_id() (dj_cqrs.registries.MasterRegistry class method) (dj_cqrs.registries.ReplicaRegistry class method) get_tracked_fields_data() (dj_cqrs.mixins.RawMasterMixin method)

I

is_expired() (dj_cqrs.dataclasses.TransportPayload method)

is_initial_cqrs_save() (dj_cqrs.mixins.RawMasterMixin property) is_sync_instance() (dj_cqrs.mixins.RawMasterMixin method)

K

KombuTransport (class in dj_cqrs.transport)

M

MasterManager (class in dj_cqrs.managers) MasterMixin (class in dj_cqrs.mixins) MasterRegistry (class in dj_cqrs.registries)

MasterSignals (class in dj_cqrs.signals) module dj_cqrs.signals

P

post_bulk_create (in module dj_cqrs.signals) post_bulk_create() (dj_cqrs.signals.MasterSignals class method) post_bulk_update() (dj_cqrs.signals.MasterSignals class method) post_delete() (dj_cqrs.signals.MasterSignals class method)

post_save() (dj_cqrs.signals.MasterSignals class method) post_update (in module dj_cqrs.signals) produce() (dj_cqrs.transport.BaseTransport static method) (dj_cqrs.transport.KombuTransport class method) (dj_cqrs.transport.RabbitMQTransport class method)

R

RabbitMQTransport (class in dj_cqrs.transport) RawMasterMixin (class in dj_cqrs.mixins) register_model() (dj_cqrs.registries.MasterRegistry class method) (dj_cqrs.registries.ReplicaRegistry class method) (dj_cqrs.signals.MasterSignals class method)

relate_cqrs_serialization() (dj_cqrs.mixins.RawMasterMixin class method) ReplicaManager (class in dj_cqrs.managers) ReplicaMixin (class in dj_cqrs.mixins) ReplicaRegistry (class in dj_cqrs.registries) reset_cqrs_saves_count() (dj_cqrs.mixins.RawMasterMixin method)

S

SAVE (dj_cqrs.constants.SignalType attribute) save_instance() (dj_cqrs.managers.ReplicaManager method)

SignalType (class in dj_cqrs.constants) SYNC (dj_cqrs.constants.SignalType attribute) sync_items() (dj_cqrs.admin.CQRSAdminMasterSyncMixin method)

T

to_cqrs_dict() (dj_cqrs.mixins.RawMasterMixin method)

to_dict() (dj_cqrs.dataclasses.TransportPayload method) TransportPayload (class in dj_cqrs.dataclasses)

U

update_instance() (dj_cqrs.managers.ReplicaManager method)