config

package
v0.8.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 3, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SeverityError   = errors.SeverityError
	SeverityWarning = errors.SeverityWarning
	SeverityInfo    = errors.SeverityInfo
)
View Source 
const ConfigKey = shared.ConfigKey

ConfigKey is the service key for configuration manager.

View Source 
const ManagerKey = shared.ConfigKey

ManagerKey is the DI key for the config manager service.

Variables

View Source 
var (
	ErrConfigError     = errors.ErrConfigError
	ErrLifecycleError  = errors.ErrLifecycleError
	ErrValidationError = errors.ErrValidationError
)

Functions

func AllowEmpty 

func AllowEmpty() configcore.GetOption

AllowEmpty allows empty values.

func DiscoverAndLoadConfigs added in v0.4.0 

func DiscoverAndLoadConfigs(cfg AutoDiscoveryConfig) (ConfigManager, *AutoDiscoveryResult, error)

DiscoverAndLoadConfigs automatically discovers and loads config files.

func ExpandSecretReferences 

func ExpandSecretReferences(ctx context.Context, data map[string]interface{}, secretsManager SecretsManager) (map[string]interface{}, error)

ExpandSecretReferences expands secret references in configuration.

func ExtractSecretKey 

func ExtractSecretKey(reference string) string

ExtractSecretKey extracts the secret key from a reference.

func F added in v0.4.0 

func F(key string, value any) logger.Field

F is a helper function to create logger fields.

func GetConfigManager added in v0.5.0 

func GetConfigManager(container shared.Container) (core.ConfigManager, error)

GetConfigManager resolves the config manager from the container This is a convenience function for resolving the config manager service Uses ManagerKey constant (defined in manager.go) which equals shared.ConfigKey.

func GetConfigSearchInfo added in v0.4.0 

func GetConfigSearchInfo(appName string) string

GetConfigSearchInfo returns information about where configs would be searched Useful for debugging config loading issues.

func IsSecretReference 

func IsSecretReference(value string) bool

IsSecretReference checks if a value is a secret reference.

func WithCacheKey 

func WithCacheKey(key string) configcore.GetOption

WithCacheKey sets a custom cache key.

func WithDefault 

func WithDefault(value any) configcore.GetOption

WithDefault sets a default value.

func WithOnMissing 

func WithOnMissing(fn func(string) any) configcore.GetOption

WithOnMissing sets a callback for missing keys.

func WithRequired 

func WithRequired() configcore.GetOption

WithRequired marks the key as required.

func WithTransform 

func WithTransform(fn func(any) any) configcore.GetOption

WithTransform adds a transformation function.

func WithValidator 

func WithValidator(fn func(any) error) configcore.GetOption

WithValidator adds a validation function.

Types

type AutoDiscoveryConfig added in v0.4.0 

type AutoDiscoveryConfig struct {
	// AppName is the application name to look for in app-scoped configs
	// If provided, will look for "apps.{AppName}" section in config
	AppName string

	// SearchPaths are directories to search for config files
	// Defaults to current directory and parent directories
	SearchPaths []string

	// ConfigNames are the config file names to search for
	// Defaults to ["config.yaml", "config.yml"]
	ConfigNames []string

	// LocalConfigNames are the local override config file names
	// Defaults to ["config.local.yaml", "config.local.yml"]
	LocalConfigNames []string

	// MaxDepth is the maximum number of parent directories to search
	// Defaults to 5
	MaxDepth int

	// RequireBase determines if base config file is required
	// Defaults to false
	RequireBase bool

	// RequireLocal determines if local config file is required
	// Defaults to false
	RequireLocal bool

	// EnableAppScoping enables app-scoped config extraction
	// If true and AppName is set, will extract "apps.{AppName}" section
	// Defaults to true
	EnableAppScoping bool

	// Environment Variable Source Configuration
	// EnableEnvSource enables loading config from environment variables
	// Defaults to true
	EnableEnvSource bool

	// EnvPrefix is the prefix for environment variables
	// If empty, defaults to AppName uppercase with trailing underscore
	EnvPrefix string

	// EnvSeparator is the separator for nested keys in env vars
	// Defaults to "_"
	EnvSeparator string

	// EnvOverridesFile controls whether env vars override file config values
	// When true, env source gets higher priority than file sources
	// Defaults to true
	EnvOverridesFile bool

	// Logger for discovery operations
	Logger logger.Logger

	// ErrorHandler for error handling
	ErrorHandler shared.ErrorHandler
}

AutoDiscoveryConfig configures automatic config file discovery.

func DefaultAutoDiscoveryConfig added in v0.4.0 

func DefaultAutoDiscoveryConfig() AutoDiscoveryConfig

DefaultAutoDiscoveryConfig returns default auto-discovery configuration.

type AutoDiscoveryResult added in v0.4.0 

type AutoDiscoveryResult struct {
	// BaseConfigPath is the path to the base config file
	BaseConfigPath string

	// LocalConfigPath is the path to the local config file
	LocalConfigPath string

	// WorkingDirectory is the directory where configs were found
	WorkingDirectory string

	// IsMonorepo indicates if this is a monorepo layout
	IsMonorepo bool

	// AppName is the app name for app-scoped configs
	AppName string
}

AutoDiscoveryResult contains the result of config discovery.

type CachedSecret 

type CachedSecret struct {
	Value     string         `json:"value"`
	Metadata  SecretMetadata `json:"metadata"`
	ExpiresAt time.Time      `json:"expires_at"`
	Encrypted bool           `json:"encrypted"`
}

CachedSecret represents a cached secret.

type ChangeDetector 

type ChangeDetector interface {
	DetectChanges(old, new map[string]any) []ConfigChange
	CalculateChecksum(data map[string]any) string
}

ChangeDetector detects changes in configuration data.

type ChangeType 

type ChangeType = core.ChangeType

ChangeType represents the type of configuration change. 

const (
	ChangeTypeSet    ChangeType = core.ChangeTypeSet
	ChangeTypeUpdate ChangeType = core.ChangeTypeUpdate
	ChangeTypeDelete ChangeType = core.ChangeTypeDelete
	ChangeTypeReload ChangeType = core.ChangeTypeReload
)

type ConfigChange 

type ConfigChange = core.ConfigChange

ConfigChange represents a configuration change event.

type ConfigManager 

type ConfigManager = core.ConfigManager

ConfigManager interface (matches v2.ConfigManagerInterface).

func AutoLoadConfigManager added in v0.4.0 

func AutoLoadConfigManager(appName string, logger logger.Logger) (ConfigManager, error)

AutoLoadConfigManager automatically discovers and loads config files This is a convenience function that uses default settings.

func LoadConfigFromPaths added in v0.4.0 

func LoadConfigFromPaths(basePath, localPath, appName string, logger logger.Logger) (ConfigManager, error)

LoadConfigFromPaths is a helper that loads config from explicit paths Useful when you know exactly where your config files are.

func LoadConfigWithAppScope added in v0.4.0 

func LoadConfigWithAppScope(appName string, logger logger.Logger, errorHandler shared.ErrorHandler) (ConfigManager, error)

LoadConfigWithAppScope loads config with app-scoped extraction This is the recommended way to load configs in a monorepo environment.

func NewManager 

func NewManager(config ManagerConfig) ConfigManager

NewManager creates a new enhanced configuration manager.

func NewTestConfigManager 

func NewTestConfigManager() ConfigManager

NewTestConfigManager creates a new test configuration manager.

func NewTestConfigManagerWithData 

func NewTestConfigManagerWithData(data map[string]any) ConfigManager

NewTestConfigManagerWithData creates a test config manager with initial data.

type ConfigSource 

type ConfigSource = core.ConfigSource

ConfigSource represents a source of configuration data.

type ConfigSourceFactory 

type ConfigSourceFactory = core.ConfigSourceFactory

ConfigSourceFactory creates configuration sources.

type ConfigSourceOptions 

type ConfigSourceOptions = core.ConfigSourceOptions

ConfigSourceOptions contains options for creating a configuration source.

type ConstraintRule 

type ConstraintRule interface {
	Name() string
	Description() string
	Validate(key string, value any, config map[string]any) error
	AppliesTo(key string) bool
}

ConstraintRule defines a constraint that must be satisfied.

type DebounceWatcher 

type DebounceWatcher struct {
	*Watcher
	// contains filtered or unexported fields
}

DebounceWatcher wraps another watcher with debouncing functionality.

func NewDebounceWatcher 

func NewDebounceWatcher(config WatcherConfig, debounceTime time.Duration) *DebounceWatcher

NewDebounceWatcher creates a watcher with debouncing.

func (*DebounceWatcher) WatchSource 

func (dw *DebounceWatcher) WatchSource(ctx context.Context, source ConfigSource, callback WatchCallback) error

WatchSource starts watching with debouncing.

type DefaultChangeDetector 

type DefaultChangeDetector struct{}

DefaultChangeDetector is a simple implementation of ChangeDetector.

func (*DefaultChangeDetector) CalculateChecksum 

func (d *DefaultChangeDetector) CalculateChecksum(data map[string]any) string

func (*DefaultChangeDetector) DetectChanges 

func (d *DefaultChangeDetector) DetectChanges(old, new map[string]any) []ConfigChange

type DurationRule 

type DurationRule struct{}

func (*DurationRule) AppliesTo 

func (r *DurationRule) AppliesTo(key string) bool

func (*DurationRule) Name 

func (r *DurationRule) Name() string

func (*DurationRule) Validate 

func (r *DurationRule) Validate(key string, value any) error

type EmailRule 

type EmailRule struct{}

func (*EmailRule) AppliesTo 

func (r *EmailRule) AppliesTo(key string) bool

func (*EmailRule) Name 

func (r *EmailRule) Name() string

func (*EmailRule) Validate 

func (r *EmailRule) Validate(key string, value any) error

type EnvironmentSecretProvider 

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

EnvironmentSecretProvider provides secrets from environment variables.

func (*EnvironmentSecretProvider) Close 

func (esp *EnvironmentSecretProvider) Close(ctx context.Context) error

func (*EnvironmentSecretProvider) DeleteSecret 

func (esp *EnvironmentSecretProvider) DeleteSecret(ctx context.Context, key string) error

func (*EnvironmentSecretProvider) GetSecret 

func (esp *EnvironmentSecretProvider) GetSecret(ctx context.Context, key string) (string, error)

func (*EnvironmentSecretProvider) HealthCheck 

func (esp *EnvironmentSecretProvider) HealthCheck(ctx context.Context) error

func (*EnvironmentSecretProvider) Initialize 

func (esp *EnvironmentSecretProvider) Initialize(ctx context.Context, config map[string]interface{}) error

func (*EnvironmentSecretProvider) ListSecrets 

func (esp *EnvironmentSecretProvider) ListSecrets(ctx context.Context) ([]string, error)

func (*EnvironmentSecretProvider) Name 

func (esp *EnvironmentSecretProvider) Name() string

func (*EnvironmentSecretProvider) SetSecret 

func (esp *EnvironmentSecretProvider) SetSecret(ctx context.Context, key, value string) error

func (*EnvironmentSecretProvider) SupportsCaching 

func (esp *EnvironmentSecretProvider) SupportsCaching() bool

func (*EnvironmentSecretProvider) SupportsRotation 

func (esp *EnvironmentSecretProvider) SupportsRotation() bool

type FileSecretProvider 

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

FileSecretProvider provides secrets from files.

func (*FileSecretProvider) Close 

func (fsp *FileSecretProvider) Close(ctx context.Context) error

func (*FileSecretProvider) DeleteSecret 

func (fsp *FileSecretProvider) DeleteSecret(ctx context.Context, key string) error

func (*FileSecretProvider) GetSecret 

func (fsp *FileSecretProvider) GetSecret(ctx context.Context, key string) (string, error)

func (*FileSecretProvider) HealthCheck 

func (fsp *FileSecretProvider) HealthCheck(ctx context.Context) error

func (*FileSecretProvider) Initialize 

func (fsp *FileSecretProvider) Initialize(ctx context.Context, config map[string]interface{}) error

func (*FileSecretProvider) ListSecrets 

func (fsp *FileSecretProvider) ListSecrets(ctx context.Context) ([]string, error)

func (*FileSecretProvider) Name 

func (fsp *FileSecretProvider) Name() string

func (*FileSecretProvider) SetSecret 

func (fsp *FileSecretProvider) SetSecret(ctx context.Context, key, value string) error

func (*FileSecretProvider) SupportsCaching 

func (fsp *FileSecretProvider) SupportsCaching() bool

func (*FileSecretProvider) SupportsRotation 

func (fsp *FileSecretProvider) SupportsRotation() bool

type FileWatcher 

type FileWatcher interface {
	Watch(path string, callback func(string)) error
	Stop() error
}

FileWatcher represents a file system watcher.

type ForgeError 

type ForgeError = errors.ForgeError

Re-export error types and constructors for backward compatibility.

type HealthCall 

type HealthCall struct {
	Timestamp time.Time
	Error     error
	Healthy   bool
}

HealthCall represents a tracked health check.

type LifecycleCall 

type LifecycleCall struct {
	Timestamp time.Time
	Error     error
}

LifecycleCall represents a tracked lifecycle operation.

type ListCall 

type ListCall struct {
	Result    []string
	Timestamp time.Time
	Error     error
}

ListCall represents a tracked list operation.

type Manager 

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

Manager implements an enhanced configuration manager that extends ConfigManager.

func (*Manager) AllKeys 

func (m *Manager) AllKeys() []string

AllKeys is an alias for GetKeys.

func (*Manager) AllSettings 

func (m *Manager) AllSettings() map[string]any

AllSettings is an alias for GetAllSettings.

func (*Manager) Bind 

func (m *Manager) Bind(key string, target any) error

Bind binds configuration to a struct.

func (*Manager) BindWithDefault 

func (m *Manager) BindWithDefault(key string, target any, defaultValue any) error

BindWithDefault binds with a default value.

func (*Manager) BindWithOptions 

func (m *Manager) BindWithOptions(key string, target any, options configcore.BindOptions) error

BindWithOptions binds with flexible options.

func (*Manager) Clone 

func (m *Manager) Clone() ConfigManager

Clone creates a deep copy.

func (*Manager) ConfigFileUsed 

func (m *Manager) ConfigFileUsed() string

ConfigFileUsed returns the config file path.

func (*Manager) ExpandEnvVars 

func (m *Manager) ExpandEnvVars() error

ExpandEnvVars expands environment variables.

func (*Manager) Get 

func (m *Manager) Get(key string) any

Get returns a configuration value.

func (*Manager) GetAllSettings 

func (m *Manager) GetAllSettings() map[string]any

GetAllSettings returns all settings.

func (*Manager) GetBool 

func (m *Manager) GetBool(key string, defaultValue ...bool) bool

GetBool returns a bool value with optional default.

func (*Manager) GetBoolSlice 

func (m *Manager) GetBoolSlice(key string, defaultValue ...[]bool) []bool

GetBoolSlice returns a bool slice with optional default.

func (*Manager) GetBoolWithOptions 

func (m *Manager) GetBoolWithOptions(key string, opts ...configcore.GetOption) (bool, error)

GetBoolWithOptions returns a bool with advanced options.

func (*Manager) GetBytesSize 

func (m *Manager) GetBytesSize(key string, defaultValue ...uint64) uint64

GetBytesSize is an alias for GetSizeInBytes.

func (*Manager) GetDuration 

func (m *Manager) GetDuration(key string, defaultValue ...time.Duration) time.Duration

GetDuration returns a duration value with optional default.

func (*Manager) GetDurationWithOptions 

func (m *Manager) GetDurationWithOptions(key string, opts ...configcore.GetOption) (time.Duration, error)

GetDurationWithOptions returns a duration with advanced options.

func (*Manager) GetFloat32 

func (m *Manager) GetFloat32(key string, defaultValue ...float32) float32

GetFloat32 returns a float32 value with optional default.

func (*Manager) GetFloat64 

func (m *Manager) GetFloat64(key string, defaultValue ...float64) float64

GetFloat64 returns a float64 value with optional default.

func (*Manager) GetFloat64Slice 

func (m *Manager) GetFloat64Slice(key string, defaultValue ...[]float64) []float64

GetFloat64Slice returns a float64 slice with optional default.

func (*Manager) GetInt 

func (m *Manager) GetInt(key string, defaultValue ...int) int

GetInt returns an int value with optional default.

func (*Manager) GetInt16 

func (m *Manager) GetInt16(key string, defaultValue ...int16) int16

GetInt16 returns an int16 value with optional default.

func (*Manager) GetInt32 

func (m *Manager) GetInt32(key string, defaultValue ...int32) int32

GetInt32 returns an int32 value with optional default.

func (*Manager) GetInt64 

func (m *Manager) GetInt64(key string, defaultValue ...int64) int64

GetInt64 returns an int64 value with optional default.

func (*Manager) GetInt64Slice 

func (m *Manager) GetInt64Slice(key string, defaultValue ...[]int64) []int64

GetInt64Slice returns an int64 slice with optional default.

func (*Manager) GetInt8 

func (m *Manager) GetInt8(key string, defaultValue ...int8) int8

GetInt8 returns an int8 value with optional default.

func (*Manager) GetIntSlice 

func (m *Manager) GetIntSlice(key string, defaultValue ...[]int) []int

GetIntSlice returns an int slice with optional default.

func (*Manager) GetIntWithOptions 

func (m *Manager) GetIntWithOptions(key string, opts ...configcore.GetOption) (int, error)

GetIntWithOptions returns an int with advanced options.

func (*Manager) GetKeys 

func (m *Manager) GetKeys() []string

GetKeys returns all configuration keys.

func (*Manager) GetSection 

func (m *Manager) GetSection(key string) map[string]any

GetSection returns a configuration section.

func (*Manager) GetSizeInBytes 

func (m *Manager) GetSizeInBytes(key string, defaultValue ...uint64) uint64

GetSizeInBytes returns size in bytes with optional default.

func (*Manager) GetSourceMetadata 

func (m *Manager) GetSourceMetadata() map[string]*SourceMetadata

