Documentation
¶
Overview ¶
Package events defines the Dejima event model and the webhook delivery manager. Events are emitted by the daemon (lifecycle, container, presence) and by per-agent shims via the internal agent-event endpoint.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event struct {
Type Type `json:"type"`
Island string `json:"island,omitempty"`
// Agent is the agent within the island this event concerns (empty for
// island-level events or agents that don't identify themselves).
Agent string `json:"agent,omitempty"`
Timestamp time.Time `json:"timestamp"`
Payload map[string]any `json:"payload,omitempty"`
}
Event is the JSON envelope POSTed to webhook subscribers.
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager fans out events to subscribed webhooks.
func (*Manager) List ¶
func (m *Manager) List() []Subscription
List returns every subscription with its HMAC secret redacted — secrets are write-only from a client's perspective and never travel back out.
func (*Manager) Subscribe ¶
func (m *Manager) Subscribe(s Subscription) (Subscription, error)
Subscribe adds a webhook subscription. The returned Subscription includes a generated ID.
func (*Manager) Unsubscribe ¶
Unsubscribe removes a subscription by ID.
type Subscription ¶
type Subscription struct {
ID string `json:"id"`
URL string `json:"url"`
Secret string `json:"secret,omitempty"` // HMAC-signs payloads if non-empty
Events []Type `json:"events,omitempty"` // empty = all
CreatedAt time.Time `json:"created_at"`
}
Subscription is a registered webhook.
type Type ¶
type Type string
Type is a stable event identifier suitable for subscriber filtering.
const ( TypeIslandCreated Type = "island.created" TypeIslandRunning Type = "island.running" TypeIslandHibernated Type = "island.hibernated" TypeIslandWoken Type = "island.woken" TypeIslandReset Type = "island.reset" TypeIslandUpgraded Type = "island.upgraded" TypeIslandPurged Type = "island.purged" TypeIslandAgentAdded Type = "island.agent-added" TypeIslandAgentRemoved Type = "island.agent-removed" TypeContainerCrashed Type = "container.crashed" TypeDaemonStarted Type = "daemon.started" TypePanicEngaged Type = "daemon.panic-engaged" TypePanicCleared Type = "daemon.panic-cleared" TypeClientAttached Type = "client.attached" TypeClientDetached Type = "client.detached" TypeLastClientDetached Type = "last-client.detached" // Agent-emitted events (via per-agent shims; opt-in). TypeAgentWaitingForInput Type = "agent.waiting-for-input" TypeAgentTaskComplete Type = "agent.task-complete" TypeAgentError Type = "agent.error" // Inter-island action delegation (Lane 5, Phase 3): a cross-island action // needs operator approval. Fires so an operator can approve/deny from a phone // notification; the payload carries from/to islands + the action type. TypeLinkActionPending Type = "link.action-pending" // Mailbox arrival (Lane 5, Phase 3.5): a message landed in an agent's mailbox. // The wake-on-message seam — Dejima's default soft-notify acts on it, and a // wrapper can subscribe to implement its own routing/priority. Payload carries // island/agent and cross_island/action flags (never the message body). TypeMailboxArrival Type = "mailbox.arrival" )
Daemon-observable events (always agnostic).
func KnownTypes ¶
func KnownTypes() []Type
KnownTypes returns the catalog of subscribable event types (a copy).
Source Files