Index

A

admin_site() (in module kafkastreamer)

B

batch_class (kafkastreamer.Streamer attribute)

batch_size (kafkastreamer.Streamer attribute)

C

context (kafkastreamer.types.MessageMeta attribute)

D

data (kafkastreamer.types.Message attribute)

E

ENUMERATE (kafkastreamer.RefreshFinalizeType attribute) enumerate_chunk_field (kafkastreamer.Streamer attribute) enumerate_chunk_size (kafkastreamer.Streamer attribute)

enumerate_ids_field (kafkastreamer.Streamer attribute) EOS (kafkastreamer.RefreshFinalizeType attribute) exclude (kafkastreamer.Streamer attribute) extra (kafkastreamer.types.MessageContext attribute)

F

full_refresh() (in module kafkastreamer)

G

get_registry() (in module kafkastreamer)

get_streamer() (in module kafkastreamer) get_streamer_for_related() (in module kafkastreamer)

H

handle_related (kafkastreamer.Streamer attribute)

I

id_field (kafkastreamer.Streamer attribute)

include (kafkastreamer.Streamer attribute) is_model_handler_stopped() (in module kafkastreamer)

K

kafkastreamer.TYPE_CREATE (built-in variable) kafkastreamer.TYPE_DELETE (built-in variable) kafkastreamer.TYPE_ENUMERATE (built-in variable)

kafkastreamer.TYPE_EOS (built-in variable) kafkastreamer.TYPE_REFRESH (built-in variable) kafkastreamer.TYPE_UPDATE (built-in variable)

M

Message (class in kafkastreamer.types) message_serializer (kafkastreamer.Streamer attribute) MessageContext (class in kafkastreamer.types)

MessageMeta (class in kafkastreamer.types) MessageSerializer (in module kafkastreamer.types) meta (kafkastreamer.types.Message attribute) msg_type (kafkastreamer.types.MessageMeta attribute)

O

obj_id (kafkastreamer.types.Message attribute)

ObjectID (in module kafkastreamer.types)

P

partition_key_serializer (kafkastreamer.Streamer attribute) Partitioner (in module kafkastreamer.types)

partitioner (kafkastreamer.Streamer attribute) PartitionKeySerializer (in module kafkastreamer.types) prefetch_related (kafkastreamer.Streamer attribute)

R

refresh() (in module kafkastreamer.tasks) refresh_finalize_type (kafkastreamer.Streamer attribute)

refresh_model() (in module kafkastreamer.tasks) RefreshFinalizeType (class in kafkastreamer) register() (in module kafkastreamer)

S

select_related (kafkastreamer.Streamer attribute) send() (in module kafkastreamer) send_create() (in module kafkastreamer) send_delete() (in module kafkastreamer) send_refresh() (in module kafkastreamer) send_update() (in module kafkastreamer)

set_context() (in module kafkastreamer) source (kafkastreamer.types.MessageContext attribute) squash() (in module kafkastreamer) static_fields (kafkastreamer.Streamer attribute) stop_handlers() (in module kafkastreamer) Streamer (class in kafkastreamer)

T

timestamp (kafkastreamer.types.MessageMeta attribute)

topic (kafkastreamer.Streamer attribute)

U

user_id (kafkastreamer.types.MessageContext attribute)