Index

A

add_cronjob() (task.crontab method) add_data() (socket_protocol.pure_json_protocol method) add_msg_to_auth_whitelist_() (socket_protocol.pure_json_protocol method) add_service() (socket_protocol.pure_json_protocol method) add_source_get_keys() (caching.property_cache_pickle method) add_status() (socket_protocol.pure_json_protocol method) ANY (task.crontab attribute)

append() (helpers.ringbuffer method) AUTH_STATE__NAMES (in module socket_protocol) AUTH_STATE_KEY_TRANSFERRED (in module socket_protocol) AUTH_STATE_SEED_REQUESTED (in module socket_protocol) AUTH_STATE_SEED_TRANSFERRED (in module socket_protocol) AUTH_STATE_TRUSTED_CONNECTION (in module socket_protocol) AUTH_STATE_UNTRUSTED_CONNECTION (in module socket_protocol) authentificate() (socket_protocol.pure_json_protocol method)

B

build_frame() (in module stringtools.csp) (in module stringtools.stp)

C

caching module check_authentification_state() (socket_protocol.pure_json_protocol method) clean_queue() (task.queue method) client_address() (tcp_socket.tcp_base method) close() (tcp_socket.tcp_base method) connect() (helpers.direct_socket_client method) (helpers.direct_socket_stp_client method)

connection_established() (socket_protocol.pure_json_protocol method) continues_statistic (class in helpers) continues_statistic_multivalue (class in helpers) cron_execution() (task.crontab.cronjob method) crontab (class in task) crontab.cronjob (class in task) crontab.cronjob.all_match (class in task) csp (class in stringtools.csp)

D

DATA_CLEAR_BUFFER (in module stringtools.stp) data_storage (class in socket_protocol) DATA_STORE_SYNC_VALUE (in module stringtools.stp) DATA_SYNC (in module stringtools.stp) DATA_VALID_MSG (in module stringtools.stp) delayed (class in task) DID_AUTH_KEY (in module socket_protocol) DID_AUTH_SEED (in module socket_protocol)

DID_CHANNEL_NAME (in module socket_protocol) direct_socket_base (class in helpers) direct_socket_client (class in helpers) direct_socket_server (class in helpers) direct_socket_stp_base (class in helpers) direct_socket_stp_client (class in helpers) direct_socket_stp_server (class in helpers) dirlist() (in module fstools) disconnect() (helpers.direct_socket_base method)

E

enqueue() (task.queue method)

expire() (task.queue method) extend() (helpers.ringbuffer method)

F

filelist() (in module fstools) fstools module

full_update() (caching.property_cache_pickle method)

G

get() (caching.property_cache_pickle method) get_data() (socket_protocol.data_storage method) get_data_id() (socket_protocol.data_storage method)

get_service_id() (socket_protocol.data_storage method) get_status() (socket_protocol.data_storage method) gzip_compress() (in module stringtools) gzip_extract() (in module stringtools)

H

helpers module

hexlify() (in module stringtools)

I

init_channel_name() (helpers.direct_socket_base method) (tcp_socket.tcp_base method) is_connected() (helpers.direct_socket_base method) (socket_protocol.pure_json_protocol method) (tcp_socket.tcp_base method)

is_writeable() (in module fstools)

J

join() (task.periodic method) (task.threaded_queue method)

L

last_transition_condition() (state_machine.state_machine method)

last_transition_condition_was() (state_machine.state_machine method)

M

max (helpers.continues_statistic property) mean (helpers.continues_statistic property) min (helpers.continues_statistic property) mkdir() (in module fstools) module caching fstools helpers socket_protocol state_machine stringtools stringtools.csp stringtools.stp task tcp_socket

O

open_locked_blocking() (in module fstools)

open_locked_non_blocking() (in module fstools)

P

periodic (class in task) pop() (helpers.continues_statistic method) (helpers.continues_statistic_multivalue method) previous_state() (state_machine.state_machine method) previous_state_duration() (state_machine.state_machine method)

previous_state_was() (state_machine.state_machine method) process() (stringtools.csp.csp method) (stringtools.stp.stp method) property_cache_json (class in caching) property_cache_pickle (class in caching) pure_json_protocol (class in socket_protocol)

Q

quantifier (helpers.continues_statistic property)

queue (class in task)

R

receive() (helpers.direct_socket_base method) (helpers.direct_socket_stp_base method) (socket_protocol.pure_json_protocol method) (tcp_socket.tcp_base method) (tcp_socket.tcp_base_stp method) reconnect() (helpers.direct_socket_client method) (helpers.direct_socket_stp_client method) (socket_protocol.pure_json_protocol method) register_callback() (helpers.direct_socket_base method) (socket_protocol.pure_json_protocol method) (tcp_socket.tcp_base method)

register_connect_callback() (helpers.direct_socket_base method) (tcp_socket.tcp_base method) register_disconnect_callback() (helpers.direct_socket_base method) (tcp_socket.tcp_base method) register_state_change_callback() (state_machine.state_machine method) RequestSidExistsError ResponseSidExistsError ringbuffer (class in helpers) run() (task.delayed method) (task.periodic method) (task.queue method) (task.threaded_queue method)

S

send() (helpers.direct_socket_base method) (socket_protocol.pure_json_protocol method) (tcp_socket.tcp_base method) (tcp_socket.tcp_base_stp method) set_trigger_conditions() (task.crontab.cronjob method) SID_AUTH_REQUEST (in module socket_protocol) SID_AUTH_RESPONSE (in module socket_protocol) SID_CHANNEL_NAME_REQUEST (in module socket_protocol) SID_CHANNEL_NAME_RESPONSE (in module socket_protocol) SID_EXECUTE_REQUEST (in module socket_protocol) SID_EXECUTE_RESPONSE (in module socket_protocol) SID_READ_REQUEST (in module socket_protocol) SID_READ_RESPONSE (in module socket_protocol) SID_WRITE_REQUEST (in module socket_protocol) SID_WRITE_RESPONSE (in module socket_protocol) socket_protocol module state_machine module state_machine (class in state_machine) STATUS_AUTH_REQUIRED (in module socket_protocol)

STATUS_BUFFERING_UNHANDLED_REQUEST (in module socket_protocol) STATUS_CALLBACK_ERROR (in module socket_protocol) STATUS_CHECKSUM_ERROR (in module socket_protocol) STATUS_LOG_LVL (in module socket_protocol) STATUS_OKAY (in module socket_protocol) STATUS_OPERATION_NOT_PERMITTED (in module socket_protocol) STATUS_SERVICE_OR_DATA_UNKNOWN (in module socket_protocol) stop() (task.periodic method) (task.queue method) (task.threaded_queue method) stp (class in stringtools.stp) STP_STATE_ESCAPE_1 (in module stringtools.stp) STP_STATE_ESCAPE_2 (in module stringtools.stp) STP_STATE_IDLE (in module stringtools.stp) STP_STATE_STORE_DATA (in module stringtools.stp) stringtools module stringtools.csp module stringtools.stp module struct_json_protocol (class in socket_protocol)

T

task module tcp_base (class in tcp_socket) tcp_base_stp (class in tcp_socket) tcp_client (class in tcp_socket) tcp_client_stp (class in tcp_socket) tcp_server (class in tcp_socket)

tcp_server_stp (class in tcp_socket) tcp_socket module this_state() (state_machine.state_machine method) this_state_duration() (state_machine.state_machine method) this_state_is() (state_machine.state_machine method) threaded_queue (class in task)

U

uid() (in module fstools)

uid_filelist() (in module fstools)

W

work() (state_machine.state_machine method)