km3pipe.srv

The KM3srv tornado webserver.

Module Contents

Classes

ClientManager() Manage km3srv clients.
MessageProvider(*args, **kwargs)
EchoWebSocket(*args, **kwargs) An echo handler for client/server messaging and debugging

Functions

srv_event(token, hits, url=RBA_URL) Serve event to RainbowAlga
srv_data(url, token, data, kind) Serve data to RainbowAlga
main()
km3pipe.srv.log[source]
km3pipe.srv.VERSION = 0.0.1[source]
km3pipe.srv.RBA_URL[source]
class km3pipe.srv.ClientManager[source]

Bases:object

Manage km3srv clients.

add(self, client)[source]
remove(self, token)[source]
heartbeat(self, interval=30)[source]
broadcast_status(self)[source]
message_to(self, token, data, kind)[source]
raw_message_to(self, token, message)[source]

Convert message to JSON and send it to the client with token

broadcast(self, data, kind='info')[source]
class km3pipe.srv.MessageProvider(*args, **kwargs)[source]

Bases:tornado.websocket.WebSocketHandler

on_message(self, message)[source]
class km3pipe.srv.EchoWebSocket(*args, **kwargs)[source]

Bases:tornado.websocket.WebSocketHandler

An echo handler for client/server messaging and debugging

status[source]
check_origin(self, origin)[source]
open(self)[source]
on_close(self)[source]
on_message(self, message)[source]
get_event(self, det_id, run_id, event_id)[source]
message(self, data, kind='info')[source]

Convert message to json and send it to the clients

km3pipe.srv.srv_event(token, hits, url=RBA_URL)[source]

Serve event to RainbowAlga

km3pipe.srv.srv_data(url, token, data, kind)[source]

Serve data to RainbowAlga

km3pipe.srv.main()[source]