GetSourceMetadata returns metadata for all sources.

func (*Manager) GetString 

func (m *Manager) GetString(key string, defaultValue ...string) string

GetString returns a string value with optional default.

func (*Manager) GetStringMap 

func (m *Manager) GetStringMap(key string, defaultValue ...map[string]string) map[string]string

GetStringMap returns a string map with optional default.

func (*Manager) GetStringMapString 

func (m *Manager) GetStringMapString(key string, defaultValue ...map[string]string) map[string]string

GetStringMapString is an alias for GetStringMap.

func (*Manager) GetStringMapStringSlice 

func (m *Manager) GetStringMapStringSlice(key string, defaultValue ...map[string][]string) map[string][]string

GetStringMapStringSlice returns a map of string slices with optional default.

func (*Manager) GetStringSlice 

func (m *Manager) GetStringSlice(key string, defaultValue ...[]string) []string

GetStringSlice returns a string slice with optional default.

func (*Manager) GetStringWithOptions 

func (m *Manager) GetStringWithOptions(key string, opts ...configcore.GetOption) (string, error)

GetStringWithOptions returns a string with advanced options.

func (*Manager) GetTime 

func (m *Manager) GetTime(key string, defaultValue ...time.Time) time.Time

GetTime returns a time value with optional default.

func (*Manager) GetUint 

func (m *Manager) GetUint(key string, defaultValue ...uint) uint

GetUint returns a uint value with optional default.

func (*Manager) GetUint16 

func (m *Manager) GetUint16(key string, defaultValue ...uint16) uint16

GetUint16 returns a uint16 value with optional default.

func (*Manager) GetUint32 

func (m *Manager) GetUint32(key string, defaultValue ...uint32) uint32

GetUint32 returns a uint32 value with optional default.

func (*Manager) GetUint64 

func (m *Manager) GetUint64(key string, defaultValue ...uint64) uint64

GetUint64 returns a uint64 value with optional default.

func (*Manager) GetUint8 

func (m *Manager) GetUint8(key string, defaultValue ...uint8) uint8

GetUint8 returns a uint8 value with optional default.

func (*Manager) GetWithOptions 

func (m *Manager) GetWithOptions(key string, opts ...configcore.GetOption) (any, error)

GetWithOptions returns a value with advanced options.

func (*Manager) HasKey 

func (m *Manager) HasKey(key string) bool

HasKey checks if a key exists.

func (*Manager) InConfig 

func (m *Manager) InConfig(key string) bool

InConfig is an alias for HasKey.

func (*Manager) IsSet 

func (m *Manager) IsSet(key string) bool

IsSet checks if a key is set and not empty.

func (*Manager) LoadFrom 

func (m *Manager) LoadFrom(sources ...ConfigSource) error

LoadFrom loads configuration from multiple sources.

func (*Manager) MergeWith 

func (m *Manager) MergeWith(other ConfigManager) error

MergeWith merges another config manager.

func (*Manager) Name 

func (m *Manager) Name() string

func (*Manager) OnConfigChange 

func (m *Manager) OnConfigChange(callback func(ConfigChange))

OnConfigChange is an alias for WatchChanges.

func (*Manager) ReadInConfig 

func (m *Manager) ReadInConfig() error

ReadInConfig reads configuration.

func (*Manager) Reload 

func (m *Manager) Reload() error

Reload forces a reload of all configuration sources.

func (*Manager) ReloadContext 

func (m *Manager) ReloadContext(ctx context.Context) error

ReloadContext forces a reload with context.

func (*Manager) Reset 

func (m *Manager) Reset()

Reset clears all configuration.

func (*Manager) SafeGet 

func (m *Manager) SafeGet(key string, expectedType reflect.Type) (any, error)

SafeGet returns a value with type checking.

func (*Manager) SecretsManager 

func (m *Manager) SecretsManager() SecretsManager

func (*Manager) Set 

func (m *Manager) Set(key string, value any)

Set sets a configuration value.

func (*Manager) SetConfigFile 

func (m *Manager) SetConfigFile(filePath string) error

SetConfigFile sets the configuration file.

func (*Manager) SetConfigType 

func (m *Manager) SetConfigType(configType string)

SetConfigType sets the configuration type.

func (*Manager) Size 

func (m *Manager) Size() int

Size returns the number of keys.

func (*Manager) Stop 

func (m *Manager) Stop() error

Stop stops the configuration manager.

func (*Manager) Sub 

func (m *Manager) Sub(key string) ConfigManager

Sub returns a sub-configuration manager.

func (*Manager) Unmarshal 

func (m *Manager) Unmarshal(rawVal any) error

Unmarshal unmarshals entire configuration.

func (*Manager) UnmarshalKey 

func (m *Manager) UnmarshalKey(key string, rawVal any) error

UnmarshalKey is an alias for Bind.

func (*Manager) Validate 

func (m *Manager) Validate() error

Validate validates the current configuration.

func (*Manager) Watch 

func (m *Manager) Watch(ctx context.Context) error

Watch starts watching for configuration changes.

func (*Manager) WatchChanges 

func (m *Manager) WatchChanges(callback func(ConfigChange))

WatchChanges registers a callback for all changes.

func (*Manager) WatchConfig 

func (m *Manager) WatchConfig() error

WatchConfig is an alias for Watch.

func (*Manager) WatchWithCallback 

func (m *Manager) WatchWithCallback(key string, callback func(string, any))

WatchWithCallback registers a callback for key changes.

type ManagerConfig 

type ManagerConfig struct {
	DefaultSources  []SourceConfig      `json:"default_sources"   yaml:"default_sources"`
	WatchInterval   time.Duration       `json:"watch_interval"    yaml:"watch_interval"`
	ValidationMode  ValidationMode      `json:"validation_mode"   yaml:"validation_mode"`
	SecretsEnabled  bool                `json:"secrets_enabled"   yaml:"secrets_enabled"`
	CacheEnabled    bool                `json:"cache_enabled"     yaml:"cache_enabled"`
	ReloadOnChange  bool                `json:"reload_on_change"  yaml:"reload_on_change"`
	ErrorRetryCount int                 `json:"error_retry_count" yaml:"error_retry_count"`
	ErrorRetryDelay time.Duration       `json:"error_retry_delay" yaml:"error_retry_delay"`
	MetricsEnabled  bool                `json:"metrics_enabled"   yaml:"metrics_enabled"`
	Logger          logger.Logger       `json:"-"                 yaml:"-"`
	Metrics         shared.Metrics      `json:"-"                 yaml:"-"`
	ErrorHandler    shared.ErrorHandler `json:"-"                 yaml:"-"`
}

ManagerConfig contains configuration for the config manager.

type MemorySecretProvider 

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

MemorySecretProvider provides secrets from memory (for testing).

func (*MemorySecretProvider) Close 

func (msp *MemorySecretProvider) Close(ctx context.Context) error

func (*MemorySecretProvider) DeleteSecret 

func (msp *MemorySecretProvider) DeleteSecret(ctx context.Context, key string) error

func (*MemorySecretProvider) GetSecret 

func (msp *MemorySecretProvider) GetSecret(ctx context.Context, key string) (string, error)

func (*MemorySecretProvider) HealthCheck 

func (msp *MemorySecretProvider) HealthCheck(ctx context.Context) error

func (*MemorySecretProvider) Initialize 

func (msp *MemorySecretProvider) Initialize(ctx context.Context, config map[string]interface{}) error

func (*MemorySecretProvider) ListSecrets 

func (msp *MemorySecretProvider) ListSecrets(ctx context.Context) ([]string, error)

func (*MemorySecretProvider) Name 

func (msp *MemorySecretProvider) Name() string

func (*MemorySecretProvider) SetSecret 

func (msp *MemorySecretProvider) SetSecret(ctx context.Context, key, value string) error

func (*MemorySecretProvider) SupportsCaching 

func (msp *MemorySecretProvider) SupportsCaching() bool

func (*MemorySecretProvider) SupportsRotation 

func (msp *MemorySecretProvider) SupportsRotation() bool

type MockSecretsBuilder 

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

MockSecretsBuilder provides fluent interface for building test scenarios.

func NewMockSecretsBuilder 

func NewMockSecretsBuilder() *MockSecretsBuilder

NewMockSecretsBuilder creates a new builder.

func (*MockSecretsBuilder) Build 

func (b *MockSecretsBuilder) Build() *MockSecretsManager

Build returns the configured mock.

func (*MockSecretsBuilder) WithGetError 

func (b *MockSecretsBuilder) WithGetError(err error) *MockSecretsBuilder

WithGetError configures GetSecret error.

func (*MockSecretsBuilder) WithLatency 

func (b *MockSecretsBuilder) WithLatency(latency time.Duration) *MockSecretsBuilder

WithLatency configures latency simulation.

func (*MockSecretsBuilder) WithProvider 

func (b *MockSecretsBuilder) WithProvider(name string, provider SecretProvider) *MockSecretsBuilder

WithProvider adds a provider.

func (*MockSecretsBuilder) WithSecret 

func (b *MockSecretsBuilder) WithSecret(key, value string) *MockSecretsBuilder

