Index

A

about() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.redis_ops.RedisOps method) (hs_py.ws_client.ChannelClient method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) accept() (hs_py.ws.HaystackWebSocket class method) add_col() (hs_py.grid.GridBuilder method) add_lib() (hs_py.ontology.namespace.Namespace method) add_meta() (hs_py.grid.GridBuilder method) add_row() (hs_py.grid.GridBuilder method) ADMIN (hs_py.user.Role attribute) all_col_names (hs_py.storage.memory.InMemoryAdapter property) (hs_py.storage.redis.RedisAdapter property) (hs_py.storage.timescale.TimescaleAdapter property)

all_defs() (hs_py.ontology.namespace.Namespace method) all_libs() (hs_py.ontology.namespace.Namespace method) all_supertypes() (hs_py.ontology.namespace.Namespace method) And (class in hs_py.filter.ast) AND (hs_py.filter.lexer.TokenType attribute) apply_delta() (hs_py.watch.WatchAccumulator method) apply_filter() (hs_py.watch.WatchState method) ARROW (hs_py.filter.lexer.TokenType attribute) authenticate() (in module hs_py.auth) Authenticator (class in hs_py.auth_types) AuthError authorize() (hs_py.auth_types.CertAuthenticator method)

B

base_uri (hs_py.ontology.defs.Lib attribute) batch() (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method)

BOOL (hs_py.filter.lexer.TokenType attribute) build_client_ssl_context() (in module hs_py.tls) build_server_ssl_context() (in module hs_py.tls)

C

ca_certificates_path (hs_py.tls.TLSConfig attribute) CallError cancel_task() (in module hs_py.ws) CertAuthenticator (class in hs_py.auth_types) certificate_path (hs_py.tls.TLSConfig attribute) channel() (hs_py.ws_client.WebSocketPool method) ChannelClient (class in hs_py.ws_client) CHUNK_SIZE (in module hs_py.ws_codec) CHUNK_THRESHOLD (in module hs_py.ws_codec) ChunkAssembler (class in hs_py.ws_codec) city_to_tz() (in module hs_py.encoding.scanner) cleanup() (hs_py.ws_codec.ChunkAssembler method) Client (class in hs_py.client) close() (hs_py.client.Client method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws.HaystackWebSocket method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) (hs_py.ws_client.WebSocketPool method) Cmp (class in hs_py.filter.ast)

CmpOp (class in hs_py.filter.ast) Col (class in hs_py.grid) col() (hs_py.grid.Grid method) col_names (hs_py.grid.Grid property) cols (hs_py.grid.Grid attribute) COMP_LZMA (in module hs_py.ws_codec) COMP_ZLIB (in module hs_py.ws_codec) compile_namespace() (in module hs_py.ontology.normalize) compress_payload() (in module hs_py.ws_codec) compute_delta() (hs_py.watch.WatchState method) connect() (hs_py.ws.HaystackWebSocket class method) Coord (class in hs_py.kinds) create_fastapi_app() (in module hs_py.fastapi_server) create_redis_client() (in module hs_py.redis_ops) (in module hs_py.storage.redis) create_timescale_pool() (in module hs_py.storage.timescale) create_user() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.UserStore method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (in module hs_py.user) created_at (hs_py.user.User attribute) credentials (hs_py.user.User attribute)

D

DATE (hs_py.filter.lexer.TokenType attribute) DATE_RE (in module hs_py.encoding.scanner) DATETIME (hs_py.filter.lexer.TokenType attribute) DATETIME_RE (in module hs_py.encoding.scanner) decode_binary_frame() (in module hs_py.ws_codec) decode_grid() (in module hs_py.encoding.json) (in module hs_py.encoding.zinc) decode_grid_dict() (in module hs_py.encoding.json) decode_val() (in module hs_py.encoding.json) (in module hs_py.encoding.zinc) decompress_payload() (in module hs_py.ws_codec) Def (class in hs_py.ontology.defs)

