manager

type Bootstrap struct {
	config.Store
	// contains filtered or unexported fields
}

type InitProvider interface {
	Init(ctx context.Context, store kv.Values) error
}

type Manager interface {
	Context() context.Context
	Registry() registry.Registry
	SOTWRegistry() registry.Registry
	ServeAll(...server.ServeOption) error
	StopAll()
	SetServeOptions(...server.ServeOption)
	WatchServicesConfigs()
	WatchBroker(ctx context.Context, br broker.Broker) error

	Bootstrap(string) error
	// RegisterBootstrapTemplate(typ string, data string) error
	RegisterStorage(scheme string, options ...controller.Option[storage.Storage])
	RegisterConfig(scheme string, config ...controller.Option[*openurl.Pool[config.Store]])
	RegisterQueue(scheme string, opts ...controller.Option[broker.AsyncQueuePool])
	RegisterCache(scheme string, opts ...controller.Option[*openurl.Pool[cache.Cache]])

	GetRootID() string
	GetStorage(ctx context.Context, name string, out any) error
	GetQueue(ctx context.Context, name string, resolutionData map[string]interface{}, openerID string, openerFunc broker.OpenWrapper) (broker.AsyncQueue, func() (bool, error), error)
	GetQueuePool(name string) (broker.AsyncQueuePool, error)
	GetCache(ctx context.Context, name string, resolutionData map[string]interface{}) (cache.Cache, error)
}

type ResolveOption func(*ResolveOptions)

type ResolveOptions struct {
	Name             string
	CleanBeforeClose bool
}

type Viper struct {
	*viper.Viper
}