events

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 27, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package events owns canonical runtime event names and metadata shared by producers, logs, notifications, and contract tests.

Index

Constants

View Source
const (
	ComponentBridge       = "bridge"
	ComponentConfig       = "config"
	ComponentHarness      = "harness"
	ComponentHook         = "hook"
	ComponentMemory       = "memory"
	ComponentNetwork      = "network"
	ComponentExtension    = "extension"
	ComponentProvider     = "provider"
	ComponentScheduler    = "scheduler"
	ComponentSession      = "session"
	ComponentSkill        = "skill"
	ComponentTask         = "task"
	ComponentTools        = "tools"
	ComponentTranscript   = "transcript"
	ComponentNotification = "notification"
)
View Source
const (
	ACPUserMessage      = "user_message"
	ACPSyntheticReentry = "synthetic_reentry"
	ACPAgentMessage     = "agent_message"
	ACPThought          = "thought"
	ACPToolCall         = "tool_call"
	ACPToolResult       = "tool_result"
	ACPPlan             = "plan"
	ACPPermission       = "permission"
	ACPUsage            = "usage"
	ACPSystem           = "system"
	ACPRuntimeProgress  = "runtime_progress"
	ACPRuntimeWarning   = "runtime_warning"
	ACPDone             = "done"
	ACPError            = "error"
	SessionStopped      = "session_stopped"
	SessionUnhealthy    = "session.unhealthy"
	SessionHung         = "session.hung"
	SessionRecovered    = "session.recovered"

	TaskCreated                 = "task.created"
	TaskUpdated                 = "task.updated"
	TaskPublished               = "task.published"
	TaskApproved                = "task.approved"
	TaskRejected                = "task.rejected"
	TaskCanceled                = "task.canceled"
	TaskChildCreated            = "task.child_created"
	TaskDependencyAdded         = "task.dependency_added"
	TaskDependencyRemoved       = "task.dependency_removed"
	TaskPaused                  = "task.paused"
	TaskResumed                 = "task.resumed"
	TaskRunEnqueued             = "task.run_enqueued"
	TaskRunClaimed              = "task.run_claimed"
	TaskRunStarting             = "task.run_starting"
	TaskRunSessionBound         = "task.run_session_bound"
	TaskRunStarted              = "task.run_started"
	TaskRunCompleted            = "task.run_completed"
	TaskRunFailed               = "task.run_failed"
	TaskRunCanceled             = "task.run_canceled"
	TaskRunForceStopped         = "task.run_force_stopped"
	TaskRunRecovered            = "task.run_recovered"
	TaskRunRejected             = "task.run_rejected"
	TaskRunLeaseExtended        = "task.run_lease_extended"
	TaskRunLeaseExpired         = "task.run_lease_expired"
	TaskRunReleased             = "task.run_released"
	TaskRunOperatorForcedFail   = "task.run_operator_forced_fail"
	TaskRunOperatorRetry        = "task.run_operator_retry"
	TaskExecutionProfileUpdated = "task.execution_profile_updated"
	TaskExecutionProfileDeleted = "task.execution_profile_deleted"
	TaskRunReviewRequested      = "task.run_review_requested"
	TaskRunReviewBound          = "task.run_review_bound"
	TaskRunReviewRecorded       = "task.run_review_recorded"
	TaskRunReviewApproved       = "task.run_review_approved"
	TaskRunReviewRejected       = "task.run_review_rejected"
	TaskRunReviewBlocked        = "task.run_review_blocked"
	TaskRunReviewError          = "task.run_review_error"
	TaskRunReviewTimeout        = "task.run_review_timeout"
	TaskRunReviewInvalidOutput  = "task.run_review_invalid_output"
	TaskRunReviewRetryEnqueued  = "task.run_review_retry_enqueued"

	SettingsChanged = "settings.changed"

	SkillShadowed   = "skill.shadowed"
	SkillLoadFailed = "skills.load_failed"

	HookDispatchStart    = "hook.dispatch.start"
	HookDispatchComplete = "hook.dispatch.complete"

	HarnessContextResolved         = "harness.context_resolved"
	HarnessSectionSelected         = "harness.section_selected"
	HarnessAugmenterApplied        = "harness.augmenter_applied"
	HarnessAugmenterFailed         = "harness.augmenter_failed"
	HarnessDetachedRunCompleted    = "harness.detached_run_completed"
	HarnessSyntheticReentryEmitted = "harness.synthetic_reentry_emitted"
	HarnessSyntheticReentryDropped = "harness.synthetic_reentry_dropped"

	MemoryWriteCommitted     = "memory.write.committed"
	MemoryWriteRejected      = "memory.write.rejected"
	MemoryWriteShadowed      = "memory.write.shadowed"
	MemoryWriteReindex       = "memory.write.reindex"
	MemoryWriteReverted      = "memory.write.reverted"
	MemoryProviderCollision  = "memory.provider.collision"
	MemoryRecallExecuted     = "memory.recall.executed"
	MemoryRecallSkipped      = "memory.recall.skipped"
	MemoryRecallDropped      = "memory.recall.signal_dropped"
	MemoryRecallFailed       = "memory.recall.signal_update_failed"
	MemoryDecisionsSummary   = "memory.decisions.audit_summarized"
	MemoryDecisionsPruned    = "memory.decisions.pruned"
	MemoryDreamStarted       = "memory.dream.run.started"
	MemoryDreamPromoted      = "memory.dream.run.promoted"
	MemoryDreamFailed        = "memory.dream.run.failed"
	MemoryExtractorStarted   = "memory.extractor.started"
	MemoryExtractorComplete  = "memory.extractor.completed"
	MemoryExtractorFailed    = "memory.extractor.failed"
	MemoryExtractorCoalesced = "memory.extractor.coalesced"
	MemoryExtractorDropped   = "memory.extractor.dropped"
	MemoryDailyRotated       = "memory.daily.rotated"
	MemoryDailyArchived      = "memory.daily.archived"
	MemoryDailyRestored      = "memory.daily.restored"
	MemoryDailyPurged        = "memory.daily.purged"
	MemoryDailyArchivePurged = "memory.daily.archive_purged"
	MemoryProviderEnabled    = "memory.provider.enabled"
	MemoryProviderDisabled   = "memory.provider.disabled"
	MemoryWorkspaceRelocated = "memory.workspace.relocated"
	MemoryWorkspaceRecovered = "memory.workspace.recovered"
	MemoryAgentPurged        = "memory.agent.purged"
	MemoryMigrationApplied   = "memory.migration.applied"

	SchedulerPaused         = "scheduler.paused"
	SchedulerResumed        = "scheduler.resumed"
	SchedulerDrainStarted   = "scheduler.drain_started"
	SchedulerDrainCompleted = "scheduler.drain_completed"

	TranscriptMarkerCreated  = "transcript_marker.created"
	TranscriptMarkerRedacted = "transcript_marker.redacted"

	ToolCallStarted     = "tool.call_started"
	ToolCallCompleted   = "tool.call_completed"
	ToolCallFailed      = "tool.call_failed"
	ToolCallDenied      = "tool.call_denied"
	ToolResultTruncated = "tool.result_truncated"

	ProviderAuthRequired          = "provider.auth_required"
	ProviderAuthRecovered         = "provider.auth_recovered"
	ProviderRateLimited           = "provider.rate_limited"
	ProviderPermissionDenied      = "provider.permission_denied"
	ProviderUnavailable           = "provider.unavailable"
	ProviderModelCatalogRefreshed = "provider.model_catalog_refreshed"

	ExtensionInstalled = "extension.installed"
	ExtensionUpdated   = "extension.updated"
	ExtensionRemoved   = "extension.removed"
	ExtensionEnabled   = "extension.enabled"
	ExtensionDisabled  = "extension.disabled"

	BridgeNotificationSuppressed = "bridge_notification_suppressed"
	NetworkPeerJoined            = "network.peer.joined"
	NetworkPeerLeft              = "network.peer.left"

	NotificationPresetCreated        = "notification.preset_created"
	NotificationPresetUpdated        = "notification.preset_updated"
	NotificationPresetDeleted        = "notification.preset_deleted"
	NotificationPresetDispatchFailed = "notification.preset_dispatch_failed"
)

