Index

C

callbacks (zmq_plugin.plugin.PluginBase attribute) close() (zmq_plugin.plugin.PluginBase method)

command_socket (zmq_plugin.hub.Hub attribute) (zmq_plugin.plugin.PluginBase attribute) command_uri (zmq_plugin.hub.Hub attribute)

D

decode_content_data() (in module zmq_plugin.schema)

default() (zmq_plugin.schema.PandasJsonEncoder method)

E

encode_content_data() (in module zmq_plugin.schema) execute() (zmq_plugin.plugin.PluginBase method)

execute_async() (zmq_plugin.plugin.PluginBase method) execute_reply_id (zmq_plugin.plugin.PluginBase attribute)

G

get_connect_reply() (in module zmq_plugin.schema) get_connect_request() (in module zmq_plugin.schema) get_execute_reply() (in module zmq_plugin.schema)

get_execute_request() (in module zmq_plugin.schema) get_header() (in module zmq_plugin.schema) get_schema() (in module zmq_plugin.schema)

H

host (zmq_plugin.hub.Hub attribute) (zmq_plugin.plugin.PluginBase attribute)

Hub (class in zmq_plugin.hub) hub_name (zmq_plugin.plugin.PluginBase attribute)

L

logger (zmq_plugin.hub.Hub attribute) (zmq_plugin.plugin.PluginBase attribute)

M

MESSAGE_SCHEMA (in module zmq_plugin.schema)

mime_type() (in module zmq_plugin.schema)

N

name (zmq_plugin.hub.Hub attribute)

O

on_command_recv() (zmq_plugin.hub.Hub method) (zmq_plugin.plugin.PluginBase method) on_execute__ping() (zmq_plugin.hub.Hub method) (zmq_plugin.plugin.Plugin method)

on_execute__register() (zmq_plugin.hub.Hub method) on_query_recv() (zmq_plugin.hub.Hub method) on_subscribe_recv() (zmq_plugin.plugin.PluginBase method)

P

pandas_object_hook() (in module zmq_plugin.schema) PandasJsonEncoder (class in zmq_plugin.schema) Plugin (class in zmq_plugin.plugin)

PluginBase (class in zmq_plugin.plugin) publish_socket (zmq_plugin.hub.Hub attribute) publish_uri (zmq_plugin.hub.Hub attribute)

Q

query() (zmq_plugin.plugin.PluginBase method) query_send() (zmq_plugin.hub.Hub method) query_socket (zmq_plugin.hub.Hub attribute) (zmq_plugin.plugin.PluginBase attribute)

query_uri (zmq_plugin.hub.Hub attribute) (zmq_plugin.plugin.PluginBase attribute)

R

register() (zmq_plugin.plugin.PluginBase method) registry (zmq_plugin.hub.Hub attribute) reset() (zmq_plugin.hub.Hub method) (zmq_plugin.plugin.PluginBase method) reset_command_socket() (zmq_plugin.hub.Hub method) (zmq_plugin.plugin.PluginBase method)

reset_publish_socket() (zmq_plugin.hub.Hub method) reset_query_socket() (zmq_plugin.hub.Hub method) (zmq_plugin.plugin.PluginBase method) reset_subscribe_socket() (zmq_plugin.plugin.PluginBase method)

S

send_command() (zmq_plugin.plugin.PluginBase method)

subscribe_options (zmq_plugin.plugin.PluginBase attribute) subscribe_socket (zmq_plugin.plugin.PluginBase attribute)

T

transport (zmq_plugin.hub.Hub attribute) (zmq_plugin.plugin.PluginBase attribute)

V

validate() (in module zmq_plugin.schema)

verify_tornado() (in module zmq_plugin.bin)

Z

zmq_plugin.bin (module) zmq_plugin.hub (module)

zmq_plugin.plugin (module) zmq_plugin.schema (module)