Versions in this module Expand all Collapse all v0 v0.2.0 Apr 9, 2026 v0.1.1 Apr 8, 2026 v0.1.0 Apr 8, 2026 Changes in this version + type AgentFatalEvent struct + Reason string + func NewAgentFatal(id string, at time.Time, reason string) AgentFatalEvent + func (AgentFatalEvent) EventType() Type + func (e AgentFatalEvent) ProcessID() string + func (e AgentFatalEvent) Timestamp() time.Time + type BackpressureStallEvent struct + DroppedMsgs int + Endpoint string + WALSize uint64 + WALSizeMax uint64 + func NewBackpressureStall(id string, at time.Time, endpoint string, size, sizeMax uint64, dropped int) BackpressureStallEvent + func (BackpressureStallEvent) EventType() Type + func (e BackpressureStallEvent) ProcessID() string + func (e BackpressureStallEvent) Timestamp() time.Time + type Bus interface + Publish func(e Event) + Subscribe func(filter Filter) Subscription + type CrashContext struct + AgentExit int + AgentSig int + ChildExit int + ChildSig int + Reason string + Source string + type Event interface + EventType func() Type + ProcessID func() string + Timestamp func() time.Time + type Filter struct + ProcessIDs []string + Types []Type + func (f Filter) Matches(e Event) bool + type LogChunkEvent struct + Size int + Stream uint8 + func NewLogChunk(id string, at time.Time, stream uint8, size int) LogChunkEvent + func (LogChunkEvent) EventType() Type + func (e LogChunkEvent) ProcessID() string + func (e LogChunkEvent) Timestamp() time.Time + type LogOverflowEvent struct + Reason string + func NewLogOverflow(id string, at time.Time, reason string) LogOverflowEvent + func (LogOverflowEvent) EventType() Type + func (e LogOverflowEvent) ProcessID() string + func (e LogOverflowEvent) Timestamp() time.Time + type ProcessCrashedEvent struct + CrashContext CrashContext + NextAttemptIn time.Duration + WillRestart bool + func NewProcessCrashed(id string, at time.Time, c CrashContext, willRestart bool, ...) ProcessCrashedEvent + func (ProcessCrashedEvent) EventType() Type + func (e ProcessCrashedEvent) ProcessID() string + func (e ProcessCrashedEvent) Timestamp() time.Time + type ProcessStartedEvent struct + AgentPID int + ChildPID int + func NewProcessStarted(id string, at time.Time, agentPID, childPID int) ProcessStartedEvent + func (ProcessStartedEvent) EventType() Type + func (e ProcessStartedEvent) ProcessID() string + func (e ProcessStartedEvent) Timestamp() time.Time + type ProcessStartingEvent struct + func NewProcessStarting(id string, at time.Time) ProcessStartingEvent + func (ProcessStartingEvent) EventType() Type + func (e ProcessStartingEvent) ProcessID() string + func (e ProcessStartingEvent) Timestamp() time.Time + type ProcessStoppedEvent struct + ExitCode int + func NewProcessStopped(id string, at time.Time, exitCode int) ProcessStoppedEvent + func (ProcessStoppedEvent) EventType() Type + func (e ProcessStoppedEvent) ProcessID() string + func (e ProcessStoppedEvent) Timestamp() time.Time + type Subscription interface + Close func() error + Events func() <-chan Event + type Type string + const TypeAgentDisconnected + const TypeAgentFatal + const TypeAgentSpawned + const TypeBackpressureStall + const TypeLogChunk + const TypeLogFileRef + const TypeLogOverflow + const TypeProcessCrashed + const TypeProcessFailed + const TypeProcessRegistered + const TypeProcessRestarting + const TypeProcessStarted + const TypeProcessStarting + const TypeProcessStopped + const TypeProcessStopping + const TypeShutdownIncomplete + const TypeShutdownRequested
Go to main page