oc_connect
Loading...
Searching...
No Matches
comms.py File Reference

Go to the source code of this file.

Classes

class  oc_connect.comms.CommsMigrationError
class  oc_connect.comms.MigratedFile
class  oc_connect.comms.MigrationReport
class  oc_connect.comms.CommsBus

Namespaces

namespace  oc_connect
namespace  oc_connect.comms

Functions

str oc_connect.comms._encode (int value, int length)
str oc_connect.comms.new_ulid (datetime now, *, bytes|None entropy=None)
str oc_connect.comms.utc_stamp (datetime now)
str oc_connect.comms.message_filename (datetime now, str source, str ulid)
str oc_connect.comms.content_digest (bytes payload)
None oc_connect.comms._atomic_write (Path destination, bytes payload)
int oc_connect.comms._count_records (str name, bytes payload)
tuple[Path,...] oc_connect.comms._message_paths (Path directory)

Variables

str oc_connect.comms._CROCKFORD = "0123456789ABCDEFGHJKMNPQRSTVWXYZ"
str oc_connect.comms.OUTBOX_FILENAME = "outbox.json"
str oc_connect.comms.AUDIT_FILENAME = "audit.jsonl"