gnes.service.base module¶
-
class
gnes.service.base.
BaseService
(args)[source]¶ Bases:
object
-
default_host
= '0.0.0.0'¶
-
handler
= <gnes.service.base.MessageHandler object>¶
-
status
¶
-
-
class
gnes.service.base.
MessageHandler
(mh=None)[source]¶ Bases:
object
-
class
gnes.service.base.
ParallelType
[source]¶ 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
[source]¶ Bases:
gnes.service.base.BetterEnum
An enumeration.
-
ALWAYS_ONE
= 1¶
-
CONCAT
= 0¶
-
-
class
gnes.service.base.
SocketType
[source]¶ 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
¶
-