WithSecret adds a secret to the mock.

func (*MockSecretsBuilder) WithSecrets 

func (b *MockSecretsBuilder) WithSecrets(secrets map[string]string) *MockSecretsBuilder

WithSecrets adds multiple secrets.

func (*MockSecretsBuilder) WithSetError 

func (b *MockSecretsBuilder) WithSetError(err error) *MockSecretsBuilder

WithSetError configures SetSecret error.

func (*MockSecretsBuilder) WithStarted 

func (b *MockSecretsBuilder) WithStarted(started bool) *MockSecretsBuilder

WithStarted sets the started state.

type MockSecretsManager 

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

MockSecretsManager is a comprehensive mock implementation of SecretsManager optimized for testing with call tracking, assertions, and behavior simulation.

func NewMockSecretsManager 

func NewMockSecretsManager() *MockSecretsManager

NewMockSecretsManager creates a new mock secrets manager with default settings.

func NewMockSecretsManagerWithSecrets 

func NewMockSecretsManagerWithSecrets(secrets map[string]string) *MockSecretsManager

NewMockSecretsManagerWithSecrets creates a mock with initial secrets.

func (*MockSecretsManager) ClearErrors 

func (m *MockSecretsManager) ClearErrors()

ClearErrors clears all configured errors.

func (*MockSecretsManager) DeleteCallCount 

func (m *MockSecretsManager) DeleteCallCount() int

DeleteCallCount returns the number of DeleteSecret calls.

func (*MockSecretsManager) DeleteCalls 

func (m *MockSecretsManager) DeleteCalls() []SecretCall

DeleteCalls returns all DeleteSecret calls.

func (*MockSecretsManager) DeleteSecret 

func (m *MockSecretsManager) DeleteSecret(ctx context.Context, key string) error

DeleteSecret removes a secret.

func (*MockSecretsManager) ErrorCount 

func (m *MockSecretsManager) ErrorCount() int64

ErrorCount returns the total number of errors.

func (*MockSecretsManager) GetCallCount 

func (m *MockSecretsManager) GetCallCount() int

GetCallCount returns the number of GetSecret calls.

func (*MockSecretsManager) GetCalls 

func (m *MockSecretsManager) GetCalls() []SecretCall

GetCalls returns all GetSecret calls.

func (*MockSecretsManager) GetProvider 

func (m *MockSecretsManager) GetProvider(name string) (SecretProvider, error)

GetProvider returns a secrets provider by name.

func (*MockSecretsManager) GetSecret 

func (m *MockSecretsManager) GetSecret(ctx context.Context, key string) (string, error)

GetSecret retrieves a secret by key.

func (*MockSecretsManager) GetStats 

func (m *MockSecretsManager) GetStats() MockStats

GetStats returns usage statistics.

func (*MockSecretsManager) HealthCallCount 

func (m *MockSecretsManager) HealthCallCount() int

HealthCallCount returns the number of HealthCheck calls.

func (*MockSecretsManager) HealthCalls 

func (m *MockSecretsManager) HealthCalls() []HealthCall

HealthCalls returns all HealthCheck calls.

func (*MockSecretsManager) HealthCheck 

func (m *MockSecretsManager) HealthCheck(ctx context.Context) error

HealthCheck performs a health check.

func (*MockSecretsManager) IsStarted 

func (m *MockSecretsManager) IsStarted() bool

IsStarted returns whether the manager is started.

func (*MockSecretsManager) LastAccessed 

func (m *MockSecretsManager) LastAccessed() time.Time

LastAccessed returns the timestamp of the last operation.

func (*MockSecretsManager) ListCallCount 

func (m *MockSecretsManager) ListCallCount() int

ListCallCount returns the number of ListSecrets calls.

func (*MockSecretsManager) ListCalls 

func (m *MockSecretsManager) ListCalls() []ListCall

ListCalls returns all ListSecrets calls.

func (*MockSecretsManager) ListSecrets 

func (m *MockSecretsManager) ListSecrets(ctx context.Context) ([]string, error)

ListSecrets returns all secret keys.

func (*MockSecretsManager) PrintStats 

func (m *MockSecretsManager) PrintStats()

PrintStats prints statistics for debugging.

func (*MockSecretsManager) ProviderCount 

func (m *MockSecretsManager) ProviderCount() int

ProviderCount returns the number of registered providers.

func (*MockSecretsManager) RefreshCallCount 

func (m *MockSecretsManager) RefreshCallCount() int

RefreshCallCount returns the number of RefreshSecrets calls.

func (*MockSecretsManager) RefreshCalls 

func (m *MockSecretsManager) RefreshCalls() []RefreshCall

RefreshCalls returns all RefreshSecrets calls.

func (*MockSecretsManager) RefreshSecrets 

func (m *MockSecretsManager) RefreshSecrets(ctx context.Context) error

RefreshSecrets refreshes all cached secrets.

func (*MockSecretsManager) RegisterProvider 

func (m *MockSecretsManager) RegisterProvider(name string, provider SecretProvider) error

RegisterProvider registers a secrets provider.

func (*MockSecretsManager) Reset 

func (m *MockSecretsManager) Reset()

Reset resets the mock to its initial state.

func (*MockSecretsManager) ResetCallTracking 

func (m *MockSecretsManager) ResetCallTracking()

ResetCallTracking resets only the call tracking (keeps secrets and state).

func (*MockSecretsManager) RotateCallCount 

func (m *MockSecretsManager) RotateCallCount() int

RotateCallCount returns the number of RotateSecret calls.

func (*MockSecretsManager) RotateCalls 

func (m *MockSecretsManager) RotateCalls() []RotateCall

RotateCalls returns all RotateSecret calls.

func (*MockSecretsManager) RotateSecret 

func (m *MockSecretsManager) RotateSecret(ctx context.Context, key, newValue string) error

RotateSecret rotates a secret with a new value.

func (*MockSecretsManager) SecretCount 

func (m *MockSecretsManager) SecretCount() int

SecretCount returns the number of secrets stored.

func (*MockSecretsManager) SetCallCount 

func (m *MockSecretsManager) SetCallCount() int

SetCallCount returns the number of SetSecret calls.

func (*MockSecretsManager) SetCalls 

func (m *MockSecretsManager) SetCalls() []SecretCall

SetCalls returns all SetSecret calls.

func (*MockSecretsManager) SetDeleteError 

func (m *MockSecretsManager) SetDeleteError(err error)

SetDeleteError configures DeleteSecret to return an error.

func (*MockSecretsManager) SetGetError 

func (m *MockSecretsManager) SetGetError(err error)

SetGetError configures GetSecret to return an error.

func (*MockSecretsManager) SetHealthError 

func (m *MockSecretsManager) SetHealthError(err error)

SetHealthError configures HealthCheck to return an error.

func (*MockSecretsManager) SetLatencySimulation 

func (m *MockSecretsManager) SetLatencySimulation(latency time.Duration)

SetLatencySimulation configures artificial latency for all operations.

func (*MockSecretsManager) SetListError 

func (m *MockSecretsManager) SetListError(err error)

SetListError configures ListSecrets to return an error.

func (*MockSecretsManager) SetRefreshError 

func (m *MockSecretsManager) SetRefreshError(err error)

SetRefreshError configures RefreshSecrets to return an error.

func (*MockSecretsManager) SetRotateError 

func (m *MockSecretsManager) SetRotateError(err error)

SetRotateError configures RotateSecret to return an error.

func (*MockSecretsManager) SetSecret 

func (m *MockSecretsManager) SetSecret(ctx context.Context, key, value string) error

SetSecret stores a secret.

func (*MockSecretsManager) SetSetError 

func (m *MockSecretsManager) SetSetError(err error)

SetSetError configures SetSecret to return an error.

func (*MockSecretsManager) SetStartError 

func (m *MockSecretsManager) SetStartError(err error)

SetStartError configures Start to return an error.

func (*MockSecretsManager) SetStopError 

func (m *MockSecretsManager) SetStopError(err error)

SetStopError configures Stop to return an error.

func (*MockSecretsManager) Start 

func (m *MockSecretsManager) Start(ctx context.Context) error

Start starts the secrets manager.

func (*MockSecretsManager) StartCallCount 

func (m *MockSecretsManager) StartCallCount() int

StartCallCount returns the number of Start calls.

func (*MockSecretsManager) StartCalls 

func (m *MockSecretsManager) StartCalls() []LifecycleCall

StartCalls returns all Start calls.

func (*MockSecretsManager) Stop 

func (m *MockSecretsManager) Stop(ctx context.Context) error

Stop stops the secrets manager.

func (*MockSecretsManager) StopCallCount 

func (m *MockSecretsManager) StopCallCount() int

StopCallCount returns the number of Stop calls.

func (*MockSecretsManager) StopCalls 

func (m *MockSecretsManager) StopCalls() []LifecycleCall

StopCalls returns all Stop calls.

func (*MockSecretsManager) TotalCallCount 

func (m *MockSecretsManager) TotalCallCount() int64

TotalCallCount returns the total number of calls.

func (*MockSecretsManager) WasDeleteCalledWith 

