Index

A

active (zeeko.cyloop.throttle.Throttle attribute) (zeeko.handlers.snail.Snail attribute) add_worker() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) append() (zeeko.telemetry.chunk.Chunk method) array (zeeko.messages.message.ArrayMessage attribute) (zeeko.telemetry.chunk.Chunk attribute)

ArrayMessage (class in zeeko.messages.message) at_address() (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method) attach() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) autosubscribe (zeeko.handlers.base.SocketOptions attribute)

B

bind() (zeeko.handlers.base.SocketOptions method)

C

c (zeeko.cyloop.throttle.Throttle attribute) cancel() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) check() (zeeko.handlers.base.SocketInfo method) (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.handlers.snail.Snail method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method) Chunk (class in zeeko.telemetry.chunk) chunkcount (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.recorder.Recorder attribute) chunksize (zeeko.telemetry.chunk.Chunk attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.recorder.Recorder attribute) (zeeko.telemetry.writer.Writer attribute) clear() (zeeko.handlers.server.Server method) (zeeko.telemetry.recorder.Recorder method) (zeeko.telemetry.writer.Writer method) Client (class in zeeko.handlers.client) close() (zeeko.handlers.base.SocketInfo method) (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method)

complete (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.recorder.Recorder attribute) configure() (zeeko.cyloop.throttle.Throttle method) (zeeko.handlers.snail.Snail method) configure_throttle() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) connect() (zeeko.handlers.base.SocketOptions method) context (zeeko.cyloop.loop.IOLoop attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.telemetry.pipeline.PipelineIOLoop attribute) copy() (zeeko.telemetry.chunk.Chunk method) counter (zeeko.telemetry.handlers.TelemetryWriter attribute) (zeeko.telemetry.recorder.Recorder attribute) (zeeko.telemetry.writer.Writer attribute) create_ioloop() (zeeko.handlers.base.SocketInfo method) (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method) create_pipeline() (in module zeeko.telemetry.pipeline)

D

deaths (zeeko.handlers.snail.Snail attribute) delay (zeeko.handlers.snail.Snail attribute) delay_max (zeeko.handlers.snail.Snail attribute)

deselected() (zeeko.cyloop.statemachine.StateMachine method) disconnect() (zeeko.handlers.base.SocketOptions method) dtype (zeeko.messages.message.ArrayMessage attribute) (zeeko.telemetry.chunk.Chunk attribute)

E

enable_hardcopy() (zeeko.messages.publisher.Publisher method) enable_notifications() (zeeko.telemetry.handlers.Telemetry method) enable_reconnections() (zeeko.handlers.client.Client method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method) ensure() (zeeko.cyloop.statemachine.StateMachine method) event() (zeeko.handlers.client.Client method) (zeeko.messages.receiver.Receiver method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.recorder.Recorder method) (zeeko.telemetry.writer.Writer method)

events (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

F

file (zeeko.telemetry.writer.Writer attribute) filename (zeeko.telemetry.handlers.TelemetryWriter attribute) filename_template (zeeko.telemetry.handlers.TelemetryWriter attribute) fired (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute) framecount (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.messages.message.ArrayMessage attribute) (zeeko.messages.publisher.Publisher attribute) (zeeko.messages.receiver.Receiver attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.recorder.Recorder attribute) (zeeko.telemetry.writer.Writer attribute)

framecounter (zeeko.telemetry.handlers.Telemetry attribute) frequency (zeeko.cyloop.throttle.Throttle attribute) from_recorder() (zeeko.telemetry.handlers.TelemetryWriter method)

G

gain (zeeko.cyloop.throttle.Throttle attribute) get() (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method)

guard() (zeeko.cyloop.statemachine.StateMachine method)

H

h5_group_name (zeeko.telemetry.handlers.TelemetryWriter attribute)

I

IOLoop (class in zeeko.cyloop.loop) is_alive() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method)

items() (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method)

J

join() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method)

K

keys() (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method)

L