def_count (hs_py.ontology.namespace.Namespace property) defs (hs_py.ontology.defs.Lib attribute) defs() (hs_py.ops.HaystackOps method) delete_user() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.UserStore method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) depends (hs_py.ontology.defs.Lib attribute) DIGIT_CHARS (in module hs_py.encoding.scanner) dis (hs_py.errors.CallError property) (hs_py.kinds.Ref attribute) doc (hs_py.ontology.defs.Def property)

E

effective_tags() (in module hs_py.ontology.taxonomy) email (hs_py.user.User attribute) enabled (hs_py.user.User attribute) encode_binary_push() (in module hs_py.ws_codec) encode_binary_request() (in module hs_py.ws_codec) encode_binary_response() (in module hs_py.ws_codec) encode_chunked_frames() (in module hs_py.ws_codec) encode_grid() (in module hs_py.encoding.csv) (in module hs_py.encoding.json) (in module hs_py.encoding.zinc) encode_grid_dict() (in module hs_py.encoding.json) encode_trio() (in module hs_py.encoding.trio)

encode_val() (in module hs_py.encoding.json) (in module hs_py.encoding.zinc) ensure_superuser() (in module hs_py.bootstrap) entities (hs_py.watch.WatchAccumulator property) EOF (hs_py.filter.lexer.TokenType attribute) EQ (hs_py.filter.ast.CmpOp attribute) (hs_py.filter.lexer.TokenType attribute) escape_str() (in module hs_py.encoding.scanner) evaluate() (in module hs_py.filter.eval) evaluate_grid() (in module hs_py.filter.eval) extract_peer_cn() (in module hs_py.tls) extract_peer_sans() (in module hs_py.tls)

F

feed() (hs_py.ws_codec.ChunkAssembler method) filetypes() (hs_py.ops.HaystackOps method) (hs_py.redis_ops.RedisOps method) find_conjuncts() (hs_py.ontology.namespace.Namespace method) first_name (hs_py.user.User attribute) fits() (in module hs_py.ontology.reflect) format_num() (in module hs_py.encoding.scanner)

format_number() (in module hs_py.encoding.scanner) format_ref() (in module hs_py.encoding.scanner) formats() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) from_meta() (hs_py.ontology.defs.Lib class method) from_tags() (hs_py.ontology.defs.Def class method)

G

GE (hs_py.filter.ast.CmpOp attribute) (hs_py.filter.lexer.TokenType attribute) generate_test_certificates() (in module hs_py.tls) get() (hs_py.ontology.namespace.Namespace method) (hs_py.watch.WatchAccumulator method) get_user() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.UserStore method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method)

Grid (class in hs_py.grid) GridBuilder (class in hs_py.grid) GT (hs_py.filter.ast.CmpOp attribute) (hs_py.filter.lexer.TokenType attribute)

H

Has (class in hs_py.filter.ast) has() (hs_py.ontology.namespace.Namespace method) has_col() (hs_py.grid.Grid method) HaystackError HaystackOps (class in hs_py.ops) HaystackWebSocket (class in hs_py.ws) heartbeat_loop() (in module hs_py.ws) his_read() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) his_read_batch() (hs_py.client.Client method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) his_write() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) his_write_batch() (hs_py.client.Client method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) hs_py.auth module hs_py.auth_types module hs_py.bootstrap module hs_py.client module hs_py.encoding module hs_py.encoding.csv module hs_py.encoding.json module hs_py.encoding.scanner module hs_py.encoding.trio module hs_py.encoding.zinc module hs_py.errors module hs_py.fastapi_server module

hs_py.filter module hs_py.filter.ast module hs_py.filter.eval module hs_py.filter.lexer module hs_py.filter.parser module hs_py.grid module hs_py.kinds module hs_py.metrics module hs_py.ontology module hs_py.ontology.defs module hs_py.ontology.namespace module hs_py.ontology.normalize module hs_py.ontology.reflect module hs_py.ontology.taxonomy module hs_py.ops module hs_py.redis_ops module hs_py.storage.memory module hs_py.storage.protocol module hs_py.storage.redis module hs_py.storage.timescale module hs_py.tls module hs_py.user module hs_py.watch module hs_py.ws module hs_py.ws_client module hs_py.ws_codec module hs_py.ws_server module

