Server¶

Event HUB¶

The EventHUB and related functions..

class geoffrey.hub.EventHUB(*args, **kwargs)[source]¶

The main data exchanger.

del_state(data)[source]¶

Delete a state of the hub state table.

get_states(key_criteria)[source]¶

Generator with the matching states of the key_criteria.

put(data)[source]¶

Put a state or event in the hub.

This method is a coroutine, use:

yield from hub.put(data)

put_nowait(data)[source]¶

Put a state or event in the hub.

This method is NOT a coroutine, use:

hub.put_nowait(data)

restore_states(filename)[source]¶

Load the state table from disk.

run()[source]¶

Infite loop that send events to the subscribers.

save_states(filename)[source]¶

Save the state table to disk.

set_state(data)[source]¶

Set a state in the hub state table.

Web Server¶

Web Socket¶

class geoffrey.websocket.WebsocketServer(consumers)[source]¶

handshake(websocket)[source]¶

Do the handshake with the websocket. Return the consumer.

Project¶

Plugin¶