last_message (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.messages.publisher.Publisher attribute) (zeeko.messages.receiver.Receiver attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.recorder.Recorder attribute) (zeeko.telemetry.writer.Writer attribute) lastindex (zeeko.telemetry.chunk.Chunk attribute) leak (zeeko.cyloop.throttle.Throttle attribute) log (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

loop (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

M

mask (zeeko.telemetry.chunk.Chunk attribute) md (zeeko.messages.message.ArrayMessage attribute) (zeeko.telemetry.chunk.Chunk attribute)

metadata (zeeko.messages.message.ArrayMessage attribute) (zeeko.telemetry.chunk.Chunk attribute) metadata_callback (zeeko.telemetry.writer.Writer attribute)

N

name (zeeko.cyloop.statemachine.StateMachine attribute) (zeeko.messages.message.ArrayMessage attribute) (zeeko.telemetry.chunk.Chunk attribute) name_to_state() (zeeko.cyloop.statemachine.StateMachine method)

nlate (zeeko.handlers.snail.Snail attribute) nlate_max (zeeko.handlers.snail.Snail attribute) notifications_address (zeeko.telemetry.handlers.Telemetry attribute) notify (zeeko.telemetry.handlers.Telemetry attribute) notify() (zeeko.telemetry.recorder.Recorder method)

O

opt (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

overhead (zeeko.cyloop.throttle.Throttle attribute)

P

pause() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) period (zeeko.cyloop.throttle.Throttle attribute) PipelineIOLoop (class in zeeko.telemetry.pipeline) pop() (zeeko.handlers.server.Server method)

popitem() (zeeko.handlers.server.Server method) publish() (zeeko.handlers.server.Server method) (zeeko.messages.publisher.Publisher method) Publisher (class in zeeko.messages.publisher) pushed (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.recorder.Recorder attribute)

R

ready() (zeeko.handlers.client.Client method) receive() (zeeko.handlers.client.Client method) (zeeko.messages.message.ArrayMessage method) (zeeko.messages.receiver.Receiver method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.recorder.Recorder method) (zeeko.telemetry.writer.Writer method)

Receiver (class in zeeko.messages.receiver) reconnect() (zeeko.handlers.client.Client method) Recorder (class in zeeko.telemetry.recorder) recv() (zeeko.cyloop.statemachine.StateMachine method) resume() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) running() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method)

S

selected() (zeeko.cyloop.statemachine.StateMachine method) send() (zeeko.messages.message.ArrayMessage method) (zeeko.telemetry.chunk.Chunk method) Server (class in zeeko.handlers.server) set() (zeeko.handlers.base.SocketOptions method) set_file_number() (zeeko.telemetry.handlers.TelemetryWriter method) set_metadata_callback() (zeeko.telemetry.handlers.TelemetryWriter method) setdefault() (zeeko.handlers.server.Server method) shape (zeeko.messages.message.ArrayMessage attribute) (zeeko.telemetry.chunk.Chunk attribute) signal() (zeeko.cyloop.loop.IOLoop method) (zeeko.cyloop.statemachine.StateMachine method) (zeeko.telemetry.pipeline.PipelineIOLoop method) Snail (class in zeeko.handlers.snail) snail (zeeko.handlers.client.Client attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute) socket (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

SocketInfo (class in zeeko.handlers.base) SocketOptionError SocketOptions (class in zeeko.handlers.base) start() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) state (zeeko.cyloop.loop.IOLoop attribute) (zeeko.telemetry.pipeline.PipelineIOLoop attribute) state_to_name() (zeeko.cyloop.statemachine.StateMachine method) StateError StateMachine (class in zeeko.cyloop.statemachine) StateTimeout stop() (zeeko.cyloop.loop.IOLoop method) (zeeko.telemetry.pipeline.PipelineIOLoop method) stride (zeeko.telemetry.chunk.Chunk attribute) subscribe() (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.telemetry.handlers.Telemetry method) subscriptions (zeeko.handlers.base.SocketOptions attribute) support_options() (zeeko.handlers.base.SocketInfo method) (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method)

T

Telemetry (class in zeeko.telemetry.handlers) TelemetryWriter (class in zeeko.telemetry.handlers) Throttle (class in zeeko.cyloop.throttle) throttle (zeeko.handlers.base.SocketInfo attribute) (zeeko.handlers.base.SocketOptions attribute) (zeeko.handlers.client.Client attribute) (zeeko.handlers.server.Server attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

timeout (zeeko.cyloop.throttle.Throttle attribute) timestamp (zeeko.messages.message.ArrayMessage attribute)

U

unbind() (zeeko.handlers.base.SocketOptions method) unsubscribe() (zeeko.handlers.base.SocketOptions method) (zeeko.handlers.client.Client method) (zeeko.telemetry.handlers.Telemetry method)

unsubscribe_all() (zeeko.handlers.base.SocketOptions method) update() (zeeko.handlers.server.Server method) use_reconnections (zeeko.handlers.client.Client attribute) (zeeko.telemetry.handlers.Telemetry attribute) (zeeko.telemetry.handlers.TelemetryWriter attribute)

V

values() (zeeko.handlers.client.Client method) (zeeko.handlers.server.Server method) (zeeko.telemetry.handlers.Telemetry method) (zeeko.telemetry.handlers.TelemetryWriter method)

W

wrap_socket() (zeeko.handlers.base.SocketOptions method) write() (zeeko.telemetry.chunk.Chunk method)

Writer (class in zeeko.telemetry.writer) writer (zeeko.telemetry.handlers.Telemetry attribute)

Z

zeeko.cyloop.loop (module) zeeko.cyloop.statemachine (module) zeeko.cyloop.throttle (module) zeeko.handlers.base (module) zeeko.handlers.client (module) zeeko.handlers.server (module) zeeko.handlers.snail (module) zeeko.messages.carray (module)

zeeko.messages.message (module) zeeko.messages.publisher (module) zeeko.messages.receiver (module) zeeko.telemetry.chunk (module) zeeko.telemetry.handlers (module) zeeko.telemetry.pipeline (module) zeeko.telemetry.recorder (module) zeeko.telemetry.writer (module)