app

type APIConfig struct {
	Environment config.Env        `json:"environment"`
	HTTP        config.HTTP       `json:"http"`
	DB          RuntimeDB         `json:"db"`
	Log         config.Log        `json:"log"`
	Modules     config.Namespaces `json:"modules"`
}

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

type BootOption func(*bootOpts)

type Booted struct {
	Kernel     *kernel.Kernel
	Router     *httpx.Router
	Events     *outbox.HandlerRegistry // event subscriptions (drives the relay)
	Jobs       *jobs.Registry          // job kinds (drives the worker pools)
	OpenAPI    map[string][]byte
	Health     map[string]func(context.Context) error
	Migrations map[string]fs.FS
	Seeds      seeds.Bundle   // merged catalog seeds, ready for SeedSync
	Recurring  []RecurringJob // module-registered recurring jobs (run by the worker scheduler)
	// I18n is the merged message catalog (framework English + every module's
	// localized bundles). Pass it to httpx.Locale so responses negotiate and
	// localize (GAP-001). Never nil — at minimum it carries the framework's
	// English catalog.
	I18n *i18n.Catalog
}

type Hook struct {
	// Name is used in log messages; should be short and unique within a run.
	Name string
	// Start launches background work and must return promptly (not block for
	// the component's lifetime). The ctx is the run context; components should
	// respect its cancellation on their own internal paths.
	Start func(ctx context.Context) error
	// Stop performs a graceful shutdown. nil means nothing to stop. Stop
	// receives a fresh context bounded by the stopTimeout, independent of
	// the (already-cancelled) run context.
	Stop func(ctx context.Context) error
}

type MigrateConfig struct {
	Environment config.Env `json:"environment"`
	DB          MigrateDB  `json:"db_migrate"`
	Log         config.Log `json:"log"`
}

type MigrateDB struct {
	DSN config.Secret `json:"dsn"`
	config.Pool
}

type RecurringJob struct {
	Name  string
	Every time.Duration
	Run   func(ctx context.Context, db database.TenantDB) error
}

type RuntimeDB struct {
	DSN         config.Secret `json:"dsn"`
	config.Pool               // flattens: max_conns, query_timeout, …
}

type WorkerConfig struct {
	Environment config.Env        `json:"environment"`
	DB          RuntimeDB         `json:"db"`
	Log         config.Log        `json:"log"`
	Modules     config.Namespaces `json:"modules"`
}

type WorkerConfigOpts struct {
	RelayBatch    int
	RelayPoll     time.Duration
	JobPoll       time.Duration
	JobPoolSize   int
	ShutdownDrain time.Duration
	// Scheduler (leader-safe kernel maintenance sweeps). Zero values use defaults.
	SchedulerPoll        time.Duration // how often to check for due tasks (default 30s)
	SLAInterval          time.Duration // workflow SLA sweep interval (default 1m)
	IdempotencyInterval  time.Duration // idempotency-key expiry sweep interval (default 1h)
	DLQDepthInterval     time.Duration // dlq_depth gauge refresh interval (default 1m)
	AuditAnchorInterval  time.Duration // audit-chain anchor-export interval (default 1h)
	NotifySendInterval   time.Duration // notify send/retry poll interval (default 1m)
	WebhookRetryInterval time.Duration // webhook retry + inbound poll interval (default 1m)
}