Variables

This section is empty.

Functions

func AllowsGlobalScope

func AllowsGlobalScope(name string) bool

AllowsGlobalScope reports whether a summary event may be emitted without a session.

func ComponentFor

func ComponentFor(name string) string

ComponentFor returns the registered component for an event name.

func NamesForComponent

func NamesForComponent(component string) []string

NamesForComponent returns canonical event names registered for component.

func NamesForOutcomes

func NamesForOutcomes(outcomes ...Outcome) []string

NamesForOutcomes returns canonical event names matching any requested outcome.

func ValidComponent

func ValidComponent(component string) bool

ValidComponent reports whether component is present in the registry.

func ValidOutcome

func ValidOutcome(value string) bool

ValidOutcome reports whether value is one of the canonical event outcomes.

func ValidatePublicName

func ValidatePublicName(name string) error

ValidatePublicName rejects deleted or unsupported public event families.

Types

type Metadata

type Metadata struct {
	Name                 string
	Family               string
	Component            string
	Outcome              Outcome
	EmitsToLogs          bool
	NotificationEligible bool
	GlobalScope          bool
}

Metadata is the canonical registry entry for one event name.

func All

func All() []Metadata

All returns all canonical registry entries sorted by event name.

func Lookup

func Lookup(name string) (Metadata, bool)

Lookup returns metadata for a canonical event name.

type Outcome

type Outcome string

Outcome classifies an event for log filtering and notification policy.

const (
	OutcomeInfo    Outcome = "info"
	OutcomeSuccess Outcome = "success"
	OutcomeFailure Outcome = "failure"
	OutcomeWarning Outcome = "warning"
)

func OutcomeFor

func OutcomeFor(name string) Outcome

OutcomeFor returns the registered outcome for an event name, defaulting to info.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL