di

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

type CircuitBreakerConfig struct {
	FailureThreshold  int
	RecoveryTimeoutMs int
	HalfOpenRequests  int
}

type CircuitState int

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

type Container interface {
	Register(key string, constructor interface{}) error
	RegisterLazy(key string, constructor interface{}, options ...LazyOption) error
	RegisterEager(key string, constructor interface{}) error
	Resolve(key string) (interface{}, error)
	RegisterSingleton(key string, instance interface{}) error
	Close() error

	// Introspection
	Registrations() []RegistrationInfo

	// Legacy methods for backward compatibility
	InvalidateCache(name string) error
	Refresh(name string) (interface{}, error)
	GetResolver(name string) func() (interface{}, error)
	MustResolve(name string) interface{}
}

type LazyOption func(*ComponentRegistration)

type PkgNames struct {
	// Core infrastructure
	Config           string
	Logger           string
	Database         string
	Redis            string
	Storage          string
	Workload         string
	ServiceRegistry  string
	ServiceDiscovery string

	// HTTP/gRPC servers
	HTTPServer    string
	GRPCServer    string
	UnifiedServer string

	// Messaging
	KafkaProducer      string
	KafkaConsumer      string
	KafkaConsumerGroup string

	// Real-time
	SSEHub string
}

type RegistrationInfo struct {
	Key         string
	Mode        RegistrationMode // Eager, Lazy, or Singleton
	Initialized bool
}

type RegistrationMode int

type RetryPolicy struct {
	MaxAttempts       int
	InitialBackoffMs  int
	MaxBackoffMs      int
	BackoffMultiplier float64
}

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