func (m *MockSecretsManager) WasDeleteCalledWith(key string) bool

WasDeleteCalledWith checks if DeleteSecret was called with a specific key.

func (*MockSecretsManager) WasGetCalledWith 

func (m *MockSecretsManager) WasGetCalledWith(key string) bool

WasGetCalledWith checks if GetSecret was called with a specific key.

func (*MockSecretsManager) WasRotateCalledWith 

func (m *MockSecretsManager) WasRotateCalledWith(key string) bool

WasRotateCalledWith checks if RotateSecret was called with a specific key.

func (*MockSecretsManager) WasSetCalledWith 

func (m *MockSecretsManager) WasSetCalledWith(key, value string) bool

WasSetCalledWith checks if SetSecret was called with a specific key and value.

type MockStats 

type MockStats struct {
	SecretCount   int
	ProviderCount int
	TotalCalls    int64
	ErrorCount    int64
	Started       bool
	LastAccessed  time.Time

	GetCalls     int
	SetCalls     int
	DeleteCalls  int
	ListCalls    int
	RotateCalls  int
	RefreshCalls int
	StartCalls   int
	StopCalls    int
	HealthCalls  int
}

Stats contains statistics about the mock's usage.

type PortRule 

type PortRule struct{}

func (*PortRule) AppliesTo 

func (r *PortRule) AppliesTo(key string) bool

func (*PortRule) Name 

func (r *PortRule) Name() string

func (*PortRule) Validate 

func (r *PortRule) Validate(key string, value any) error

type PropertySchema 

type PropertySchema struct {
	Type        PropertyType              `json:"type"`
	Required    bool                      `json:"required"`
	Default     any                       `json:"default,omitempty"`
	Description string                    `json:"description,omitempty"`
	Format      string                    `json:"format,omitempty"`
	Pattern     string                    `json:"pattern,omitempty"`
	Enum        []any                     `json:"enum,omitempty"`
	Minimum     *float64                  `json:"minimum,omitempty"`
	Maximum     *float64                  `json:"maximum,omitempty"`
	MinLength   *int                      `json:"min_length,omitempty"`
	MaxLength   *int                      `json:"max_length,omitempty"`
	Items       *PropertySchema           `json:"items,omitempty"`
	Properties  map[string]PropertySchema `json:"properties,omitempty"`
	Constraints []ConstraintRule          `json:"constraints,omitempty"`
}

PropertySchema defines validation for a specific property.

type PropertyType 

type PropertyType string

PropertyType represents the type of a configuration property. 

const (
	PropertyTypeString  PropertyType = "string"
	PropertyTypeInteger PropertyType = "integer"
	PropertyTypeNumber  PropertyType = "number"
	PropertyTypeBoolean PropertyType = "boolean"
	PropertyTypeArray   PropertyType = "array"
	PropertyTypeObject  PropertyType = "object"
	PropertyTypeAny     PropertyType = "any"
)

type ProviderConfig 

type ProviderConfig struct {
	Type       string                 `json:"type"       yaml:"type"`
	Priority   int                    `json:"priority"   yaml:"priority"`
	Properties map[string]interface{} `json:"properties" yaml:"properties"`
	Enabled    bool                   `json:"enabled"    yaml:"enabled"`
}

ProviderConfig contains configuration for a secret provider.

type RefreshCall 

type RefreshCall struct {
	Timestamp time.Time
	Error     error
}

RefreshCall represents a tracked refresh operation.

type RotateCall 

type RotateCall struct {
	Key       string
	OldValue  string
	NewValue  string
	Timestamp time.Time
	Error     error
}

RotateCall represents a tracked rotate operation.

type SecretCall 

type SecretCall struct {
	Key       string
	Value     string
	Timestamp time.Time
	Error     error
}

SecretCall represents a tracked secret operation call.

type SecretEncryptor 

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

SecretEncryptor handles encryption and decryption of secrets.

func NewSecretEncryptor 

func NewSecretEncryptor(keyStr string) *SecretEncryptor

NewSecretEncryptor creates a new secret encryptor.

func (*SecretEncryptor) Decrypt 

func (se *SecretEncryptor) Decrypt(ciphertext string) (string, error)

Decrypt decrypts a secret value.

func (*SecretEncryptor) Encrypt 

func (se *SecretEncryptor) Encrypt(plaintext string) (string, error)

Encrypt encrypts a secret value.

type SecretGenerator 

type SecretGenerator interface {
	GenerateSecret(ctx context.Context, key string, metadata SecretMetadata) (string, error)
	ValidateSecret(ctx context.Context, value string) error
}

SecretGenerator generates new secret values.

type SecretMetadata 

type SecretMetadata struct {
	Key          string                 `json:"key"`
	Provider     string                 `json:"provider"`
	Created      time.Time              `json:"created"`
	LastAccessed time.Time              `json:"last_accessed"`
	LastRotated  time.Time              `json:"last_rotated,omitempty"`
	AccessCount  int64                  `json:"access_count"`
	Tags         map[string]string      `json:"tags,omitempty"`
	Encrypted    bool                   `json:"encrypted"`
	TTL          time.Duration          `json:"ttl,omitempty"`
	Properties   map[string]interface{} `json:"properties,omitempty"`
}

SecretMetadata contains metadata about a secret.

type SecretProvider 

type SecretProvider = configscore.SecretProvider

SecretProvider defines an interface for different secret backends.

type SecretRotationPolicy 

type SecretRotationPolicy struct {
	Enabled    bool              `json:"enabled"`
	Interval   time.Duration     `json:"interval"`
	MaxAge     time.Duration     `json:"max_age"`
	Generator  SecretGenerator   `json:"-"`
	Validators []SecretValidator `json:"-"`
	NotifyOn   []string          `json:"notify_on"`
}

SecretRotationPolicy defines how secrets should be rotated.

type SecretValidator 

type SecretValidator interface {
	ValidateSecret(ctx context.Context, key, value string) error
	GetValidationRules() []string
}

SecretValidator validates secret values.

type SecretsConfig 

type SecretsConfig struct {
	DefaultProvider   string                    `json:"default_provider"   yaml:"default_provider"`
	Providers         map[string]ProviderConfig `json:"providers"          yaml:"providers"`
	CacheEnabled      bool                      `json:"cache_enabled"      yaml:"cache_enabled"`
	CacheTTL          time.Duration             `json:"cache_ttl"          yaml:"cache_ttl"`
	RotationEnabled   bool                      `json:"rotation_enabled"   yaml:"rotation_enabled"`
	RotationInterval  time.Duration             `json:"rotation_interval"  yaml:"rotation_interval"`
	EncryptionEnabled bool                      `json:"encryption_enabled" yaml:"encryption_enabled"`
	EncryptionKey     string                    `json:"encryption_key"     yaml:"encryption_key"`
	MetricsEnabled    bool                      `json:"metrics_enabled"    yaml:"metrics_enabled"`
	Logger            logger.Logger             `json:"-"                  yaml:"-"`
	Metrics           shared.Metrics            `json:"-"                  yaml:"-"`
	ErrorHandler      shared.ErrorHandler       `json:"-"                  yaml:"-"`
}

SecretsConfig contains configuration for the secrets manager.

type SecretsManager 

type SecretsManager = configscore.SecretsManager

SecretsManager manages secrets for configuration.

func NewSecretsManager 

func NewSecretsManager(config SecretsConfig) SecretsManager

NewSecretsManager creates a new secrets manager.

type SecretsManagerImpl 

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

SecretsManagerImpl implements the SecretsManager interface.

func (*SecretsManagerImpl) DeleteSecret 

func (sm *SecretsManagerImpl) DeleteSecret(ctx context.Context, key string) error

DeleteSecret removes a secret.

func (*SecretsManagerImpl) GetProvider 

func (sm *SecretsManagerImpl) GetProvider(name string) (SecretProvider, error)

GetProvider returns a secrets provider by name.

func (*SecretsManagerImpl) GetSecret 

func (sm *SecretsManagerImpl) GetSecret(ctx context.Context, key string) (string, error)

GetSecret retrieves a secret by key.

func (*SecretsManagerImpl) HealthCheck 

func (sm *SecretsManagerImpl) HealthCheck(ctx context.Context) error

HealthCheck performs a health check.

func (*SecretsManagerImpl) ListSecrets 

func (sm *SecretsManagerImpl) ListSecrets(ctx context.Context) ([]string, error)

ListSecrets returns all secret keys.

func (*SecretsManagerImpl) RefreshSecrets 

func (sm *SecretsManagerImpl) RefreshSecrets(ctx context.Context) error

RefreshSecrets refreshes all cached secrets.

func (*SecretsManagerImpl) RegisterProvider 

func (sm *SecretsManagerImpl) RegisterProvider(name string, provider SecretProvider) error

RegisterProvider registers a secrets provider.

func (*SecretsManagerImpl) RotateSecret 

func (sm *SecretsManagerImpl) RotateSecret(ctx context.Context, key, newValue string) error

RotateSecret rotates a secret with a new value.

func (*SecretsManagerImpl) SetSecret 

func (sm *SecretsManagerImpl) SetSecret(ctx context.Context, key, value string) error

