Index

_

__init__() (django_broadcaster.backends.RedisStreamBackend method) (django_broadcaster.events.CloudEvent method) (django_broadcaster.models.OutboxEvent method) (django_broadcaster.publishers.OutboxPublisher method) (django_broadcaster.registry.EventHandlerRegistry method)

__str__() (django_broadcaster.models.OutboxEvent method) _get_default_backend() (django_broadcaster.publishers.OutboxPublisher method) _load_backends() (django_broadcaster.publishers.OutboxPublisher method) _process_single_event() (django_broadcaster.publishers.OutboxPublisher method)

C

clear_handlers() (django_broadcaster.registry.EventHandlerRegistry method), [1]

CloudEvent (class in django_broadcaster.events) created_at (django_broadcaster.models.OutboxEvent attribute)

D

data (django_broadcaster.models.OutboxEvent attribute) data_content_type (django_broadcaster.models.OutboxEvent attribute) data_schema (django_broadcaster.models.OutboxEvent attribute) django_broadcaster.backends module django_broadcaster.events module

django_broadcaster.models module django_broadcaster.publishers module django_broadcaster.registry module django_broadcaster.signals module

E

event_created (in module django_broadcaster.registry) event_published (in module django_broadcaster.registry)

event_registry (in module django_broadcaster.registry) event_type (django_broadcaster.models.OutboxEvent attribute) EventHandlerRegistry (class in django_broadcaster.registry)

F

FAILED (django_broadcaster.models.OutboxEventStatus attribute)

G

get_backend_health() (django_broadcaster.publishers.OutboxPublisher method), [1] get_handlers() (django_broadcaster.registry.EventHandlerRegistry method), [1] get_name() (django_broadcaster.backends.PublisherBackend method), [1] (django_broadcaster.backends.RedisStreamBackend method), [1] get_next_by_created_at() (django_broadcaster.models.OutboxEvent method)

get_next_by_scheduled_at() (django_broadcaster.models.OutboxEvent method) get_next_by_updated_at() (django_broadcaster.models.OutboxEvent method) get_previous_by_created_at() (django_broadcaster.models.OutboxEvent method) get_previous_by_scheduled_at() (django_broadcaster.models.OutboxEvent method) get_previous_by_updated_at() (django_broadcaster.models.OutboxEvent method) get_status_display() (django_broadcaster.models.OutboxEvent method)

H

handle_event() (django_broadcaster.registry.EventHandlerRegistry method), [1] handle_outbox_event_signals() (in module django_broadcaster.signals)

health_check() (django_broadcaster.backends.PublisherBackend method), [1] (django_broadcaster.backends.RedisStreamBackend method), [1]

I

id (django_broadcaster.models.OutboxEvent attribute)

increment_retry() (django_broadcaster.models.OutboxEvent method), [1]

L

last_error (django_broadcaster.models.OutboxEvent attribute)

M

mark_as_failed() (django_broadcaster.models.OutboxEvent method), [1] mark_as_published() (django_broadcaster.models.OutboxEvent method), [1] max_retries (django_broadcaster.models.OutboxEvent attribute) module django_broadcaster.backends django_broadcaster.events django_broadcaster.models django_broadcaster.publishers django_broadcaster.registry django_broadcaster.signals

O

objects (django_broadcaster.models.OutboxEvent attribute) OutboxEvent (class in django_broadcaster.models) OutboxEvent.DoesNotExist

OutboxEvent.MultipleObjectsReturned OutboxEventStatus (class in django_broadcaster.models) OutboxPublisher (class in django_broadcaster.publishers)

P

PENDING (django_broadcaster.models.OutboxEventStatus attribute) process_pending_events() (django_broadcaster.publishers.OutboxPublisher method), [1] PROCESSING (django_broadcaster.models.OutboxEventStatus attribute) publish() (django_broadcaster.backends.PublisherBackend method), [1] (django_broadcaster.backends.RedisStreamBackend method), [1] publish_cloud_event() (django_broadcaster.publishers.OutboxPublisher method), [1]

publish_event() (django_broadcaster.publishers.OutboxPublisher method), [1] PUBLISHED (django_broadcaster.models.OutboxEventStatus attribute) published_at (django_broadcaster.models.OutboxEvent attribute) publisher (in module django_broadcaster.publishers) publisher_backend (django_broadcaster.models.OutboxEvent attribute) publisher_config (django_broadcaster.models.OutboxEvent attribute) PublisherBackend (class in django_broadcaster.backends)

R

RedisStreamBackend (class in django_broadcaster.backends) register() (django_broadcaster.registry.EventHandlerRegistry method), [1]

RETRY (django_broadcaster.models.OutboxEventStatus attribute) retry_count (django_broadcaster.models.OutboxEvent attribute)

S

scheduled_at (django_broadcaster.models.OutboxEvent attribute) source (django_broadcaster.models.OutboxEvent attribute)

spec_version (django_broadcaster.models.OutboxEvent attribute) status (django_broadcaster.models.OutboxEvent attribute) subject (django_broadcaster.models.OutboxEvent attribute)

T

to_cloud_event() (django_broadcaster.models.OutboxEvent method), [1]

to_dict() (django_broadcaster.events.CloudEvent method), [1]

U

updated_at (django_broadcaster.models.OutboxEvent attribute)