lifecycle

Documentation

Overview

Package lifecycle manages background maintenance tasks: session reaping, terminal execution cleanup, timeout enforcement, and startup recovery.

Index

• type Deps
• type EventEmitter
• type Manager
  • func NewManager(d Deps) *Manager
  • func (m *Manager) RecoverActiveExecutions(ctx context.Context)
  • func (m *Manager) StartCleanup(ctx context.Context, retentionPeriod, interval time.Duration)
  • func (m *Manager) StartSessionReaper(ctx context.Context)
  • func (m *Manager) StartTimeoutWatcher(ctx context.Context)

Types

type Deps

type Deps struct {
	Events           store.EventStore
	Sessions         store.SessionStore
	Checkpoints      store.CheckpointStore
	Signals          store.SignalStore
	AgentHub         store.AgentHub
	Locker           store.Locker
	Projector        *projector.Projector
	Emitter          EventEmitter
	Logger           *slog.Logger
	ExecutionTimeout time.Duration
}

type EventEmitter

type EventEmitter interface {
	EmitEvent(
		ctx context.Context,
		executionID string,
		stepID string,
		eventType domain.EventType,
		payload any,
		causationID uuid.UUID,
		correlationID uuid.UUID,
	) (domain.Event, error)
}

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(d Deps) *Manager

func (*Manager) RecoverActiveExecutions

func (m *Manager) RecoverActiveExecutions(ctx context.Context)

func (*Manager) StartCleanup

func (m *Manager) StartCleanup(ctx context.Context, retentionPeriod, interval time.Duration)

func (*Manager) StartSessionReaper

func (m *Manager) StartSessionReaper(ctx context.Context)

func (*Manager) StartTimeoutWatcher

func (m *Manager) StartTimeoutWatcher(ctx context.Context)