hub.py File Reference

Go to the source code of this file.

Classes
class	oc_orchestrator.hub.HubError
class	oc_orchestrator.hub.AddressError
class	oc_orchestrator.hub.KindError
class	oc_orchestrator.hub.ProvenanceError
class	oc_orchestrator.hub.CarrierError
class	oc_orchestrator.hub.UnknownAskError
class	oc_orchestrator.hub.Provenance
class	oc_orchestrator.hub.HubMessage
class	oc_orchestrator.hub.HubEntry
class	oc_orchestrator.hub.DeliveryReceipt
class	oc_orchestrator.hub.HubLog
class	oc_orchestrator.hub.Carrier
class	oc_orchestrator.hub.Hub

Namespaces
namespace	oc_orchestrator
namespace	oc_orchestrator.hub

Functions
str	oc_orchestrator.hub._encode (int value, int length)
str	oc_orchestrator.hub.new_ulid (datetime now, *, bytes|None entropy=None)
str	oc_orchestrator.hub._now_iso ()
str	oc_orchestrator.hub.parse_address (str value)
None	oc_orchestrator.hub.check_kind (str kind)
str|None	oc_orchestrator.hub._optional_str (object value)
HubMessage	oc_orchestrator.hub.new_message (*, str kind, str sender, str recipient, str body, Provenance provenance, str|None subject=None, str|None in_reply_to=None, str|None requires=None, str|None answer=None, datetime|None now=None, bytes|None entropy=None)
None	oc_orchestrator.hub.check_ruling_provenance (HubMessage ask, HubMessage ruling)

Variables
str	oc_orchestrator.hub.ADDRESS_ORCHESTRATOR = "orchestrator"
str	oc_orchestrator.hub.ADDRESS_OPERATOR_LOCAL = "operator@local"
str	oc_orchestrator.hub.ADDRESS_OPERATOR_REMOTE = "operator@remote"
tuple	oc_orchestrator.hub.FIXED_ADDRESSES
str	oc_orchestrator.hub.KIND_DISPATCH = "dispatch"
str	oc_orchestrator.hub.KIND_REPORT = "report"
str	oc_orchestrator.hub.KIND_ALERT = "alert"
str	oc_orchestrator.hub.KIND_ASK = "ask"
str	oc_orchestrator.hub.KIND_RULING = "ruling"
str	oc_orchestrator.hub.KIND_INSTRUCTION = "instruction"
frozenset	oc_orchestrator.hub.SUPPORTED_KINDS
str	oc_orchestrator.hub.REQUIRES_HUMAN = "human"
str	oc_orchestrator.hub.REQUIRES_ORCHESTRATOR = "orchestrator"
tuple	oc_orchestrator.hub.SUPPORTED_REQUIRES = (REQUIRES_HUMAN, REQUIRES_ORCHESTRATOR)
tuple	oc_orchestrator.hub.RULING_ANSWERS = ("YES", "NO", "ACK", "HOLD")
tuple	oc_orchestrator.hub.ACTOR_TYPES
tuple	oc_orchestrator.hub.CHANNELS = ("session", "cli", "lane", "telegram")
tuple	oc_orchestrator.hub.HUMAN_CHANNELS = ("cli", "telegram")
str	oc_orchestrator.hub.HUMAN_ACTOR_TYPE = "human_operator"
str	oc_orchestrator.hub.CROCKFORD_ALPHABET = "0123456789ABCDEFGHJKMNPQRSTVWXYZ"