SetSecret stores a secret.

func (*SecretsManagerImpl) Start 

func (sm *SecretsManagerImpl) Start(ctx context.Context) error

Start starts the secrets manager.

func (*SecretsManagerImpl) Stop 

func (sm *SecretsManagerImpl) Stop(ctx context.Context) error

Stop stops the secrets manager.

type Severity 

type Severity = errors.Severity

type SourceConfig 

type SourceConfig = core.SourceConfig

SourceConfig contains common configuration for all sources.

type SourceEvent 

type SourceEvent = core.SourceEvent

SourceEvent represents an event from a configuration source.

type SourceEventHandler 

type SourceEventHandler = core.SourceEventHandler

SourceEventHandler handles events from configuration sources.

type SourceMetadata 

type SourceMetadata = core.SourceMetadata

SourceMetadata contains metadata about a configuration source.

type SourceRegistry 

type SourceRegistry = core.SourceRegistry

SourceRegistry manages registered configuration sources.

func NewSourceRegistry 

func NewSourceRegistry(logger logger.Logger) SourceRegistry

NewSourceRegistry creates a new source registry.

type SourceRegistryImpl 

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

SourceRegistryImpl implements the SourceRegistry interface.

func (*SourceRegistryImpl) Clear 

func (sr *SourceRegistryImpl) Clear() error

Clear removes all registered sources.

func (*SourceRegistryImpl) GetAllMetadata 

func (sr *SourceRegistryImpl) GetAllMetadata() map[string]*SourceMetadata

GetAllMetadata returns metadata for all sources.

func (*SourceRegistryImpl) GetSource 

func (sr *SourceRegistryImpl) GetSource(name string) (ConfigSource, error)

GetSource retrieves a configuration source by name.

func (*SourceRegistryImpl) GetSourceMetadata 

func (sr *SourceRegistryImpl) GetSourceMetadata(name string) (*SourceMetadata, error)

GetSourceMetadata returns metadata for a source.

func (*SourceRegistryImpl) GetSourceNames 

func (sr *SourceRegistryImpl) GetSourceNames() []string

GetSourceNames returns the names of all registered sources.

func (*SourceRegistryImpl) GetSourceStats 

func (sr *SourceRegistryImpl) GetSourceStats() map[string]any

GetSourceStats returns statistics about the registry.

func (*SourceRegistryImpl) GetSources 

func (sr *SourceRegistryImpl) GetSources() []ConfigSource

GetSources returns all registered sources ordered by priority.

func (*SourceRegistryImpl) GetSourcesByType 

func (sr *SourceRegistryImpl) GetSourcesByType(sourceType string) []ConfigSource

GetSourcesByType returns sources of a specific type.

func (*SourceRegistryImpl) GetSourcesWithSecrets 

func (sr *SourceRegistryImpl) GetSourcesWithSecrets() []ConfigSource

GetSourcesWithSecrets returns all sources that support secrets.

func (*SourceRegistryImpl) GetWatchableSources 

func (sr *SourceRegistryImpl) GetWatchableSources() []ConfigSource

GetWatchableSources returns all sources that support watching.

func (*SourceRegistryImpl) HasSource 

func (sr *SourceRegistryImpl) HasSource(name string) bool

HasSource returns true if a source with the given name is registered.

func (*SourceRegistryImpl) IsEmpty 

func (sr *SourceRegistryImpl) IsEmpty() bool

IsEmpty returns true if no sources are registered.

func (*SourceRegistryImpl) RegisterSource 

func (sr *SourceRegistryImpl) RegisterSource(source ConfigSource) error

RegisterSource registers a configuration source.

func (*SourceRegistryImpl) UnregisterSource 

func (sr *SourceRegistryImpl) UnregisterSource(name string) error

UnregisterSource unregisters a configuration source.

func (*SourceRegistryImpl) UpdateLoadStats 

func (sr *SourceRegistryImpl) UpdateLoadStats(name string, keyCount int, err error) error

UpdateLoadStats updates load statistics for a source.

func (*SourceRegistryImpl) UpdateModifiedTime 

func (sr *SourceRegistryImpl) UpdateModifiedTime(name string, modifiedTime time.Time) error

UpdateModifiedTime updates the last modified time for a source.

func (*SourceRegistryImpl) UpdateSourceMetadata 

func (sr *SourceRegistryImpl) UpdateSourceMetadata(name string, updater func(*SourceMetadata)) error

UpdateSourceMetadata updates metadata for a source (internal use).

func (*SourceRegistryImpl) UpdateWatchStatus 

func (sr *SourceRegistryImpl) UpdateWatchStatus(name string, isWatching bool) error

UpdateWatchStatus updates watch status for a source.

func (*SourceRegistryImpl) ValidateSourceDependencies 

func (sr *SourceRegistryImpl) ValidateSourceDependencies() error

ValidateSourceDependencies validates that all source dependencies are met.

type TestConfigAssertions 

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

TestConfigAssertions provides assertion helpers for testing configuration.

func NewTestConfigAssertions 

func NewTestConfigAssertions(manager ConfigManager) *TestConfigAssertions

NewTestConfigAssertions creates assertion helpers for the test config manager.

func (*TestConfigAssertions) AssertIntEquals 

func (a *TestConfigAssertions) AssertIntEquals(key string, expected int) bool

AssertIntEquals checks that a key has the expected int value.

func (*TestConfigAssertions) AssertKeyEquals 

func (a *TestConfigAssertions) AssertKeyEquals(key string, expected any) bool

AssertKeyEquals checks that a key has the expected value.

func (*TestConfigAssertions) AssertKeyExists 

func (a *TestConfigAssertions) AssertKeyExists(key string) bool

AssertKeyExists checks that a key exists.

func (*TestConfigAssertions) AssertStringEquals 

func (a *TestConfigAssertions) AssertStringEquals(key string, expected string) bool

AssertStringEquals checks that a key has the expected string value.

type TestConfigBuilder 

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

TestConfigBuilder provides a fluent interface for building test configurations.

func NewTestConfigBuilder 

func NewTestConfigBuilder() *TestConfigBuilder

NewTestConfigBuilder creates a new builder for test configurations.

func (*TestConfigBuilder) Build 

func (b *TestConfigBuilder) Build() ConfigManager

Build creates a TestConfigManager with the configured data.

func (*TestConfigBuilder) Set 

func (b *TestConfigBuilder) Set(key string, value any) *TestConfigBuilder

Set sets a key-value pair.

func (*TestConfigBuilder) SetDefaults 

func (b *TestConfigBuilder) SetDefaults(defaults map[string]any) *TestConfigBuilder

SetDefaults sets multiple default values.

func (*TestConfigBuilder) SetSection 

func (b *TestConfigBuilder) SetSection(key string, section map[string]any) *TestConfigBuilder

SetSection sets a configuration section.

type TestConfigManager 

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

TestConfigManager is a lightweight, in-memory implementation of ConfigManager optimized for testing scenarios. It provides realistic behavior without external dependencies like files, databases, or network services.

func (*TestConfigManager) AllKeys 

func (t *TestConfigManager) AllKeys() []string

AllKeys is an alias for GetKeys.

func (*TestConfigManager) AllSettings 

func (t *TestConfigManager) AllSettings() map[string]any

AllSettings is an alias for GetAllSettings.

func (*TestConfigManager) Bind 

func (t *TestConfigManager) Bind(key string, target any) error

Bind binds configuration to a struct (simplified for testing).

func (*TestConfigManager) BindWithDefault 

func (t *TestConfigManager) BindWithDefault(key string, target any, defaultValue any) error

BindWithDefault binds with a default value.

func (*TestConfigManager) BindWithOptions 

func (t *TestConfigManager) BindWithOptions(key string, target any, options configcore.BindOptions) error

BindWithOptions binds with flexible options.

func (*TestConfigManager) Clone 

func (t *TestConfigManager) Clone() ConfigManager

Clone creates a deep copy.

func (*TestConfigManager) ConfigFileUsed 

func (t *TestConfigManager) ConfigFileUsed() string

ConfigFileUsed returns the config file path.

func (*TestConfigManager) ExpandEnvVars 

func (t *TestConfigManager) ExpandEnvVars() error

ExpandEnvVars expands environment variables (no-op for testing).

func (*TestConfigManager) Get 

func (t *TestConfigManager) Get(key string) any

Get returns a configuration value.

func (*TestConfigManager) GetAllSettings 

func (t *TestConfigManager) GetAllSettings() map[string]any

GetAllSettings returns all settings.

func (*TestConfigManager) GetBool 

func (t *TestConfigManager) GetBool(key string, defaultValue ...bool) bool

GetBool returns a bool value with optional default.

func (*TestConfigManager) GetBoolSlice 

func (t *TestConfigManager) GetBoolSlice(key string, defaultValue ...[]bool) []bool

GetBoolSlice returns a bool slice with optional default.

func (*TestConfigManager) GetBoolWithOptions 

func (t *TestConfigManager) GetBoolWithOptions(key string, opts ...configcore.GetOption) (bool, error)

GetBoolWithOptions returns a bool with advanced options.

func (*TestConfigManager) GetBytesSize 

func (t *TestConfigManager) GetBytesSize(key string, defaultValue ...uint64) uint64

GetBytesSize is an alias for GetSizeInBytes.

func (*TestConfigManager) GetDuration 

func (t *TestConfigManager) GetDuration(key string, defaultValue ...time.Duration) time.Duration

GetDuration returns a duration value with optional default.

func (*TestConfigManager) GetDurationWithOptions 

func (t *TestConfigManager) GetDurationWithOptions(key string, opts ...configcore.GetOption) (time.Duration, error)

GetDurationWithOptions returns a duration with advanced options.

func (*TestConfigManager) GetFloat32 

func (t *TestConfigManager) GetFloat32(key string, defaultValue ...float32) float32

GetFloat32 returns a float32 value with optional default.

func (*TestConfigManager) GetFloat64 

func (t *TestConfigManager) GetFloat64(key string, defaultValue ...float64) float64

GetFloat64 returns a float64 value with optional default.

func (*TestConfigManager) GetFloat64Slice 

func (t *TestConfigManager) GetFloat64Slice(key string, defaultValue ...[]float64) []float64

GetFloat64Slice returns a float64 slice with optional default.

func (*TestConfigManager) GetInt 

func (t *TestConfigManager) GetInt(key string, defaultValue ...int) int

GetInt returns an int value with optional default.

func (*TestConfigManager) GetInt16 

func (t *TestConfigManager) GetInt16(key string, defaultValue ...int16) int16

GetInt16 returns an int16 value with optional default.

func (*TestConfigManager) GetInt32 

func (t *TestConfigManager) GetInt32(key string, defaultValue ...int32) int32

GetInt32 returns an int32 value with optional default.

func (*TestConfigManager) GetInt64 

func (t *TestConfigManager) GetInt64(key string, defaultValue ...int64) int64

GetInt64 returns an int64 value with optional default.

func (*TestConfigManager) GetInt64Slice 

func (t *TestConfigManager) GetInt64Slice(key string, defaultValue ...[]int64) []int64

GetInt64Slice returns an int64 slice with optional default.

func (*TestConfigManager) GetInt8 

func (t *TestConfigManager) GetInt8(key string, defaultValue ...int8) int8

GetInt8 returns an int8 value with optional default.

func (*TestConfigManager) GetIntSlice 

func (t *TestConfigManager) GetIntSlice(key string, defaultValue ...[]int) []int

GetIntSlice returns an int slice with optional default.

func (*TestConfigManager) GetIntWithOptions 

func (t *TestConfigManager) GetIntWithOptions(key string, opts ...configcore.GetOption) (int, error)

GetIntWithOptions returns an int with advanced options.

func (*TestConfigManager) GetKeys 

func (t *TestConfigManager) GetKeys() []string

GetKeys returns all configuration keys.

func (*TestConfigManager) GetSection 

func (t *TestConfigManager) GetSection(key string) map[string]any

GetSection returns a configuration section.

func (*TestConfigManager) GetSizeInBytes 

func (t *TestConfigManager) GetSizeInBytes(key string, defaultValue ...uint64) uint64

GetSizeInBytes returns size in bytes with optional default.

func (*TestConfigManager) GetSourceMetadata 

func (t *TestConfigManager) GetSourceMetadata() map[string]*SourceMetadata

GetSourceMetadata returns metadata for all sources.

func (*TestConfigManager) GetString 

func (t *TestConfigManager) GetString(key string, defaultValue ...string) string

GetString returns a string value with optional default.

func (*TestConfigManager) GetStringMap 

func (t *TestConfigManager) GetStringMap(key string, defaultValue ...map[string]string) map[string]string

GetStringMap returns a string map with optional default.

func (*TestConfigManager) GetStringMapString 

func (t *TestConfigManager) GetStringMapString(key string, defaultValue ...map[string]string) map[string]string

GetStringMapString is an alias for GetStringMap.

func (*TestConfigManager) GetStringMapStringSlice 

func (t *TestConfigManager) GetStringMapStringSlice(key string, defaultValue ...map[string][]string) map[string][]string

GetStringMapStringSlice returns a map of string slices with optional default.

func (*TestConfigManager) GetStringSlice 

func (t *TestConfigManager) GetStringSlice(key string, defaultValue ...[]string) []string

GetStringSlice returns a string slice with optional default.

func (*TestConfigManager) GetStringWithOptions 

func (t *TestConfigManager) GetStringWithOptions(key string, opts ...configcore.GetOption) (string, error)

GetStringWithOptions returns a string with advanced options.

func (*TestConfigManager) GetTime 

func (t *TestConfigManager) GetTime(key string, defaultValue ...time.Time) time.Time

GetTime returns a time value with optional default.

func (*TestConfigManager) GetUint 

func (t *TestConfigManager) GetUint(key string, defaultValue ...uint) uint

GetUint returns a uint value with optional default.

func (*TestConfigManager) GetUint16 

func (t *TestConfigManager) GetUint16(key string, defaultValue ...uint16) uint16

GetUint16 returns a uint16 value with optional default.

func (*TestConfigManager) GetUint32 

func (t *TestConfigManager) GetUint32(key string, defaultValue ...uint32) uint32

GetUint32 returns a uint32 value with optional default.

func (*TestConfigManager) GetUint64 

func (t *TestConfigManager) GetUint64(key string, defaultValue ...uint64) uint64

GetUint64 returns a uint64 value with optional default.

func (*TestConfigManager) GetUint8 

func (t *TestConfigManager) GetUint8(key string, defaultValue ...uint8) uint8

GetUint8 returns a uint8 value with optional default.

func (*TestConfigManager) GetWithOptions 

func (t *TestConfigManager) GetWithOptions(key string, opts ...configcore.GetOption) (any, error)

GetWithOptions returns a value with advanced options.

func (*TestConfigManager) HasKey 

func (t *TestConfigManager) HasKey(key string) bool

HasKey checks if a key exists.

func (*TestConfigManager) InConfig 

func (t *TestConfigManager) InConfig(key string) bool

InConfig is an alias for HasKey.

func (*TestConfigManager) IsSet 

func (t *TestConfigManager) IsSet(key string) bool

IsSet checks if a key is set and not empty.

func (*TestConfigManager) LoadFrom 

func (t *TestConfigManager) LoadFrom(sources ...ConfigSource) error

LoadFrom simulates loading from sources.

func (*TestConfigManager) MergeWith 

func (t *TestConfigManager) MergeWith(other ConfigManager) error

MergeWith merges another config manager.

func (*TestConfigManager) Name 

func (t *TestConfigManager) Name() string

Name returns the manager name.

func (*TestConfigManager) OnConfigChange 

func (t *TestConfigManager) OnConfigChange(callback func(ConfigChange))

OnConfigChange is an alias for WatchChanges.

func (*TestConfigManager) ReadInConfig 

func (t *TestConfigManager) ReadInConfig() error

ReadInConfig reads configuration.

func (*TestConfigManager) Reload 

func (t *TestConfigManager) Reload() error

Reload simulates reloading configuration.

func (*TestConfigManager) ReloadContext 

func (t *TestConfigManager) ReloadContext(ctx context.Context) error

ReloadContext simulates reload with context.

func (*TestConfigManager) Reset 

func (t *TestConfigManager) Reset()

Reset clears all configuration.

func (*TestConfigManager) SafeGet 

func (t *TestConfigManager) SafeGet(key string, expectedType reflect.Type) (any, error)

SafeGet returns a value with type checking.

func (*TestConfigManager) SecretsManager 

func (t *TestConfigManager) SecretsManager() SecretsManager

SecretsManager returns the secrets manager.

func (*TestConfigManager) Set 

func (t *TestConfigManager) Set(key string, value any)

Set sets a configuration value.

func (*TestConfigManager) SetConfigFile 

func (t *TestConfigManager) SetConfigFile(filePath string) error

SetConfigFile sets the configuration file (no-op for testing).

func (*TestConfigManager) SetConfigType 

func (t *TestConfigManager) SetConfigType(configType string)

SetConfigType sets the configuration type (no-op for testing).

func (*TestConfigManager) SimulateConfigChange 

func (t *TestConfigManager) SimulateConfigChange(key string, newValue any)

SimulateConfigChange simulates a configuration change for testing watchers.

func (*TestConfigManager) Size 

func (t *TestConfigManager) Size() int

Size returns the number of keys.

func (*TestConfigManager) Stop 

func (t *TestConfigManager) Stop() error

Stop stops the manager.

func (*TestConfigManager) Sub 

func (t *TestConfigManager) Sub(key string) ConfigManager

Sub returns a sub-configuration manager.

func (*TestConfigManager) Unmarshal 

func (t *TestConfigManager) Unmarshal(rawVal any) error

Unmarshal unmarshals entire configuration.

func (*TestConfigManager) UnmarshalKey 

func (t *TestConfigManager) UnmarshalKey(key string, rawVal any) error

UnmarshalKey is an alias for Bind.

func (*TestConfigManager) Validate 

func (t *TestConfigManager) Validate() error

Validate always validates successfully in tests.

func (*TestConfigManager) Watch 

func (t *TestConfigManager) Watch(ctx context.Context) error

Watch simulates watching for changes.

func (*TestConfigManager) WatchChanges 

func (t *TestConfigManager) WatchChanges(callback func(ConfigChange))

WatchChanges registers a callback for all changes.

func (*TestConfigManager) WatchConfig 

func (t *TestConfigManager) WatchConfig() error

WatchConfig is an alias for Watch.

func (*TestConfigManager) WatchWithCallback 

func (t *TestConfigManager) WatchWithCallback(key string, callback func(string, any))

WatchWithCallback registers a callback for key changes.

type URLRule 

type URLRule struct{}

func (*URLRule) AppliesTo 

func (r *URLRule) AppliesTo(key string) bool

func (*URLRule) Name 

func (r *URLRule) Name() string

func (*URLRule) Validate 

func (r *URLRule) Validate(key string, value any) error

type ValidationConfig 

type ValidationConfig = core.ValidationConfig

ValidationConfig contains validation configuration for sources.

type ValidationError 

type ValidationError = errors.ValidationError

Re-export error types from internal/errors.

type ValidationMode 

type ValidationMode string

ValidationMode defines the validation mode. 

const (
	ValidationModeStrict     ValidationMode = "strict"
	ValidationModeLoose      ValidationMode = "loose"
	ValidationModePermissive ValidationMode = "permissive"
	ValidationModeDisabled   ValidationMode = "disabled"
)

type ValidationOptions 

type ValidationOptions = core.ValidationOptions

ValidationOptions contains validation configuration.

type ValidationResult 

type ValidationResult struct {
	Valid    bool                `json:"valid"`
	Errors   []ValidationError   `json:"errors,omitempty"`
	Warnings []ValidationWarning `json:"warnings,omitempty"`
	Schema   string              `json:"schema,omitempty"`
}

ValidationResult contains the result of validation.

type ValidationRule 

type ValidationRule = core.ValidationRule

ValidationRule represents a custom validation rule.

type ValidationSchema 

type ValidationSchema struct {
	Name        string                    `json:"name"`
	Path        string                    `json:"path"`
	Required    []string                  `json:"required"`
	Properties  map[string]PropertySchema `json:"properties"`
	Constraints []ConstraintRule          `json:"constraints"`
	Custom      []ValidationRule          `json:"-"`
}

ValidationSchema defines a schema for validating configuration sections.

type ValidationWarning 

type ValidationWarning struct {
	Key        string `json:"key"`
	Value      any    `json:"value,omitempty"`
	Message    string `json:"message"`
	Suggestion string `json:"suggestion,omitempty"`
}

ValidationWarning represents a validation warning.

type Validator 

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

Validator handles configuration validation.

func NewValidator 

func NewValidator(config ValidatorConfig) *Validator

NewValidator creates a new configuration validator.

func (*Validator) AddConstraint 

func (v *Validator) AddConstraint(keyPattern string, constraint ConstraintRule)

AddConstraint adds a constraint rule for a specific key pattern.

func (*Validator) AddRule 

func (v *Validator) AddRule(keyPattern string, rule ValidationRule)

AddRule adds a validation rule for a specific key pattern.

func (*Validator) IsStrictMode 

func (v *Validator) IsStrictMode() bool

IsStrictMode returns true if the validator is in strict mode.

func (*Validator) RegisterSchema 

func (v *Validator) RegisterSchema(schema ValidationSchema)

RegisterSchema registers a validation schema.

func (*Validator) SetMode 

func (v *Validator) SetMode(mode ValidationMode)

SetMode sets the validation mode.

func (*Validator) ValidateAll 

func (v *Validator) ValidateAll(config map[string]any) error

ValidateAll validates the entire configuration.

func (*Validator) ValidateConfig 

func (v *Validator) ValidateConfig(config map[string]any) ValidationResult

ValidateConfig validates a configuration map.

func (*Validator) ValidateKey 

func (v *Validator) ValidateKey(key string, value any, config map[string]any) error

ValidateKey validates a specific configuration key.

type ValidatorConfig 

type ValidatorConfig struct {
	Mode           ValidationMode
	DefaultRules   []ValidationRule
	DefaultSchemas []ValidationSchema
	Logger         logger.Logger
	ErrorHandler   shared.ErrorHandler
	StrictMode     bool
	ValidateOnLoad bool
	ValidateOnSet  bool
}

ValidatorConfig contains configuration for the validator.

type VaultSecretProvider 

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

VaultSecretProvider provides secrets from HashiCorp Vault (placeholder).

func (*VaultSecretProvider) Close 

func (vsp *VaultSecretProvider) Close(ctx context.Context) error

func (*VaultSecretProvider) DeleteSecret 

func (vsp *VaultSecretProvider) DeleteSecret(ctx context.Context, key string) error

func (*VaultSecretProvider) GetSecret 

func (vsp *VaultSecretProvider) GetSecret(ctx context.Context, key string) (string, error)

func (*VaultSecretProvider) HealthCheck 

func (vsp *VaultSecretProvider) HealthCheck(ctx context.Context) error

func (*VaultSecretProvider) Initialize 

func (vsp *VaultSecretProvider) Initialize(ctx context.Context, config map[string]interface{}) error

func (*VaultSecretProvider) ListSecrets 

func (vsp *VaultSecretProvider) ListSecrets(ctx context.Context) ([]string, error)

func (*VaultSecretProvider) Name 

func (vsp *VaultSecretProvider) Name() string

func (*VaultSecretProvider) SetSecret 

func (vsp *VaultSecretProvider) SetSecret(ctx context.Context, key, value string) error

func (*VaultSecretProvider) SupportsCaching 

func (vsp *VaultSecretProvider) SupportsCaching() bool

func (*VaultSecretProvider) SupportsRotation 

func (vsp *VaultSecretProvider) SupportsRotation() bool

type WatchCallback 

type WatchCallback func(string, map[string]any)

WatchCallback represents a callback function for configuration changes.

type WatchContext 

type WatchContext = core.WatchContext

WatchContext contains context for watching configuration changes.

type WatchEvent 

type WatchEvent struct {
	SourceName string         `json:"source_name"`
	EventType  WatchEventType `json:"event_type"`
	Data       map[string]any `json:"data"`
	Timestamp  time.Time      `json:"timestamp"`
	Checksum   string         `json:"checksum,omitempty"`
	Error      error          `json:"error,omitempty"`
}

WatchEvent represents a configuration change event.

type WatchEventType 

type WatchEventType string

WatchEventType represents the type of watch event. 

const (
	WatchEventTypeChange WatchEventType = "change"
	WatchEventTypeCreate WatchEventType = "create"
	WatchEventTypeDelete WatchEventType = "delete"
	WatchEventTypeError  WatchEventType = "error"
	WatchEventTypeReload WatchEventType = "reload"
)

type WatchStats 

type WatchStats struct {
	SourceName  string        `json:"source_name"`
	Active      bool          `json:"active"`
	LastCheck   time.Time     `json:"last_check"`
	ChangeCount int64         `json:"change_count"`
	ErrorCount  int64         `json:"error_count"`
	Interval    time.Duration `json:"interval"`
	Uptime      time.Duration `json:"uptime"`
}

WatchStats contains statistics about a watched source.

type Watcher 

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

Watcher handles watching configuration sources for changes.

func NewWatcher 

func NewWatcher(config WatcherConfig) *Watcher

NewWatcher creates a new configuration watcher.

func (*Watcher) GetAllStats 

func (w *Watcher) GetAllStats() map[string]*WatchStats

GetAllStats returns statistics for all watched sources.

func (*Watcher) GetSourceStats 

func (w *Watcher) GetSourceStats(sourceName string) (*WatchStats, error)

GetSourceStats returns statistics for a watched source.

func (*Watcher) GetWatchedSources 

func (w *Watcher) GetWatchedSources() []string

GetWatchedSources returns the list of currently watched sources.

func (*Watcher) RegisterEventHandler 

func (w *Watcher) RegisterEventHandler(sourceName string, handler SourceEventHandler)

RegisterEventHandler registers an event handler for a source.

func (*Watcher) StopAll 

func (w *Watcher) StopAll() error

StopAll stops watching all sources.

func (*Watcher) StopWatching 

func (w *Watcher) StopWatching(sourceName string) error

StopWatching stops watching a specific source.

func (*Watcher) UnregisterEventHandler 

func (w *Watcher) UnregisterEventHandler(sourceName string, handler SourceEventHandler)

UnregisterEventHandler unregisters an event handler for a source.

func (*Watcher) WatchSource 

func (w *Watcher) WatchSource(ctx context.Context, source ConfigSource, callback WatchCallback) error

WatchSource starts watching a configuration source.

type WatcherConfig 

type WatcherConfig struct {
	Interval       time.Duration
	BufferSize     int
	MaxRetries     int
	RetryInterval  time.Duration
	Logger         logger.Logger
	Metrics        shared.Metrics
	ErrorHandler   shared.ErrorHandler
	EnableDebounce bool
	DebounceTime   time.Duration
}

WatcherConfig contains configuration for the watcher.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.