gnes.service.base module

class gnes.service.base.BaseService(args)

Bases: object

close()

default_host = '0.0.0.0'

dump(respect_dump_interval=True)

handler = <gnes.service.base.MessageHandler object>

load_model(base_class, yaml_path=None)

Return type:~T

post_init()

run()

status

class gnes.service.base.BetterEnum

Bases: enum.Enum

An enumeration.

from_string = <bound method BetterEnum.from_string of <enum 'BetterEnum'>>

exception gnes.service.base.BlockMessage

Bases: Exception

exception gnes.service.base.ComponentNotLoad

Bases: Exception

class gnes.service.base.ConcurrentService

Bases: type

exception gnes.service.base.EventLoopEnd

Bases: Exception

class gnes.service.base.MessageHandler(mh=None)

Bases: object

call_hooks(msg, hook_type, *args, **kwargs)

All post handler hooks are called after the handler is done but before sending out the message to the next service. All pre handler hooks are called after the service received a message and before calling the message handler

call_routes(msg)

call_routes_send_back(msg, out_sock)

register(msg_type)

register_hook(hook_type, only_when_verbose=False)

Register a function as a pre/post hook

Parameters:

• only_when_verbose (bool) – only call the hook when verbose is true
• hook_type (Union[str, Tuple[str]]) – possible values ‘pre’ or ‘post’ or (‘pre’, ‘post’)

class gnes.service.base.ParallelType

Bases: gnes.service.base.BetterEnum

An enumeration.

PUB_BLOCK = 2

PUB_NONBLOCK = 3

PUSH_BLOCK = 0

PUSH_NONBLOCK = 1

is_block

is_push

class gnes.service.base.ReduceOp

Bases: gnes.service.base.BetterEnum

An enumeration.

ALWAYS_ONE = 1

CONCAT = 0

exception gnes.service.base.ServiceError

Bases: Exception

class gnes.service.base.ServiceManager(service_cls, args)

Bases: object

join()

class gnes.service.base.SocketType

Bases: gnes.service.base.BetterEnum

An enumeration.

PAIR_BIND = 8

PAIR_CONNECT = 9

PUB_BIND = 6

PUB_CONNECT = 7

PULL_BIND = 0

PULL_CONNECT = 1

PUSH_BIND = 2

PUSH_CONNECT = 3

SUB_BIND = 4

SUB_CONNECT = 5

is_bind

paired

gnes.service.base.build_socket(ctx, host, port, socket_type, identity=None, use_ipc=False)

Return type:Tuple[Socket, str]

gnes.service.base.get_random_ipc()

Return type:str

gnes.service.base.send_ctrl_message(address, msg, timeout)