config

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2025 License: MIT Imports: 24 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 = ConfigKey

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 interface{}) logger.Field

F is a helper function to create logger fields

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 interface{}) configcore.GetOption

WithDefault sets a default value

func WithOnMissing 

func WithOnMissing(fn func(string) interface{}) 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(interface{}) interface{}) configcore.GetOption

WithTransform adds a transformation function

func WithValidator 

func WithValidator(fn func(interface{}) 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

	// 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]interface{}) []ConfigChange
	CalculateChecksum(data map[string]interface{}) 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]interface{}) 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 interface{}, config map[string]interface{}) 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]interface{}) string

func (*DefaultChangeDetector) DetectChanges 

func (d *DefaultChangeDetector) DetectChanges(old, new map[string]interface{}) []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 interface{}) 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 interface{}) 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]interface{}

AllSettings is an alias for GetAllSettings

func (*Manager) Bind 

func (m *Manager) Bind(key string, target interface{}) error

Bind binds configuration to a struct

func (*Manager) BindWithDefault 

func (m *Manager) BindWithDefault(key string, target interface{}, defaultValue interface{}) error

BindWithDefault binds with a default value

func (*Manager) BindWithOptions 

func (m *Manager) BindWithOptions(key string, target interface{}, 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) interface{}

Get returns a configuration value

func (*Manager) GetAllSettings 

func (m *Manager) GetAllSettings() map[string]interface{}

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]interface{}

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) (interface{}, 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) (interface{}, 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 interface{})

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 interface{}) error

Unmarshal unmarshals entire configuration

func (*Manager) UnmarshalKey 

func (m *Manager) UnmarshalKey(key string, rawVal interface{}) 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, interface{}))

WatchWithCallback registers a callback for key changes

type ManagerConfig 

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

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 interface{}) error

type PropertySchema 

type PropertySchema struct {
	Type        PropertyType              `json:"type"`
	Required    bool                      `json:"required"`
	Default     interface{}               `json:"default,omitempty"`
	Description string                    `json:"description,omitempty"`
	Format      string                    `json:"format,omitempty"`
	Pattern     string                    `json:"pattern,omitempty"`
	Enum        []interface{}             `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                 `yaml:"type" json:"type"`
	Priority   int                    `yaml:"priority" json:"priority"`
	Properties map[string]interface{} `yaml:"properties" json:"properties"`
	Enabled    bool                   `yaml:"enabled" json:"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                    `yaml:"default_provider" json:"default_provider"`
	Providers         map[string]ProviderConfig `yaml:"providers" json:"providers"`
	CacheEnabled      bool                      `yaml:"cache_enabled" json:"cache_enabled"`
	CacheTTL          time.Duration             `yaml:"cache_ttl" json:"cache_ttl"`
	RotationEnabled   bool                      `yaml:"rotation_enabled" json:"rotation_enabled"`
	RotationInterval  time.Duration             `yaml:"rotation_interval" json:"rotation_interval"`
	EncryptionEnabled bool                      `yaml:"encryption_enabled" json:"encryption_enabled"`
	EncryptionKey     string                    `yaml:"encryption_key" json:"encryption_key"`
	MetricsEnabled    bool                      `yaml:"metrics_enabled" json:"metrics_enabled"`
	Logger            logger.Logger             `yaml:"-" json:"-"`
	Metrics           shared.Metrics            `yaml:"-" json:"-"`
	ErrorHandler      shared.ErrorHandler       `yaml:"-" json:"-"`
}

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]interface{}

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 interface{}) 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 interface{}) *TestConfigBuilder

Set sets a key-value pair

func (*TestConfigBuilder) SetDefaults 

func (b *TestConfigBuilder) SetDefaults(defaults map[string]interface{}) *TestConfigBuilder

SetDefaults sets multiple default values

func (*TestConfigBuilder) SetSection 

func (b *TestConfigBuilder) SetSection(key string, section map[string]interface{}) *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]interface{}

AllSettings is an alias for GetAllSettings

func (*TestConfigManager) Bind 

func (t *TestConfigManager) Bind(key string, target interface{}) error

Bind binds configuration to a struct (simplified for testing)

func (*TestConfigManager) BindWithDefault 

func (t *TestConfigManager) BindWithDefault(key string, target interface{}, defaultValue interface{}) error

BindWithDefault binds with a default value

func (*TestConfigManager) BindWithOptions 

func (t *TestConfigManager) BindWithOptions(key string, target interface{}, 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) interface{}

Get returns a configuration value

func (*TestConfigManager) GetAllSettings 

func (t *TestConfigManager) GetAllSettings() map[string]interface{}

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]interface{}

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) (interface{}, 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) (interface{}, 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 interface{})

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 interface{})

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 interface{}) error

Unmarshal unmarshals entire configuration

func (*TestConfigManager) UnmarshalKey 

func (t *TestConfigManager) UnmarshalKey(key string, rawVal interface{}) 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, interface{}))

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 interface{}) 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      interface{} `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]interface{}) error

ValidateAll validates the entire configuration

func (*Validator) ValidateConfig 

func (v *Validator) ValidateConfig(config map[string]interface{}) ValidationResult

ValidateConfig validates a configuration map

func (*Validator) ValidateKey 

func (v *Validator) ValidateKey(key string, value interface{}, config map[string]interface{}) 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]interface{})

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]interface{} `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.