I

IDENT (hs_py.filter.lexer.TokenType attribute) IDENT_CHARS (in module hs_py.encoding.scanner) InMemoryAdapter (class in hs_py.storage.memory) invoke_action() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.redis_ops.RedisOps method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method)

is_conjunct() (in module hs_py.ontology.taxonomy) is_empty (hs_py.grid.Grid property) is_error (hs_py.grid.Grid property) is_haystack_type() (in module hs_py.kinds) is_list (hs_py.ontology.defs.Def property) is_open (hs_py.ws.HaystackWebSocket property) is_subtype() (hs_py.ontology.namespace.Namespace method) iterations (hs_py.auth_types.ScramCredentials attribute)

J

JsonVersion (class in hs_py.encoding.json)

K

key_password (hs_py.tls.TLSConfig attribute)

L

last_name (hs_py.user.User attribute) lat (hs_py.kinds.Coord attribute) LE (hs_py.filter.ast.CmpOp attribute) (hs_py.filter.lexer.TokenType attribute) left (hs_py.filter.ast.And attribute) (hs_py.filter.ast.Or attribute) level (hs_py.user.Role property) Lexer (class in hs_py.filter.lexer) Lib (class in hs_py.ontology.defs) lib_prefix (hs_py.ontology.defs.Def property) libs() (hs_py.ops.HaystackOps method) list_users() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.UserStore method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method)

lng (hs_py.kinds.Coord attribute) load_defs_from_trio() (in module hs_py.ontology.namespace) load_entities() (hs_py.redis_ops.RedisOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) load_grid() (hs_py.redis_ops.RedisOps method) load_lib_from_trio() (in module hs_py.ontology.namespace) LPAREN (hs_py.filter.lexer.TokenType attribute) LT (hs_py.filter.ast.CmpOp attribute) (hs_py.filter.lexer.TokenType attribute)

M

make_empty() (hs_py.grid.Grid class method) make_error() (hs_py.grid.Grid class method) make_rows() (hs_py.grid.Grid class method) make_rows_with_col_names() (hs_py.grid.Grid class method) mark_dirty() (hs_py.storage.memory.InMemoryAdapter method) Marker (class in hs_py.kinds) MARKER (in module hs_py.kinds) marker_tags() (in module hs_py.ontology.taxonomy) meta (hs_py.grid.Col attribute) (hs_py.grid.Grid attribute) MetricsHooks (class in hs_py.metrics) Missing (class in hs_py.filter.ast) module hs_py.auth hs_py.auth_types hs_py.bootstrap hs_py.client hs_py.encoding hs_py.encoding.csv hs_py.encoding.json hs_py.encoding.scanner hs_py.encoding.trio hs_py.encoding.zinc hs_py.errors hs_py.fastapi_server hs_py.filter hs_py.filter.ast hs_py.filter.eval hs_py.filter.lexer hs_py.filter.parser hs_py.grid hs_py.kinds hs_py.metrics hs_py.ontology hs_py.ontology.defs hs_py.ontology.namespace hs_py.ontology.normalize hs_py.ontology.reflect hs_py.ontology.taxonomy hs_py.ops hs_py.redis_ops hs_py.storage.memory hs_py.storage.protocol hs_py.storage.redis hs_py.storage.timescale hs_py.tls hs_py.user hs_py.watch hs_py.ws hs_py.ws_client hs_py.ws_codec hs_py.ws_server

N

Na (class in hs_py.kinds) NA (in module hs_py.kinds) name (hs_py.grid.Col attribute) (hs_py.ontology.defs.Def property) names (hs_py.filter.ast.Path attribute) Namespace (class in hs_py.ontology.namespace) nav() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method)

NE (hs_py.filter.ast.CmpOp attribute) (hs_py.filter.lexer.TokenType attribute) NetworkError Node (in module hs_py.filter.ast) NormalizeError NOT (hs_py.filter.lexer.TokenType attribute) Number (class in hs_py.kinds) NUMBER (hs_py.filter.lexer.TokenType attribute)

O

on_close() (hs_py.ops.HaystackOps method) on_error (hs_py.metrics.MetricsHooks attribute) on_request (hs_py.metrics.MetricsHooks attribute) on_watch_push() (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) on_ws_connect (hs_py.metrics.MetricsHooks attribute) on_ws_disconnect (hs_py.metrics.MetricsHooks attribute) on_ws_message_recv (hs_py.metrics.MetricsHooks attribute) on_ws_message_sent (hs_py.metrics.MetricsHooks attribute)

op (hs_py.filter.ast.Cmp attribute) OP_CODES (in module hs_py.ws_codec) OPERATOR (hs_py.user.Role attribute) ops() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.ws_client.ChannelClient method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) Or (class in hs_py.filter.ast) OR (hs_py.filter.lexer.TokenType attribute)

P

parse() (in module hs_py.filter.parser) parse_datetime() (in module hs_py.encoding.scanner) parse_trio() (in module hs_py.encoding.trio) parse_zinc_val() (in module hs_py.encoding.trio) ParseError Path (class in hs_py.filter.ast) path (hs_py.filter.ast.Cmp attribute) (hs_py.filter.ast.Has attribute) (hs_py.filter.ast.Missing attribute) pending_count (hs_py.ws_codec.ChunkAssembler property) ping() (hs_py.ws.HaystackWebSocket method) point_read_array() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method)

point_write() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) point_write_array() (hs_py.client.Client method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) port (hs_py.ws_server.WebSocketServer property) pos (hs_py.filter.lexer.Token attribute) private_key_path (hs_py.tls.TLSConfig attribute) push_watch() (hs_py.ops.HaystackOps method) (hs_py.ws_server.WebSocketServer method)

R

read() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.ws_client.ChannelClient method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) read_by_filter() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) read_by_ids() (hs_py.client.Client method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ChannelClient method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method)

ReconnectingWebSocketClient (class in hs_py.ws_client) recv() (hs_py.ws.HaystackWebSocket method) RedisAdapter (class in hs_py.storage.redis) RedisOps (class in hs_py.redis_ops) Ref (class in hs_py.kinds) REF (hs_py.filter.lexer.TokenType attribute) REF_CHARS (in module hs_py.encoding.scanner) reflect() (in module hs_py.ontology.reflect) Remove (class in hs_py.kinds) REMOVE (in module hs_py.kinds) resolve_conjunct_parts() (in module hs_py.ontology.taxonomy) Resolver (in module hs_py.filter.eval) right (hs_py.filter.ast.And attribute) (hs_py.filter.ast.Or attribute) Role (class in hs_py.user) role (hs_py.user.User attribute) rows (hs_py.grid.Grid attribute) RPAREN (hs_py.filter.lexer.TokenType attribute)

S

salt (hs_py.auth_types.ScramCredentials attribute) scan_dict() (in module hs_py.encoding.scanner) scan_keyword() (in module hs_py.encoding.scanner) scan_list() (in module hs_py.encoding.scanner) scan_number() (in module hs_py.encoding.scanner) scan_number_or_temporal() (in module hs_py.encoding.scanner) scan_ref() (in module hs_py.encoding.scanner) scan_str() (in module hs_py.encoding.scanner) scan_symbol() (in module hs_py.encoding.scanner) scan_tag_name() (in module hs_py.encoding.scanner) scan_uri() (in module hs_py.encoding.scanner) scan_val() (in module hs_py.encoding.scanner) scram_client_final() (in module hs_py.auth) scram_client_first() (in module hs_py.auth) scram_credentials() (hs_py.auth_types.Authenticator method) (hs_py.auth_types.SimpleAuthenticator method) (hs_py.auth_types.StorageAuthenticator method) ScramAuthMiddleware (class in hs_py.fastapi_server) ScramCredentials (class in hs_py.auth_types) send_bytes() (hs_py.ws.HaystackWebSocket method) send_text() (hs_py.ws.HaystackWebSocket method) send_text_preencoded() (hs_py.ws.HaystackWebSocket method) server_key (hs_py.auth_types.ScramCredentials attribute) set_meta() (hs_py.grid.GridBuilder method) set_push_handler() (hs_py.ops.HaystackOps method)

