Index

A

AnonymousUserServerProtocol (class in tg_pubsub.protocol), [1] AnyUserServerProtocol (class in tg_pubsub.protocol), [1] args (tg_pubsub.management.commands.pubsub_server.Command attribute)

as_message() (tg_pubsub.messages.BaseMessage method) AuthenticatedUserServerProtocol (class in tg_pubsub.protocol), [1]

B

BaseMessage (class in tg_pubsub.messages)

C

client_handler() (in module tg_pubsub.worker) Command (class in tg_pubsub.management.commands.pubsub_server)

create_redis_connection() (in module tg_pubsub.pubsub)

F

FakeRequest (class in tg_pubsub.protocol)

G

get_extra_models() (in module tg_pubsub.config) get_handler_kwargs() (tg_pubsub.protocol.AnyUserServerProtocol method) (tg_pubsub.protocol.RequestServerProtocol method) (tg_pubsub.protocol.SessionRequiredServerProtocol method) get_hello_packets() (in module tg_pubsub.config) get_protocol_handler() (in module tg_pubsub.config) get_protocol_handler_klass() (in module tg_pubsub.config)

get_pubsub_server_host() (in module tg_pubsub.config) get_pubsub_server_ping_delta() (in module tg_pubsub.config) get_pubsub_server_port() (in module tg_pubsub.config) get_serializer() (tg_pubsub.models.ListenableBase method) get_serializer_class() (tg_pubsub.models.ListenableBase method)

H

handle() (tg_pubsub.management.commands.pubsub_server.Command method) HandlerProtocol (class in tg_pubsub.worker) has_access() (tg_pubsub.models.ListenableBase class method)

has_permissions() (tg_pubsub.protocol.AnonymousUserServerProtocol method) (tg_pubsub.protocol.AnyUserServerProtocol method) (tg_pubsub.protocol.AuthenticatedUserServerProtocol method) (tg_pubsub.protocol.StaffUserServerProtocol method) (tg_pubsub.protocol.SuperUserServerProtocol method) help (tg_pubsub.management.commands.pubsub_server.Command attribute)

I

IgnoreMessageException InvalidMessageException

is_model_listenable() (in module tg_pubsub.models)

L

ListenableBase (class in tg_pubsub.models) ListenableModelMixin (class in tg_pubsub.models)

logging_key (tg_pubsub.worker.HandlerProtocol attribute)

M

MESSAGE_IDENTIFIER (tg_pubsub.messages.BaseMessage attribute) (tg_pubsub.messages.ModelChanged attribute) message_valid() (tg_pubsub.worker.WebSocketHandler class method) model_changed() (in module tg_pubsub.models) model_path (tg_pubsub.models.ModelListenConfig attribute)

model_post_save_handler() (in module tg_pubsub.models) model_pre_delete_handler() (in module tg_pubsub.models) ModelChanged (class in tg_pubsub.messages) ModelListenConfig (class in tg_pubsub.models)

O

open (tg_pubsub.worker.HandlerProtocol attribute)

P

ping() (tg_pubsub.worker.HandlerProtocol method) (tg_pubsub.worker.WebSocketHandler method) prepare_for_send() (tg_pubsub.messages.BaseMessage class method) (tg_pubsub.messages.ModelChanged class method) publish() (in module tg_pubsub.pubsub) (tg_pubsub.messages.BaseMessage method)

pubsub_get_model() (tg_pubsub.models.ListenableBase method) (tg_pubsub.models.ModelListenConfig method) pubsub_serialize() (tg_pubsub.models.ListenableBase class method)

R

RequestServerProtocol (class in tg_pubsub.protocol), [1] run() (tg_pubsub.worker.WebSocketHandler method)

run_pubsub_server() (in module tg_pubsub.worker)

S

send() (tg_pubsub.worker.HandlerProtocol method) send_hello() (tg_pubsub.worker.WebSocketHandler method) send_on_change() (tg_pubsub.worker.WebSocketHandler method) serializer_class (tg_pubsub.models.ListenableBase attribute) serializer_fields (tg_pubsub.models.ListenableBase attribute)

session (tg_pubsub.protocol.FakeRequest attribute) SessionRequiredServerProtocol (class in tg_pubsub.protocol), [1] should_notify() (tg_pubsub.models.ListenableBase class method) StaffUserServerProtocol (class in tg_pubsub.protocol), [1] SuperUserServerProtocol (class in tg_pubsub.protocol), [1]

T

tg_pubsub (module) tg_pubsub.config (module) tg_pubsub.exceptions (module) tg_pubsub.management (module) tg_pubsub.management.commands (module) tg_pubsub.management.commands.pubsub_server (module)

tg_pubsub.messages (module) tg_pubsub.models (module) tg_pubsub.protocol (module) tg_pubsub.pubsub (module) tg_pubsub.worker (module) TOKEN_PARAM (tg_pubsub.protocol.RequestServerProtocol attribute)

U

user (tg_pubsub.worker.HandlerProtocol attribute)

W

WebSocketHandler (class in tg_pubsub.worker)