Versions in this module Expand all Collapse all v0 v0.0.1 Jan 13, 2026 Changes in this version + const DomainTypeActionLog + const DomainTypePipelineBuildResult + const DomainTypePipelineLaunchPlan + const DomainTypePipelinePhaseFinished + const DomainTypePipelinePhaseStarted + const DomainTypePipelinePrepareResult + const DomainTypePipelineRunFinished + const DomainTypePipelineRunStarted + const DomainTypePipelineValidateResult + const DomainTypeServiceExit + const DomainTypeStateSnapshot + const DomainTypeStreamEnded + const DomainTypeStreamEvent + const DomainTypeStreamStarted + const TopicDevctlEvents + const TopicUIActions + const TopicUIMessages + const UITypeActionRequest + const UITypeEventAppend + const UITypePipelineBuildResult + const UITypePipelineLaunchPlan + const UITypePipelinePhaseFinished + const UITypePipelinePhaseStarted + const UITypePipelinePrepareResult + const UITypePipelineRunFinished + const UITypePipelineRunStarted + const UITypePipelineValidateResult + const UITypeStateSnapshot + const UITypeStreamEnded + const UITypeStreamEvent + const UITypeStreamStartRequest + const UITypeStreamStarted + const UITypeStreamStopRequest + func PublishAction(pub message.Publisher, req ActionRequest) error + func PublishStreamStart(pub message.Publisher, req StreamStartRequest) error + func PublishStreamStop(pub message.Publisher, req StreamStopRequest) error + func RegisterDomainToUITransformer(bus *Bus) + func RegisterUIActionRunner(tuiCtx context.Context, bus *Bus, opts RootOptions) + func RegisterUIForwarder(bus *Bus, p *tea.Program) + func RegisterUIStreamRunner(tuiCtx context.Context, bus *Bus, opts RootOptions) + type ActionKind string + const ActionDown + const ActionRestart + const ActionStop + const ActionUp + type ActionLog struct + At time.Time + Text string + type ActionRequest struct + At time.Time + Kind ActionKind + Service string + type ActionRequestMsg struct + Request ActionRequest + type Bus struct + Publisher message.Publisher + Router *message.Router + Subscriber message.Subscriber + func NewInMemoryBus() (*Bus, error) + func (b *Bus) AddHandler(name, topic string, handler func(*message.Message) error) + func (b *Bus) Run(ctx context.Context) error + type ConfigPatch struct + Key string + Plugin string + Value string + type Envelope struct + Payload json.RawMessage + Type string + func NewEnvelope(typ string, payload any) (Envelope, error) + func (e Envelope) MarshalJSONBytes() ([]byte, error) + type EventLogAppendMsg struct + Entry EventLogEntry + type EventLogEntry struct + At time.Time + Level LogLevel + Source string + Text string + type HealthCheckResult struct + CheckType string + Endpoint string + Error string + LastCheck time.Time + ResponseMs int64 + ServiceName string + Status HealthStatus + type HealthStatus string + const HealthHealthy + const HealthUnhealthy + const HealthUnknown + type LogLevel string + const LogLevelDebug + const LogLevelError + const LogLevelInfo + const LogLevelWarn + type NavigateBackMsg struct + type NavigateToServiceMsg struct + Name string + type PipelineBuildResult struct + Artifacts map[string]string + At time.Time + RunID string + Steps []PipelineStepResult + type PipelineBuildResultMsg struct + Result PipelineBuildResult + type PipelineConfigPatches struct + Patches []ConfigPatch + RunID string + type PipelineConfigPatchesMsg struct + Patches PipelineConfigPatches + type PipelineLaunchPlan struct + At time.Time + RunID string + Services []string + type PipelineLaunchPlanMsg struct + Plan PipelineLaunchPlan + type PipelineLiveOutput struct + Line string + RunID string + Source string + Stream string + type PipelineLiveOutputMsg struct + Output PipelineLiveOutput + type PipelinePhase string + const PipelinePhaseBuild + const PipelinePhaseLaunchPlan + const PipelinePhaseMutateConfig + const PipelinePhasePrepare + const PipelinePhaseRemoveState + const PipelinePhaseStateSave + const PipelinePhaseStopSupervise + const PipelinePhaseSupervise + const PipelinePhaseValidate + type PipelinePhaseFinished struct + At time.Time + DurationMs int64 + Error string + Ok bool + Phase PipelinePhase + RunID string + type PipelinePhaseFinishedMsg struct + Event PipelinePhaseFinished + type PipelinePhaseStarted struct + At time.Time + Phase PipelinePhase + RunID string + type PipelinePhaseStartedMsg struct + Event PipelinePhaseStarted + type PipelinePrepareResult struct + Artifacts map[string]string + At time.Time + RunID string + Steps []PipelineStepResult + type PipelinePrepareResultMsg struct + Result PipelinePrepareResult + type PipelineRunFinished struct + At time.Time + DurationMs int64 + Error string + Kind ActionKind + Ok bool + RepoRoot string + RunID string + type PipelineRunFinishedMsg struct + Run PipelineRunFinished + type PipelineRunStarted struct + At time.Time + Kind ActionKind + Phases []PipelinePhase + RepoRoot string + RunID string + type PipelineRunStartedMsg struct + Run PipelineRunStarted + type PipelineStepProgressMsg struct + Percent int + RunID string + Step string + type PipelineStepResult struct + DurationMs int64 + Name string + Ok bool + ProgressPercent int + type PipelineValidateResult struct + At time.Time + Errors []protocol.Error + RunID string + Valid bool + Warnings []protocol.Error + type PipelineValidateResultMsg struct + Result PipelineValidateResult + type PluginIntrospectionRefreshMsg struct + type PluginSummary struct + CapEnd time.Time + CapError string + CapStart time.Time + CapStatus string + Commands []string + ID string + Ops []string + Path string + Priority int + Protocol string + Status string + Streams []string + type RootOptions struct + Config string + DryRun bool + RepoRoot string + Strict bool + Timeout time.Duration + type ServiceExitObserved struct + Name string + PID int + Reason string + When time.Time + type StateSnapshot struct + Alive map[string]bool + At time.Time + Error string + Exists bool + Health map[string]*HealthCheckResult + Plugins []PluginSummary + ProcessStats map[int]*proc.Stats + RepoRoot string + State *state.State + type StateSnapshotMsg struct + Snapshot StateSnapshot + type StateWatcher struct + Interval time.Duration + Pub message.Publisher + RepoRoot string + func (w *StateWatcher) RequestIntrospection() + func (w *StateWatcher) Run(ctx context.Context) error + type StreamEnded struct + At time.Time + Error string + Ok bool + Op string + PluginID string + StreamID string + StreamKey string + type StreamEndedMsg struct + End StreamEnded + type StreamEvent struct + At time.Time + Event protocol.Event + Op string + PluginID string + StreamID string + StreamKey string + type StreamEventMsg struct + Event StreamEvent + type StreamStartRequest struct + Input map[string]any + Label string + Op string + PluginID string + type StreamStartRequestMsg struct + Request StreamStartRequest + type StreamStarted struct + At time.Time + Op string + PluginID string + StreamID string + StreamKey string + type StreamStartedMsg struct + Stream StreamStarted + type StreamStopRequest struct + StreamKey string + type StreamStopRequestMsg struct + Request StreamStopRequest