pybeehive package

Submodules

pybeehive.core module

class pybeehive.core.Event(data, topic=None, created_at=None)[source]

Bases: object

Parameters:
  • data
  • topic
  • created_at
static create_id(data, time_created)[source]
Parameters:
  • data
  • time_created
Returns:

static fromstring(string)[source]
Parameters:string
Returns:
tostring()[source]
Returns:
class pybeehive.core.Killable[source]

Bases: object

alive
Returns:
kill()[source]
class pybeehive.core.Listener(filters=None)[source]

Bases: abc.ABC

Parameters:filters
chain(bee)[source]
Parameters:bee
Returns:
filter(event)[source]
Parameters:event
Returns:
notify(event)[source]
Parameters:event
Returns:
on_event(event)[source]
Parameters:event
Returns:
on_exception(exception)[source]
Parameters:exception
setup()[source]
teardown()[source]
class pybeehive.core.Streamer(topic=None)[source]

Bases: pybeehive.core.Killable, abc.ABC

Parameters:topic
on_exception(exception)[source]
Parameters:exception
run()[source]
set_queue(q)[source]
Parameters:q
setup()[source]
stream()[source]
Returns:
teardown()[source]

pybeehive.hive module

class pybeehive.hive.Hive[source]

Bases: pybeehive.core.Killable

add(*bees)[source]
Parameters:bees
close()[source]
Returns:
listener(chain=None, filters=None, **kwargs)[source]
Parameters:
  • chain
  • filters
  • kwargs
Returns:

run(threaded=False, debug=False)[source]
Parameters:
  • threaded
  • debug
Returns:

socket_listener(address, chain=None, filters=None)[source]
Parameters:
  • address
  • chain
  • filters
Returns:

socket_streamer(address, topic=None)[source]
Parameters:
  • address
  • topic
Returns:

streamer(topic=None, **kwargs)[source]
Parameters:
  • topic
  • kwargs
Returns:

submit_event(event)[source]
Parameters:event
Returns:

pybeehive.logging module

pybeehive.logging.create_logger(name='pybeehive.hive', handler=None)[source]

pybeehive.socket module

class pybeehive.socket.Client(address)[source]

Bases: pybeehive.core.Killable

connect()[source]
send(data)[source]
shutdown()[source]
class pybeehive.socket.Server(address)[source]

Bases: pybeehive.core.Killable

iter_messages()[source]
shutdown()[source]
start()[source]
class pybeehive.socket.SocketListener(address, filters=None)[source]

Bases: pybeehive.core.Listener

Parameters:
  • address
  • filters
on_event(event)[source]
Parameters:event
Returns:
parse_event(event)[source]
Parameters:event
Returns:
setup()[source]
teardown()[source]
class pybeehive.socket.SocketStreamer(address, topic=None)[source]

Bases: pybeehive.core.Streamer

Parameters:
  • address
  • topic
setup()[source]
stream()[source]
Returns:
teardown()[source]

pybeehive.utils module

Module contents

Top-level package for pybeehive.

class pybeehive.Event(data, topic=None, created_at=None)[source]

Bases: object

Parameters:
  • data
  • topic
  • created_at
static create_id(data, time_created)[source]
Parameters:
  • data
  • time_created
Returns:

static fromstring(string)[source]
Parameters:string
Returns:
tostring()[source]
Returns:
class pybeehive.Listener(filters=None)[source]

Bases: abc.ABC

Parameters:filters
chain(bee)[source]
Parameters:bee
Returns:
filter(event)[source]
Parameters:event
Returns:
notify(event)[source]
Parameters:event
Returns:
on_event(event)[source]
Parameters:event
Returns:
on_exception(exception)[source]
Parameters:exception
setup()[source]
teardown()[source]
class pybeehive.Streamer(topic=None)[source]

Bases: pybeehive.core.Killable, abc.ABC

Parameters:topic
on_exception(exception)[source]
Parameters:exception
run()[source]
set_queue(q)[source]
Parameters:q
setup()[source]
stream()[source]
Returns:
teardown()[source]
class pybeehive.Hive[source]

Bases: pybeehive.core.Killable

add(*bees)[source]
Parameters:bees
close()[source]
Returns:
listener(chain=None, filters=None, **kwargs)[source]
Parameters:
  • chain
  • filters
  • kwargs
Returns:

run(threaded=False, debug=False)[source]
Parameters:
  • threaded
  • debug
Returns:

socket_listener(address, chain=None, filters=None)[source]
Parameters:
  • address
  • chain
  • filters
Returns:

socket_streamer(address, topic=None)[source]
Parameters:
  • address
  • topic
Returns:

streamer(topic=None, **kwargs)[source]
Parameters:
  • topic
  • kwargs
Returns:

submit_event(event)[source]
Parameters:event
Returns: