registry

type CronScheduler interface {
	AddHandler(opts command.HandlerConfig, handler any) (cron.Subscription, error)
}

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

type RuntimeDependencies struct {
	Registry *command.Registry

	Dispatcher   any
	Router       *router.Mux
	Scheduler    CronScheduler
	Orchestrator any

	RunnerDefaults []runner.Option

	CronRegister func(opts command.HandlerConfig, handler any) error
	RPCRegister  func(opts command.RPCConfig, handler any, meta command.CommandMeta) error

	SubscribeCommand func(cmd any, opts ...runner.Option) (dispatcher.Subscription, error)
	SubscribeQuery   func(qry any, opts ...runner.Option) (dispatcher.Subscription, error)
}