SimpleAuthenticator (class in hs_py.auth_types) skip_ws() (in module hs_py.encoding.scanner) start() (hs_py.redis_ops.RedisOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_server.WebSocketServer method) stop() (hs_py.redis_ops.RedisOps method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_server.WebSocketServer method) StorageAdapter (class in hs_py.storage.protocol) StorageAuthenticator (class in hs_py.auth_types) stored_key (hs_py.auth_types.ScramCredentials attribute) STR (hs_py.filter.lexer.TokenType attribute) STR_ESCAPES (in module hs_py.encoding.scanner) subprotocol (hs_py.ws.HaystackWebSocket property) subtypes() (hs_py.ontology.namespace.Namespace method) supertypes() (hs_py.ontology.namespace.Namespace method) sym_name() (in module hs_py.kinds) Symbol (class in hs_py.kinds) SYMBOL (hs_py.filter.lexer.TokenType attribute) symbol (hs_py.ontology.defs.Def attribute) (hs_py.ontology.defs.Lib attribute) SYMBOL_CHARS (in module hs_py.encoding.scanner)

T

tag_on_defs() (in module hs_py.ontology.taxonomy) tags (hs_py.ontology.defs.Def attribute) TIME (hs_py.filter.lexer.TokenType attribute) TIME_RE (in module hs_py.encoding.scanner) TimescaleAdapter (class in hs_py.storage.timescale) TLSConfig (class in hs_py.tls) to_grid() (hs_py.grid.GridBuilder method) (hs_py.watch.WatchAccumulator method)

Token (class in hs_py.filter.lexer) tokenize() (hs_py.filter.lexer.Lexer method) tokens (hs_py.fastapi_server.ScramAuthMiddleware property) TokenType (class in hs_py.filter.lexer) trace (hs_py.errors.CallError property) type (hs_py.filter.lexer.Token attribute) type_name (hs_py.kinds.XStr attribute) tz_name() (in module hs_py.encoding.scanner) tz_to_city() (in module hs_py.encoding.scanner)

U

unit (hs_py.kinds.Number attribute) UNIT_STOP_BASE (in module hs_py.encoding.scanner) update() (hs_py.watch.WatchState method) update_user() (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.UserStore method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method)

updated_at (hs_py.user.User attribute) Uri (class in hs_py.kinds) URI (hs_py.filter.lexer.TokenType attribute) User (class in hs_py.user) user_from_dict() (in module hs_py.user) user_to_dict() (in module hs_py.user) username (hs_py.user.User attribute) UserStore (class in hs_py.storage.protocol)

V

V3 (hs_py.encoding.json.JsonVersion attribute) V4 (hs_py.encoding.json.JsonVersion attribute) val (hs_py.filter.ast.Cmp attribute) (hs_py.filter.lexer.Token attribute) (hs_py.kinds.Number attribute) (hs_py.kinds.Ref attribute) (hs_py.kinds.Symbol attribute) (hs_py.kinds.Uri attribute) (hs_py.kinds.XStr attribute)

version (hs_py.ontology.defs.Lib attribute) VIEWER (hs_py.user.Role attribute)

W

watch_close() (hs_py.client.Client method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) watch_poll() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) watch_sub() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method)

watch_unsub() (hs_py.client.Client method) (hs_py.ops.HaystackOps method) (hs_py.storage.memory.InMemoryAdapter method) (hs_py.storage.protocol.StorageAdapter method) (hs_py.storage.redis.RedisAdapter method) (hs_py.storage.timescale.TimescaleAdapter method) (hs_py.ws_client.ReconnectingWebSocketClient method) (hs_py.ws_client.WebSocketClient method) WatchAccumulator (class in hs_py.watch) WatchState (class in hs_py.watch) WebSocketClient (class in hs_py.ws_client) WebSocketPool (class in hs_py.ws_client) WebSocketServer (class in hs_py.ws_server)

X

XStr (class in hs_py.kinds)