pybeehive package

Subpackages

• pybeehive.asyn package
  • Submodules
  • pybeehive.asyn.core module
  • pybeehive.asyn.hive module
  • pybeehive.asyn.socket module
  • pybeehive.asyn.utils module
  • Module contents

Submodules

pybeehive.core module

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

Bases: object

Parameters:

• data –
• topic –
• created_at –

static create_id(data, time_created)

Parameters:

• data –
• time_created –

Returns:

static fromstring(string)

Parameters:string – Returns:

tostring()

Returns:

class pybeehive.core.Killable

Bases: object

alive

Returns:

kill()

class pybeehive.core.Listener(filters=None)

Bases: abc.ABC

Parameters:filters –

chain(bee)

Parameters:bee – Returns:

filter(event)

Parameters:event – Returns:

notify(event)

Parameters:event – Returns:

on_event(event)

Parameters:event – Returns:

on_exception(exception)

Parameters:exception –

setup()

teardown()

class pybeehive.core.Streamer(topic=None)

Bases: pybeehive.core.Killable, abc.ABC

Parameters:topic –

on_exception(exception)

Parameters:exception –

run()

set_queue(q)

Parameters:q –

setup()

stream()

Returns:

teardown()

pybeehive.hive module

class pybeehive.hive.Hive

Bases: pybeehive.core.Killable

add(*bees)

Parameters:bees –

close()

Returns:

listener(chain=None, filters=None, **kwargs)

Parameters:

• chain –
• filters –
• kwargs –

Returns:

run(threaded=False, debug=False)

Parameters:

• threaded –
• debug –

Returns:

socket_listener(address, chain=None, filters=None)

Parameters:

• address –
• chain –
• filters –

Returns:

socket_streamer(address, topic=None)

Parameters:

• address –
• topic –

Returns:

streamer(topic=None, **kwargs)

Parameters:

• topic –
• kwargs –

Returns:

submit_event(event)

Parameters:event – Returns:

pybeehive.logging module

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

pybeehive.socket module

class pybeehive.socket.Client(address)

Bases: pybeehive.core.Killable

connect()

send(data)

shutdown()

class pybeehive.socket.Server(address)

Bases: pybeehive.core.Killable

iter_messages()

shutdown()

start()

class pybeehive.socket.SocketListener(address, filters=None)

Bases: pybeehive.core.Listener

Parameters:

• address –
• filters –

on_event(event)

Parameters:event – Returns:

parse_event(event)

Parameters:event – Returns:

setup()

teardown()

class pybeehive.socket.SocketStreamer(address, topic=None)

Bases: pybeehive.core.Streamer

Parameters:

• address –
• topic –

setup()

stream()

Returns:

teardown()

pybeehive.utils module

Module contents

Top-level package for pybeehive.

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

Bases: object

Parameters:

• data –
• topic –
• created_at –

static create_id(data, time_created)

Parameters:

• data –
• time_created –

Returns:

static fromstring(string)

Parameters:string – Returns:

tostring()

Returns:

class pybeehive.Listener(filters=None)

Bases: abc.ABC

Parameters:filters –

chain(bee)

Parameters:bee – Returns:

filter(event)

Parameters:event – Returns:

notify(event)

Parameters:event – Returns:

on_event(event)

Parameters:event – Returns:

on_exception(exception)

Parameters:exception –

setup()

teardown()

class pybeehive.Streamer(topic=None)

Bases: pybeehive.core.Killable, abc.ABC

Parameters:topic –

on_exception(exception)

Parameters:exception –

run()

set_queue(q)

Parameters:q –

setup()

stream()

Returns:

teardown()

class pybeehive.Hive

Bases: pybeehive.core.Killable

add(*bees)

Parameters:bees –

close()

Returns:

listener(chain=None, filters=None, **kwargs)

Parameters:

• chain –
• filters –
• kwargs –

Returns:

run(threaded=False, debug=False)

Parameters:

• threaded –
• debug –

Returns:

socket_listener(address, chain=None, filters=None)

Parameters:

• address –
• chain –
• filters –

Returns:

socket_streamer(address, topic=None)

Parameters:

• address –
• topic –

Returns:

streamer(topic=None, **kwargs)

Parameters:

• topic –
• kwargs –

Returns:

submit_event(event)

Parameters:event – Returns: