repositories
loading repo index
repositories
loading repo index
repository
loading code, commits, and activity
Mirrored from https://github.com/yingqi-z20/Agent-libOS
stars
latest
clone command
git clone gitlawb://did:key:z6MkqRzA...RfoM/yingqi-z20-Agen...git clone gitlawb://did:key:z6MkqRzA.../yingqi-z20-Agen...d98dd2c9IPC1d ago| from __future__ import annotations |
| #2 |
| #3 | from dataclasses import dataclass, field |
| #4 | from typing import Any |
| #5 |
| #6 | from agent_libos.models.base import PID, ProcessMessageID, StrEnum |
| #7 |
| #8 |
| #9 | class ProcessMessageKind(StrEnum): |
| #10 | NORMAL = "normal" |
| #11 | INTERRUPT = "interrupt" |
| #12 |
| #13 |
| #14 | class ProcessMessageStatus(StrEnum): |
| #15 | UNREAD = "unread" |
| #16 | ACKED = "acked" |
| #17 |
| #18 |
| #19 | @dataclass |
| #20 | class ProcessMessage: |
| #21 | message_id: ProcessMessageID |
| #22 | sender: str |
| #23 | recipient_pid: PID |
| #24 | kind: ProcessMessageKind |
| #25 | subject: str |
| #26 | body: str |
| #27 | channel: str = "default" |
| #28 | correlation_id: str | None = None |
| #29 | reply_to: ProcessMessageID | None = None |
| #30 | payload: dict[str, Any] = field(default_factory=dict) |
| #31 | status: ProcessMessageStatus = ProcessMessageStatus.UNREAD |
| #32 | created_at: str = "" |
| #33 | updated_at: str = "" |
| #34 | acked_at: str | None = None |
| #35 |