morphogenesis_observer_main

Dedicated, credential-minimal Stage 6A morphogenesis observer process.

class morphogenesis_observer_main.RedisTLSSettings(ca_cert, client_cert, client_key, verify=True, connect_timeout_seconds=5.0, read_timeout_seconds=15.0, health_check_interval_seconds=30.0)

Bases: object

Mandatory verified mTLS and finite connection timing policy.

Parameters:

ca_cert (str)
client_cert (str)
client_key (str)
verify (Literal[True])
connect_timeout_seconds (float)
read_timeout_seconds (float)
health_check_interval_seconds (float)

ca_cert: str

client_cert: str

client_key: str

verify: Literal[True]

connect_timeout_seconds: float

read_timeout_seconds: float

health_check_interval_seconds: float

class morphogenesis_observer_main.DirectRedisTopology(url, db, mode='direct')

Bases: object

One canonical direct TLS endpoint with credentials embedded in its URL.

Parameters:

url (str)
db (int)
mode (Literal['direct'])

url: str

db: int

mode: Literal['direct']

class morphogenesis_observer_main.SentinelRedisTopology(endpoints, service_name, sentinel_acl_username, sentinel_acl_password, data_acl_username, data_acl_password, db=0, mode='sentinel')

Bases: object

Sentinel discovery plus distinct Sentinel and data ACL identities.

Parameters:

endpoints (tuple[tuple[str, int], ...])
service_name (str)
sentinel_acl_username (str)
sentinel_acl_password (str)
data_acl_username (str)
data_acl_password (str)
db (int)
mode (Literal['sentinel'])

endpoints: tuple[tuple[str, int], ...]

service_name: str

sentinel_acl_username: str

sentinel_acl_password: str

data_acl_username: str

data_acl_password: str

db: int

mode: Literal['sentinel']

class morphogenesis_observer_main.MorphogenesisObserverRuntimeSettings(enabled, observe_only, redis_topology, redis_tls, retention_seconds, evidence_horizon_seconds, batch_size, poll_seconds, max_history_rows, source_stream='sg:stream:inbound', source_start_id='$')