modular

package module

Go to main page

Versions in this module

v1

v1.4.3

Sep 11, 2025

Changes in this version

+ const EventTypeConfigReloadFailed

+ const EventTypeConfigReloadNoop

+ const EventTypeConfigReloadStart

+ const EventTypeConfigReloadSuccess

+ const EventTypeHealthAggregateUpdated

+ var ErrCannotClearSecretValue = errors.New("cannot clear secret value")

+ var ErrConfigsNil = errors.New("configs cannot be nil")

+ var ErrDynamicReloadNotAvailable = errors.New(...)

+ var ErrHealthAggregatorNotAvailable = errors.New(...)

+ var ErrInvalidHealthAggregator = errors.New("invalid health aggregator service")

+ var ErrInvalidHealthTrigger = errors.New("invalid health trigger")

+ var ErrInvalidReloadTrigger = errors.New("invalid reload trigger")

+ var ErrInvalidSecretHandle = errors.New("invalid secret handle")

+ var ErrInvalidSecretKeyLength = errors.New("invalid secret key length")

+ var ErrInvalidSecureBuffer = errors.New("invalid secure buffer")

+ var ErrInvalidServiceScope = errors.New("invalid service scope")

+ var ErrInvalidTenantGuardConfiguration = errors.New("invalid tenant guard configuration")

+ var ErrInvalidTenantGuardMode = errors.New("invalid tenant guard mode")

+ var ErrMemguardNotAvailable = errors.New(...)

+ var ErrMemguardProviderNotAvailable = errors.New("memguard provider not available")

+ var ErrModuleNameEmpty = errors.New("module name cannot be empty")

+ var ErrProviderAlreadyExists = errors.New("provider already registered")

+ var ErrProviderNil = errors.New("provider cannot be nil")

+ var ErrProviderNotRegistered = errors.New("no provider registered")

+ var ErrReloadBackoffActive = errors.New("reload orchestrator: backing off after recent failures")

+ var ErrReloadInProgress = errors.New("reload operation already in progress")

+ var ErrReloadModuleAlreadyExists = errors.New("reload orchestrator: module already registered")

+ var ErrReloadModuleNameEmpty = errors.New("reload orchestrator: module name cannot be empty")

+ var ErrReloadModuleNil = errors.New("reload orchestrator: module cannot be nil")

+ var ErrReloadModuleNotFound = errors.New("reload orchestrator: no module registered")

+ var ErrReloadNotSupported = errors.New("dynamic reload not supported")

+ var ErrReloadQueueFull = errors.New("reload orchestrator: request queue is full")

+ var ErrReloadStopTimeout = errors.New("reload orchestrator: timeout waiting for stop")

+ var ErrReloadTimeout = errors.New("reload operation timed out")

+ var ErrSecretConfigInvalid = errors.New("secret configuration invalid")

+ var ErrSecretHandleInvalid = errors.New("secret handle is invalid")

+ var ErrSecretLimitReached = errors.New("maximum number of secrets reached")

+ var ErrSecretNotFound = errors.New("secret not found")

+ var ErrSecretProviderNotSecure = errors.New("provider is not secure, but secure memory is required")

+ var ErrSecretProviderUnavailable = errors.New("secret provider unavailable")

+ var ErrSecretStoreNotInitialized = errors.New("secret store not initialized")

+ var ErrSecretTypeMismatch = errors.New("secret type mismatch")

+ var ErrSecretValueOverflow = errors.New("secret value overflow")

+ var ErrServerClosed = errors.New("server closed")

+ var ErrTenantNotIsolated = errors.New("tenant is not properly isolated")

+ var ErrUnknownProvider = errors.New("unknown provider")

+ var ErrUnknownSecretProvider = errors.New("unknown secret provider")

+ var ErrUnknownTenantGuardMode = errors.New("unknown tenant guard mode")

+ var MustImplementHealthProvider = func(HealthProvider)

+ var MustImplementHealthReporter = func(HealthReporter)

+ func EnableMemguardForTesting(provider SecretProvider)

+ func GetInsecureProviderStats(provider SecretProvider) map[string]interface

+ func GetMemguardProviderStats(provider SecretProvider) map[string]interface

+ func InitializeSecretProvider(config SecretProviderConfig, logger Logger) error

+ func RedactGlobally(text string) string

+ func RedactGloballyStructured(fields map[string]interface{}) map[string]interface

+ func RegisterGlobalPattern(pattern string)

+ func RegisterGlobalSecret(secret *SecretValue)

+ func RegisterSecretProvider(name string, creator func(config SecretProviderConfig) (SecretProvider, error))

+ func WithScopeContext(ctx context.Context, scopeKey, scopeValue string) context.Context

+ func WithTenantContext(ctx context.Context, tenantID string) context.Context

+ type AggregateHealthService struct

+ func NewAggregateHealthService() *AggregateHealthService

+ func NewAggregateHealthServiceWithConfig(config AggregateHealthServiceConfig) *AggregateHealthService

+ func (s *AggregateHealthService) Collect(ctx context.Context) (AggregatedHealth, error)

+ func (s *AggregateHealthService) GetProviders() map[string]ProviderInfo

+ func (s *AggregateHealthService) RegisterProvider(moduleName string, provider HealthProvider, optional bool) error

+ func (s *AggregateHealthService) SetEventSubject(subject Subject)

+ func (s *AggregateHealthService) UnregisterProvider(moduleName string) error

+ type AggregateHealthServiceConfig struct

+ CacheEnabled bool

+ CacheTTL time.Duration

+ DefaultTimeout time.Duration

+ type AggregateHealthSnapshot struct

+ Components map[string]HealthResult

+ GeneratedAt time.Time

+ Metadata map[string]interface{}

+ OverallStatus HealthStatus

+ ReadinessStatus HealthStatus

+ SnapshotID string

+ Summary HealthSummary

+ Timestamp time.Time

+ func (s *AggregateHealthSnapshot) GetUnhealthyComponents() []string

+ func (s *AggregateHealthSnapshot) IsHealthy() bool

+ func (s *AggregateHealthSnapshot) IsReady() bool

+ type AggregatedHealth struct

+ GeneratedAt time.Time

+ Health HealthStatus

+ Readiness HealthStatus

+ Reports []HealthReport

type Application

+ func NewStdApplicationWithOptions(cp ConfigProvider, logger Logger, options ...ApplicationOption) Application

+ GetTenantGuard func() TenantGuard

+ Health func() (HealthAggregator, error)

+ RegisterHealthProvider func(moduleName string, provider HealthProvider, optional bool) error

+ RequestReload func(sections ...string) error

type ApplicationBuilder

+ func NewApplicationBuilder() *ApplicationBuilder

+ func (b *ApplicationBuilder) WithOption(opt Option) *ApplicationBuilder

+ type ApplicationBuilderExtension struct

+ type ApplicationOption func(*StdApplication) error

+ func WithDynamicReload(config DynamicReloadConfig) ApplicationOption

+ func WithHealthAggregator(config HealthAggregatorConfig) ApplicationOption

type BaseApplicationDecorator

+ func (d *BaseApplicationDecorator) GetTenantGuard() TenantGuard

+ func (d *BaseApplicationDecorator) Health() (HealthAggregator, error)

+ func (d *BaseApplicationDecorator) RegisterHealthProvider(moduleName string, provider HealthProvider, optional bool) error

+ func (d *BaseApplicationDecorator) RequestReload(sections ...string) error

+ type BasicHealthAggregator struct

+ func (a *BasicHealthAggregator) Collect(ctx context.Context) (AggregatedHealth, error)

+ func (a *BasicHealthAggregator) RegisterProvider(provider HealthProvider)

+ type ChangeSummary struct

+ AddedCount int

+ ModifiedCount int

+ RemovedCount int

+ SensitiveChanges int

+ TotalChanges int

+ type ChangeType string

+ const ChangeTypeAdded

+ const ChangeTypeModified

+ const ChangeTypeRemoved

+ func (c ChangeType) String() string

+ type ConfigChange struct

+ FieldPath string

+ NewValue any

+ OldValue any

+ Section string

+ Source string

+ type ConfigDiff struct

+ Added map[string]interface{}

+ Changed map[string]FieldChange

+ DiffID string

+ Removed map[string]interface{}

+ Timestamp time.Time

+ func GenerateConfigDiff(oldConfig, newConfig interface{}) (*ConfigDiff, error)

+ func GenerateConfigDiffWithOptions(oldConfig, newConfig interface{}, options ConfigDiffOptions) (*ConfigDiff, error)

+ func (d *ConfigDiff) ChangeSummary() ChangeSummary

+ func (d *ConfigDiff) FilterByPrefix(prefix string) *ConfigDiff

+ func (d *ConfigDiff) GetAddedFields() []string

+ func (d *ConfigDiff) GetAllAffectedFields() []string

+ func (d *ConfigDiff) GetChangedFields() []string

+ func (d *ConfigDiff) GetRemovedFields() []string

+ func (d *ConfigDiff) HasChanges() bool

+ func (d *ConfigDiff) IsEmpty() bool

+ func (d *ConfigDiff) RedactSensitiveFields() *ConfigDiff

+ type ConfigDiffOptions struct

+ IgnoreFields []string

+ IncludeValidation bool

+ MaxDepth int

+ SensitiveFields []string

+ ValidateChanges bool

+ type ConfigFieldChange = FieldChange

+ type ConfigReloadCompletedEvent struct

+ AffectedModules []string

+ ChangesApplied int

+ Duration time.Duration

+ Error string

+ ReloadID string

+ Success bool

+ Timestamp time.Time

+ func (e *ConfigReloadCompletedEvent) EventSource() string

+ func (e *ConfigReloadCompletedEvent) EventType() string

+ func (e *ConfigReloadCompletedEvent) GetEventSource() string

+ func (e *ConfigReloadCompletedEvent) GetEventType() string

+ func (e *ConfigReloadCompletedEvent) GetTimestamp() time.Time

+ func (e *ConfigReloadCompletedEvent) StructuredFields() map[string]interface{}

+ type ConfigReloadFailedEvent struct

+ Duration time.Duration

+ Error string

+ FailedModule string

+ ReloadID string

+ Timestamp time.Time

+ func (e *ConfigReloadFailedEvent) EventSource() string

+ func (e *ConfigReloadFailedEvent) EventType() string

+ func (e *ConfigReloadFailedEvent) GetEventSource() string

+ func (e *ConfigReloadFailedEvent) GetEventType() string

+ func (e *ConfigReloadFailedEvent) GetTimestamp() time.Time

+ type ConfigReloadNoopEvent struct

+ Reason string

+ ReloadID string

+ Timestamp time.Time

+ func (e *ConfigReloadNoopEvent) EventSource() string

+ func (e *ConfigReloadNoopEvent) EventType() string

+ func (e *ConfigReloadNoopEvent) GetEventSource() string

+ func (e *ConfigReloadNoopEvent) GetEventType() string

+ func (e *ConfigReloadNoopEvent) GetTimestamp() time.Time

+ type ConfigReloadStartedEvent struct

+ ConfigDiff *ConfigDiff

+ ReloadID string

+ Timestamp time.Time

+ TriggerType ReloadTrigger

+ func (e *ConfigReloadStartedEvent) EventSource() string

+ func (e *ConfigReloadStartedEvent) EventType() string

+ func (e *ConfigReloadStartedEvent) GetEventSource() string

+ func (e *ConfigReloadStartedEvent) GetEventType() string

+ func (e *ConfigReloadStartedEvent) GetTimestamp() time.Time

+ func (e *ConfigReloadStartedEvent) StructuredFields() map[string]interface{}

+ type DynamicFieldParser interface

+ GetDynamicFields func(config interface{}) ([]string, error)

+ ValidateDynamicReload func(oldConfig, newConfig interface{}) (*ConfigDiff, error)

+ func NewDynamicFieldParser() DynamicFieldParser

+ type DynamicReloadConfig struct

+ Enabled bool

+ ReloadTimeout time.Duration

+ type EventObserver interface

+ OnStatusChange func(ctx context.Context, event *HealthStatusChangedEvent)

+ type FieldChange struct

+ ChangeType ChangeType

+ FieldPath string

+ IsSensitive bool

+ NewValue interface{}

+ OldValue interface{}

+ ValidationResult *ValidationResult

+ type HealthAggregator interface

+ Collect func(ctx context.Context) (AggregatedHealth, error)

+ type HealthAggregatorConfig struct

+ CheckInterval time.Duration

+ CheckTimeout time.Duration

+ Enabled bool

+ type HealthComponent struct

+ CheckDuration time.Duration

+ LastChecked time.Time

+ Message string

+ Metadata map[string]interface{}

+ Name string

+ Status HealthStatus

+ type HealthEvaluatedEvent struct

+ Duration time.Duration

+ EvaluationID string

+ Metrics *HealthEvaluationMetrics

+ PreviousStatus HealthStatus

+ Snapshot AggregateHealthSnapshot

+ StatusChanged bool

+ Timestamp time.Time

+ TriggerType HealthTrigger

+ func (e *HealthEvaluatedEvent) EventSource() string

+ func (e *HealthEvaluatedEvent) EventType() string

+ func (e *HealthEvaluatedEvent) GetEventSource() string

+ func (e *HealthEvaluatedEvent) GetEventType() string

+ func (e *HealthEvaluatedEvent) GetTimestamp() time.Time

+ func (e *HealthEvaluatedEvent) StructuredFields() map[string]interface{}

+ type HealthEvaluationMetrics struct

+ AverageResponseTimeMs float64

+ ComponentsEvaluated int

+ ComponentsSkipped int

+ ComponentsTimedOut int

+ FailedEvaluations int

+ SlowestComponentName string

+ SlowestComponentTime time.Duration

+ TotalEvaluationTime time.Duration

+ func (h *HealthEvaluationMetrics) BottleneckPercentage() float64

+ func (h *HealthEvaluationMetrics) CalculateEfficiency() float64

+ func (h *HealthEvaluationMetrics) HasPerformanceBottleneck() bool

+ type HealthProvider interface

+ HealthCheck func(ctx context.Context) ([]HealthReport, error)

+ func HealthReporterToProvider(reporter HealthReporter, moduleName string) HealthProvider

+ func NewCompositeHealthProvider(providers ...HealthProvider) HealthProvider

+ func NewHealthReporterAdapter(reporter HealthReporter, moduleName string) HealthProvider

+ func NewSimpleHealthProvider(moduleName, componentName string, ...) HealthProvider

+ func NewStaticHealthProvider(moduleName, componentName string, status HealthStatus, message string) HealthProvider

+ type HealthReport struct

+ CheckedAt time.Time

+ Component string

+ Details map[string]any

+ Message string

+ Module string

+ ObservedSince time.Time

+ Optional bool

+ Status HealthStatus

+ type HealthReporter interface

+ CheckHealth func(ctx context.Context) HealthResult

+ HealthCheckName func() string

+ HealthCheckTimeout func() time.Duration

+ type HealthResult struct

+ CheckDuration time.Duration

+ Details map[string]interface{}

+ Message string

+ Metadata map[string]interface{}

+ Status HealthStatus

+ Timestamp time.Time

+ type HealthStatus int

+ const HealthStatusDegraded

+ const HealthStatusHealthy

+ const HealthStatusUnhealthy

+ const HealthStatusUnknown

+ func (s HealthStatus) IsHealthy() bool

+ func (s HealthStatus) String() string

+ type HealthStatusChangedEvent struct

+ Duration time.Duration

+ NewStatus HealthStatus

+ PreviousStatus HealthStatus

+ ReportCount int

+ Timestamp time.Time

+ func (e *HealthStatusChangedEvent) GetEventSource() string

+ func (e *HealthStatusChangedEvent) GetEventType() string

+ func (e *HealthStatusChangedEvent) GetTimestamp() time.Time

+ type HealthSummary struct

+ DegradedCount int

+ HealthyCount int

+ TotalCount int

+ UnhealthyCount int

+ type HealthTrigger int

+ const HealthTriggerOnDemand

+ const HealthTriggerPostReload

+ const HealthTriggerScheduled

+ const HealthTriggerStartup

+ const HealthTriggerThreshold

+ func ParseHealthTrigger(s string) (HealthTrigger, error)

+ func (h HealthTrigger) String() string

+ type InsecureSecretProvider struct

+ func (p *InsecureSecretProvider) Cleanup() error

+ func (p *InsecureSecretProvider) Clone(handle SecretHandle) (SecretHandle, error)

+ func (p *InsecureSecretProvider) Compare(handle SecretHandle, value string) (bool, error)

+ func (p *InsecureSecretProvider) Destroy(handle SecretHandle) error

+ func (p *InsecureSecretProvider) GetMetadata(handle SecretHandle) (SecretMetadata, error)

+ func (p *InsecureSecretProvider) IsEmpty(handle SecretHandle) bool

+ func (p *InsecureSecretProvider) IsSecure() bool

+ func (p *InsecureSecretProvider) Name() string

+ func (p *InsecureSecretProvider) Retrieve(handle SecretHandle) (string, error)

+ func (p *InsecureSecretProvider) Store(value string, secretType SecretType) (SecretHandle, error)

+ type MemguardSecretProvider struct

+ func (p *MemguardSecretProvider) Cleanup() error

+ func (p *MemguardSecretProvider) Clone(handle SecretHandle) (SecretHandle, error)

+ func (p *MemguardSecretProvider) Compare(handle SecretHandle, value string) (bool, error)

+ func (p *MemguardSecretProvider) Destroy(handle SecretHandle) error

+ func (p *MemguardSecretProvider) GetMetadata(handle SecretHandle) (SecretMetadata, error)

+ func (p *MemguardSecretProvider) IsEmpty(handle SecretHandle) bool

+ func (p *MemguardSecretProvider) IsSecure() bool

+ func (p *MemguardSecretProvider) Name() string

+ func (p *MemguardSecretProvider) Retrieve(handle SecretHandle) (string, error)

+ func (p *MemguardSecretProvider) Store(value string, secretType SecretType) (SecretHandle, error)

+ type ObserverEvent interface

+ GetEventSource func() string

+ GetEventType func() string

+ GetTimestamp func() time.Time

+ func FilterEventsByReloadID(events []ObserverEvent, reloadID string) []ObserverEvent

+ func FilterHealthEventsByStatus(events []ObserverEvent, status HealthStatus) []ObserverEvent

+ func FilterHealthEventsByStatusChange(events []ObserverEvent, statusChanged bool) []ObserverEvent

+ func FilterHealthEventsByTrigger(events []ObserverEvent, trigger HealthTrigger) []ObserverEvent

type Option

+ func WithTenantGuardMode(mode TenantGuardMode) Option

+ func WithTenantGuardModeConfig(config TenantGuardConfig) Option

+ type ProviderInfo struct

+ Module string

+ Optional bool

+ type ReloadOrchestrator struct

+ func NewReloadOrchestrator() *ReloadOrchestrator

+ func NewReloadOrchestratorWithConfig(config ReloadOrchestratorConfig) *ReloadOrchestrator

+ func (o *ReloadOrchestrator) RegisterModule(name string, module Reloadable) error

+ func (o *ReloadOrchestrator) RequestReload(ctx context.Context, sections ...string) error

+ func (o *ReloadOrchestrator) SetEventSubject(subject Subject)

+ func (o *ReloadOrchestrator) Stop(ctx context.Context) error

+ func (o *ReloadOrchestrator) UnregisterModule(name string) error

+ type ReloadOrchestratorConfig struct

+ BackoffBase time.Duration

+ BackoffCap time.Duration

+ QueueSize int

+ type ReloadTrigger int

+ const ReloadTriggerAPIRequest

+ const ReloadTriggerFileChange

+ const ReloadTriggerManual

+ const ReloadTriggerScheduled

+ func ParseReloadTrigger(s string) (ReloadTrigger, error)

+ func (r ReloadTrigger) String() string

+ type Reloadable interface

+ CanReload func() bool

+ Reload func(ctx context.Context, changes []ConfigChange) error

+ ReloadTimeout func() time.Duration

+ type ReloadableLegacy interface

+ CanReload func() bool

+ Reload func(ctx context.Context, newConfig interface{}) error

+ ReloadTimeout func() time.Duration

+ type ScopedServiceRegistry struct

+ func NewServiceRegistry() *ScopedServiceRegistry

+ func (r *ScopedServiceRegistry) ApplyOption(option ServiceRegistryOption) error

+ func (r *ScopedServiceRegistry) Get(name string) (any, error)

+ func (r *ScopedServiceRegistry) GetServiceScope(serviceName string) ServiceScope

+ func (r *ScopedServiceRegistry) GetWithContext(ctx context.Context, name string) (any, error)

+ func (r *ScopedServiceRegistry) Register(name string, factory any) error

+ type SecretHandle interface

+ ID func() string

+ IsValid func() bool

+ Provider func() string

+ type SecretMetadata struct

+ Created time.Time

+ IsEmpty bool

+ Provider string

+ SecureStorage bool

+ Type SecretType

+ type SecretProvider interface

+ Cleanup func() error

+ Clone func(handle SecretHandle) (SecretHandle, error)

+ Compare func(handle SecretHandle, value string) (bool, error)

+ Destroy func(handle SecretHandle) error

+ GetMetadata func(handle SecretHandle) (SecretMetadata, error)

+ IsEmpty func(handle SecretHandle) bool

+ IsSecure func() bool

+ Name func() string

+ Retrieve func(handle SecretHandle) (string, error)

+ Store func(value string, secretType SecretType) (SecretHandle, error)

+ func GetGlobalSecretProvider() SecretProvider

+ func NewInsecureSecretProvider(config SecretProviderConfig) (SecretProvider, error)

+ func NewMemguardSecretProvider(config SecretProviderConfig) (SecretProvider, error)

+ type SecretProviderConfig struct

+ AutoDestroy time.Duration

+ EnableSecureMemory bool

+ MaxSecrets int

+ Provider string

+ WarnOnInsecure bool

+ type SecretProviderFactory struct

+ func NewSecretProviderFactory(logger Logger) *SecretProviderFactory

+ func (f *SecretProviderFactory) CreateProvider(config SecretProviderConfig) (SecretProvider, error)

+ func (f *SecretProviderFactory) GetProviderInfo(name string) (map[string]interface{}, error)

+ func (f *SecretProviderFactory) ListProviders() []string

+ func (f *SecretProviderFactory) RegisterProvider(name string, creator func(config SecretProviderConfig) (SecretProvider, error))

+ type SecretRedactor struct

+ func NewSecretRedactor() *SecretRedactor

+ func (r *SecretRedactor) AddPattern(pattern string)

+ func (r *SecretRedactor) AddSecret(secret *SecretValue)

+ func (r *SecretRedactor) Redact(text string) string

+ func (r *SecretRedactor) RedactStructuredLog(fields map[string]interface{}) map[string]interface{}

+ type SecretType int

+ const SecretTypeCertificate

+ const SecretTypeGeneric

+ const SecretTypeKey

+ const SecretTypePassword

+ const SecretTypeToken

+ func (s SecretType) String() string

+ type SecretValue struct

+ func NewCertificateSecret(value string) *SecretValue

+ func NewGenericSecret(value string) *SecretValue

+ func NewKeySecret(value string) *SecretValue

+ func NewPasswordSecret(value string) *SecretValue

+ func NewSecretValue(value string, secretType SecretType) *SecretValue

+ func NewSecretValueWithProvider(value string, secretType SecretType, provider SecretProvider) *SecretValue

+ func NewTokenSecret(value string) *SecretValue

+ func (s *SecretValue) Clone() *SecretValue

+ func (s *SecretValue) Created() time.Time

+ func (s *SecretValue) Destroy()

+ func (s *SecretValue) Equals(other *SecretValue) bool

+ func (s *SecretValue) EqualsString(value string) bool

+ func (s *SecretValue) GetMaskStrategy() string

+ func (s *SecretValue) GetMaskedValue() any

+ func (s *SecretValue) GoString() string

+ func (s *SecretValue) IsEmpty() bool

+ func (s *SecretValue) MarshalJSON() ([]byte, error)

+ func (s *SecretValue) MarshalText() ([]byte, error)

+ func (s *SecretValue) Reveal() string

+ func (s *SecretValue) ShouldMask() bool

+ func (s *SecretValue) String() string

+ func (s *SecretValue) Type() SecretType

+ func (s *SecretValue) UnmarshalJSON(data []byte) error

+ func (s *SecretValue) UnmarshalText(text []byte) error

+ type ServiceRegistryOption func(*ScopedServiceRegistry) error

+ func WithServiceScope(serviceName string, scope ServiceScope) ServiceRegistryOption

+ func WithServiceScopeConfig(serviceName string, config ServiceScopeConfig) ServiceRegistryOption

+ type ServiceScope string

+ const ServiceScopeFactory

+ const ServiceScopeScoped

+ const ServiceScopeSingleton

+ const ServiceScopeTransient

+ func GetDefaultServiceScope() ServiceScope

+ func OrderScopesByLifetime(scopes []ServiceScope) []ServiceScope

+ func ParseServiceScope(s string) (ServiceScope, error)

+ func (s ServiceScope) AllowsMultipleInstances() bool

+ func (s ServiceScope) Description() string

+ func (s ServiceScope) DetailedDescription() string

+ func (s ServiceScope) Equals(other ServiceScope) bool

+ func (s ServiceScope) IsCacheable() bool

+ func (s ServiceScope) IsCompatibleWith(other ServiceScope) bool

+ func (s ServiceScope) IsValid() bool

+ func (s ServiceScope) String() string

+ type ServiceScopeConfig struct

+ EnableCaching bool

+ EnableMetrics bool

+ InstanceTimeout string

+ MaxInstances int

+ Scope ServiceScope

+ ScopeKey string

+ func GetDefaultScopeConfig(scope ServiceScope) ServiceScopeConfig

+ func (c ServiceScopeConfig) IsValid() bool

type StdApplication

+ func (app *StdApplication) GetModules() map[string]Module

+ func (app *StdApplication) GetTenantGuard() TenantGuard

+ func (app *StdApplication) Health() (HealthAggregator, error)

+ func (app *StdApplication) RegisterHealthProvider(moduleName string, provider HealthProvider, optional bool) error

+ func (app *StdApplication) RequestReload(sections ...string) error

+ type StdDynamicFieldParser struct

+ func (p *StdDynamicFieldParser) GetDynamicFields(config interface{}) ([]string, error)

+ func (p *StdDynamicFieldParser) ValidateDynamicReload(oldConfig, newConfig interface{}) (*ConfigDiff, error)

type TenantAwareDecorator

+ func (d *TenantAwareDecorator) GetTenantGuard() TenantGuard

+ type TenantGuard interface

+ GetMode func() TenantGuardMode

+ GetRecentViolations func() []*TenantViolation

+ ValidateAccess func(ctx context.Context, violation *TenantViolation) (bool, error)

+ type TenantGuardConfig struct

+ AllowCrossTenant bool

+ BlockViolations bool

+ CrossTenantWhitelist map[string][]string

+ EnforceIsolation bool

+ LogViolations bool

+ MaxTenantCacheSize int

+ Mode TenantGuardMode

+ TenantTTL time.Duration

+ ValidationTimeout time.Duration

+ func NewDefaultTenantGuardConfig(mode TenantGuardMode) TenantGuardConfig

+ func (c TenantGuardConfig) IsValid() bool

+ type TenantGuardMode string

+ const TenantGuardModeDisabled

+ const TenantGuardModeLenient

+ const TenantGuardModeStrict

+ func ParseTenantGuardMode(s string) (TenantGuardMode, error)

+ func (m TenantGuardMode) IsEnforcing() bool

+ func (m TenantGuardMode) IsStrict() bool

+ func (m TenantGuardMode) String() string

+ type TenantViolation struct

+ AccessedResource string

+ Context map[string]interface{}

+ RequestingTenant string

+ Severity TenantViolationSeverity

+ Timestamp time.Time

+ ViolationType TenantViolationType

+ type TenantViolationSeverity string

+ const TenantViolationSeverityCritical

+ const TenantViolationSeverityHigh

+ const TenantViolationSeverityLow

+ const TenantViolationSeverityMedium

+ type TenantViolationType string

+ const TenantViolationCrossTenantAccess

+ const TenantViolationInvalidTenantContext

+ const TenantViolationMissingTenantContext

+ const TenantViolationUnauthorizedOperation

+ type ValidationResult struct

+ IsValid bool

+ Message string

+ Warnings []string

v1.4.2

Sep 6, 2025

Changes in this version

+ const ModuleLifecycleSchema

+ func IsErrCircularDependency(err error) bool

+ func NewModuleLifecycleEvent(source, subject, name, version, action string, metadata map[string]interface{}) cloudevents.Event

type Application

+ ServiceIntrospector func() ServiceIntrospector

type BaseApplicationDecorator

+ func (d *BaseApplicationDecorator) ServiceIntrospector() ServiceIntrospector

type DefaultFieldTracker

+ func (t *DefaultFieldTracker) GetMostRelevantFieldPopulation(fieldPath string) *FieldPopulation

+ type DependencyEdge struct

+ From string

+ InterfaceType reflect.Type

+ ServiceName string

+ To string

+ Type EdgeType

+ type EdgeType int

+ const EdgeTypeInterfaceService

+ const EdgeTypeModule

+ const EdgeTypeNamedService

+ func (e EdgeType) String() string

+ type EnhancedServiceRegistry struct

+ func NewEnhancedServiceRegistry() *EnhancedServiceRegistry

+ func (r *EnhancedServiceRegistry) AsServiceRegistry() ServiceRegistry

+ func (r *EnhancedServiceRegistry) ClearCurrentModule()

+ func (r *EnhancedServiceRegistry) GetService(name string) (any, bool)

+ func (r *EnhancedServiceRegistry) GetServiceEntry(name string) (*ServiceRegistryEntry, bool)

+ func (r *EnhancedServiceRegistry) GetServicesByInterface(interfaceType reflect.Type) []*ServiceRegistryEntry

+ func (r *EnhancedServiceRegistry) GetServicesByModule(moduleName string) []string

+ func (r *EnhancedServiceRegistry) RegisterService(name string, service any) (string, error)

+ func (r *EnhancedServiceRegistry) SetCurrentModule(module Module)

+ type InterfaceMatch struct

+ Consumer string

+ InterfaceType reflect.Type

+ Provider string

+ Required bool

+ ServiceName string

+ type ModuleLifecyclePayload struct

+ Action string

+ Metadata map[string]interface{}

+ Name string

+ Subject string

+ Timestamp time.Time

+ Version string

+ type ServiceIntrospector interface

+ GetServiceEntry func(serviceName string) (*ServiceRegistryEntry, bool)

+ GetServicesByInterface func(interfaceType reflect.Type) []*ServiceRegistryEntry

+ GetServicesByModule func(moduleName string) []string

+ type ServiceIntrospectorImpl struct

+ func (s *ServiceIntrospectorImpl) GetServiceEntry(serviceName string) (*ServiceRegistryEntry, bool)

+ func (s *ServiceIntrospectorImpl) GetServicesByInterface(interfaceType reflect.Type) []*ServiceRegistryEntry

+ func (s *ServiceIntrospectorImpl) GetServicesByModule(moduleName string) []string

+ type ServiceRegistryEntry struct

+ ActualName string

+ ModuleName string

+ ModuleType reflect.Type

+ OriginalName string

+ Service any

type StdApplication

+ func (app *StdApplication) ServiceIntrospector() ServiceIntrospector

+ func (app *StdApplication) SetConfigFeeders(feeders []Feeder)

v1.4.1

Sep 3, 2025

Changes in this version

+ var ErrNoSubjectForEventEmission = errors.New("no subject available for event emission")

+ func DetectBaseConfigStructure() bool

+ func GetBaseConfigFeeder() feeders.Feeder

+ func HandleEventEmissionError(err error, logger Logger, moduleName, eventType string) bool

+ func IsBaseConfigEnabled() bool

+ func IsSynchronousNotification(ctx context.Context) bool

+ func SetBaseConfig(configDir, environment string)

+ func WithSynchronousNotification(ctx context.Context) context.Context

+ type BaseConfigOptions struct

+ ConfigDir string

+ Enabled bool

+ Environment string

+ var BaseConfigSettings BaseConfigOptions

+ type BaseLoggerDecorator struct

+ func NewBaseLoggerDecorator(inner Logger) *BaseLoggerDecorator

+ func (d *BaseLoggerDecorator) Debug(msg string, args ...any)

+ func (d *BaseLoggerDecorator) Error(msg string, args ...any)

+ func (d *BaseLoggerDecorator) GetInnerLogger() Logger

+ func (d *BaseLoggerDecorator) Info(msg string, args ...any)

+ func (d *BaseLoggerDecorator) Warn(msg string, args ...any)

type ComplexFeeder

+ func GetBaseConfigComplexFeeder() ComplexFeeder

+ type DualWriterLoggerDecorator struct

+ func NewDualWriterLoggerDecorator(primary, secondary Logger) *DualWriterLoggerDecorator

+ func (d *DualWriterLoggerDecorator) Debug(msg string, args ...any)

+ func (d *DualWriterLoggerDecorator) Error(msg string, args ...any)

+ func (d *DualWriterLoggerDecorator) Info(msg string, args ...any)

+ func (d *DualWriterLoggerDecorator) Warn(msg string, args ...any)

+ type EventValidationObserver struct

+ func NewEventValidationObserver(id string, expectedEvents []string) *EventValidationObserver

+ func (v *EventValidationObserver) GetAllEvents() []cloudevents.Event

+ func (v *EventValidationObserver) GetMissingEvents() []string

+ func (v *EventValidationObserver) GetUnexpectedEvents() []string

+ func (v *EventValidationObserver) ObserverID() string

+ func (v *EventValidationObserver) OnEvent(ctx context.Context, event cloudevents.Event) error

+ func (v *EventValidationObserver) Reset()

+ type FilterLoggerDecorator struct

+ func NewFilterLoggerDecorator(inner Logger, messageFilters []string, keyFilters map[string]string, ...) *FilterLoggerDecorator

+ func (d *FilterLoggerDecorator) Debug(msg string, args ...any)

+ func (d *FilterLoggerDecorator) Error(msg string, args ...any)

+ func (d *FilterLoggerDecorator) Info(msg string, args ...any)

+ func (d *FilterLoggerDecorator) Warn(msg string, args ...any)

+ type LevelModifierLoggerDecorator struct

+ func NewLevelModifierLoggerDecorator(inner Logger, levelMappings map[string]string) *LevelModifierLoggerDecorator

+ func (d *LevelModifierLoggerDecorator) Debug(msg string, args ...any)

+ func (d *LevelModifierLoggerDecorator) Error(msg string, args ...any)

+ func (d *LevelModifierLoggerDecorator) Info(msg string, args ...any)

+ func (d *LevelModifierLoggerDecorator) Warn(msg string, args ...any)

+ type LoggerDecorator interface

+ GetInnerLogger func() Logger

type ObservableModule

+ GetRegisteredEventTypes func() []string

+ type PrefixLoggerDecorator struct

+ func NewPrefixLoggerDecorator(inner Logger, prefix string) *PrefixLoggerDecorator

+ func (d *PrefixLoggerDecorator) Debug(msg string, args ...any)

+ func (d *PrefixLoggerDecorator) Error(msg string, args ...any)

+ func (d *PrefixLoggerDecorator) Info(msg string, args ...any)

+ func (d *PrefixLoggerDecorator) Warn(msg string, args ...any)

type StdApplication

+ func (app *StdApplication) InitWithApp(appToPass Application) error

+ type ValueInjectionLoggerDecorator struct

+ func NewValueInjectionLoggerDecorator(inner Logger, injectedArgs ...any) *ValueInjectionLoggerDecorator

+ func (d *ValueInjectionLoggerDecorator) Debug(msg string, args ...any)

+ func (d *ValueInjectionLoggerDecorator) Error(msg string, args ...any)

+ func (d *ValueInjectionLoggerDecorator) Info(msg string, args ...any)

+ func (d *ValueInjectionLoggerDecorator) Warn(msg string, args ...any)

v1.4.0

Aug 3, 2025

Changes in this version

+ const EventTypeApplicationFailed

+ const EventTypeApplicationStarted

+ const EventTypeApplicationStopped

+ const EventTypeConfigChanged

+ const EventTypeConfigLoaded

+ const EventTypeConfigValidated

+ const EventTypeModuleFailed

+ const EventTypeModuleInitialized

+ const EventTypeModuleRegistered

+ const EventTypeModuleStarted

+ const EventTypeModuleStopped

+ const EventTypeServiceRegistered

+ const EventTypeServiceRequested

+ const EventTypeServiceUnregistered

+ var ErrLoggerNotSet = errors.New("logger not set in application builder")

+ func NewCloudEvent(eventType, source string, data interface{}, metadata map[string]interface{}) cloudevents.Event

+ func ValidateCloudEvent(event cloudevents.Event) error

+ type ApplicationBuilder struct

+ func (b *ApplicationBuilder) Build() (Application, error)

+ type ApplicationDecorator interface

+ GetInnerApplication func() Application

+ type BaseApplicationDecorator struct

+ func NewBaseApplicationDecorator(inner Application) *BaseApplicationDecorator

+ func (d *BaseApplicationDecorator) ConfigProvider() ConfigProvider

+ func (d *BaseApplicationDecorator) ConfigSections() map[string]ConfigProvider

+ func (d *BaseApplicationDecorator) GetConfigSection(section string) (ConfigProvider, error)

+ func (d *BaseApplicationDecorator) GetInnerApplication() Application

+ func (d *BaseApplicationDecorator) GetObservers() []ObserverInfo

+ func (d *BaseApplicationDecorator) GetService(name string, target any) error

+ func (d *BaseApplicationDecorator) GetTenantConfig(tenantID TenantID, section string) (ConfigProvider, error)

+ func (d *BaseApplicationDecorator) GetTenantService() (TenantService, error)

+ func (d *BaseApplicationDecorator) Init() error

+ func (d *BaseApplicationDecorator) IsVerboseConfig() bool

+ func (d *BaseApplicationDecorator) Logger() Logger

+ func (d *BaseApplicationDecorator) NotifyObservers(ctx context.Context, event cloudevents.Event) error

+ func (d *BaseApplicationDecorator) RegisterConfigSection(section string, cp ConfigProvider)

+ func (d *BaseApplicationDecorator) RegisterModule(module Module)

+ func (d *BaseApplicationDecorator) RegisterObserver(observer Observer, eventTypes ...string) error

+ func (d *BaseApplicationDecorator) RegisterService(name string, service any) error

+ func (d *BaseApplicationDecorator) Run() error

+ func (d *BaseApplicationDecorator) SetLogger(logger Logger)

+ func (d *BaseApplicationDecorator) SetVerboseConfig(enabled bool)

+ func (d *BaseApplicationDecorator) Start() error

+ func (d *BaseApplicationDecorator) Stop() error

+ func (d *BaseApplicationDecorator) SvcRegistry() ServiceRegistry

+ func (d *BaseApplicationDecorator) UnregisterObserver(observer Observer) error

+ func (d *BaseApplicationDecorator) WithTenant(tenantID TenantID) (*TenantContext, error)

+ type CloudEvent = cloudevents.Event

type Config

+ func (c *Config) FeedWithModuleContext(target interface{}, moduleName string) error

+ type ConfigDecorator interface

+ DecorateConfig func(base ConfigProvider) ConfigProvider

+ Name func() string

+ func InstanceAwareConfig() ConfigDecorator

+ func TenantAwareConfigDecorator(loader TenantLoader) ConfigDecorator

+ type FunctionalObserver struct

+ func (f *FunctionalObserver) ObserverID() string

+ func (f *FunctionalObserver) OnEvent(ctx context.Context, event cloudevents.Event) error

+ type ModuleAwareFeeder interface

+ FeedWithModuleContext func(structure interface{}, moduleName string) error

+ type ObservableApplication struct

+ func NewObservableApplication(cp ConfigProvider, logger Logger) *ObservableApplication

+ func (app *ObservableApplication) GetObservers() []ObserverInfo

+ func (app *ObservableApplication) Init() error

+ func (app *ObservableApplication) NotifyObservers(ctx context.Context, event cloudevents.Event) error

+ func (app *ObservableApplication) RegisterModule(module Module)

+ func (app *ObservableApplication) RegisterObserver(observer Observer, eventTypes ...string) error

+ func (app *ObservableApplication) RegisterService(name string, service any) error

+ func (app *ObservableApplication) Start() error

+ func (app *ObservableApplication) Stop() error

+ func (app *ObservableApplication) UnregisterObserver(observer Observer) error

+ type ObservableDecorator struct

+ func NewObservableDecorator(inner Application, observers ...ObserverFunc) *ObservableDecorator

+ func (d *ObservableDecorator) AddObserver(observer ObserverFunc)

+ func (d *ObservableDecorator) Init() error

+ func (d *ObservableDecorator) RemoveObserver(observer ObserverFunc)

+ func (d *ObservableDecorator) Start() error

+ func (d *ObservableDecorator) Stop() error

+ type ObservableModule interface

+ EmitEvent func(ctx context.Context, event cloudevents.Event) error

+ RegisterObservers func(subject Subject) error

+ type Observer interface

+ ObserverID func() string

+ OnEvent func(ctx context.Context, event cloudevents.Event) error

+ func NewFunctionalObserver(id string, handler func(ctx context.Context, event cloudevents.Event) error) Observer

+ type ObserverFunc func(ctx context.Context, event cloudevents.Event) error

+ type ObserverInfo struct

+ EventTypes []string

+ ID string

+ RegisteredAt time.Time

+ type Option func(*ApplicationBuilder) error

+ func WithBaseApplication(base Application) Option

+ func WithConfigDecorators(decorators ...ConfigDecorator) Option

+ func WithConfigProvider(provider ConfigProvider) Option

+ func WithLogger(logger Logger) Option

+ func WithModules(modules ...Module) Option

+ func WithObserver(observers ...ObserverFunc) Option

+ func WithTenantAware(loader TenantLoader) Option

+ type Subject interface

+ GetObservers func() []ObserverInfo

+ NotifyObservers func(ctx context.Context, event cloudevents.Event) error

+ RegisterObserver func(observer Observer, eventTypes ...string) error

+ UnregisterObserver func(observer Observer) error

+ type Tenant struct

+ ID TenantID

+ Name string

+ type TenantAwareDecorator struct

+ func NewTenantAwareDecorator(inner Application, loader TenantLoader) *TenantAwareDecorator

+ func (d *TenantAwareDecorator) GetTenantConfig(tenantID TenantID, section string) (ConfigProvider, error)

+ func (d *TenantAwareDecorator) GetTenantService() (TenantService, error)

+ func (d *TenantAwareDecorator) Start() error

+ func (d *TenantAwareDecorator) WithTenant(tenantID TenantID) (*TenantContext, error)

+ type TenantLoader interface

+ LoadTenants func() ([]Tenant, error)

v1.3.9

Jul 10, 2025

v1.3.8

Jul 10, 2025

v1.3.7

Jul 10, 2025

v1.3.6

Jul 9, 2025

v1.3.5

Jul 9, 2025

v1.3.4

Jul 9, 2025

Changes in this version

type Config

+ Feeders []Feeder

+ FieldTracker FieldTracker

+ func (c *Config) SetFieldTracker(tracker FieldTracker) *Config

+ type DefaultFieldTracker struct

+ FieldPopulations []FieldPopulation

+ func NewDefaultFieldTracker() *DefaultFieldTracker

+ func (t *DefaultFieldTracker) GetFieldPopulation(fieldPath string) *FieldPopulation

+ func (t *DefaultFieldTracker) GetPopulationsByFeeder(feederType string) []FieldPopulation

+ func (t *DefaultFieldTracker) GetPopulationsBySource(sourceType string) []FieldPopulation

+ func (t *DefaultFieldTracker) RecordFieldPopulation(fp FieldPopulation)

+ func (t *DefaultFieldTracker) SetLogger(logger Logger)

type Feeder

+ Feed func(structure interface{}) error

+ type FieldPopulation struct

+ FeederType string

+ FieldName string

+ FieldPath string

+ FieldType string

+ FoundKey string

+ InstanceKey string

+ SearchKeys []string

+ SourceKey string

+ SourceType string

+ Value interface{}

+ type FieldTracker interface

+ RecordFieldPopulation func(fp FieldPopulation)

+ SetLogger func(logger Logger)

+ type FieldTrackerBridge struct

+ func NewFieldTrackerBridge(mainTracker FieldTracker) *FieldTrackerBridge

+ func (b *FieldTrackerBridge) RecordFieldPopulation(fp feeders.FieldPopulation)

+ type FieldTrackingFeeder interface

+ SetFieldTracker func(tracker FieldTracker)

+ type StructStateDiffer struct

+ func NewStructStateDiffer(tracker FieldTracker, logger Logger) *StructStateDiffer

+ func (d *StructStateDiffer) CaptureAfterStateAndDiff(structure interface{}, prefix string, feederType, sourceType string)

+ func (d *StructStateDiffer) CaptureBeforeState(structure interface{}, prefix string)

+ func (d *StructStateDiffer) Reset()

v1.3.3

Jul 8, 2025

Changes in this version

type Application

+ IsVerboseConfig func() bool

+ SetVerboseConfig func(enabled bool)

type Config

+ Logger Logger

+ VerboseDebug bool

+ func (c *Config) AddFeeder(feeder Feeder) *Config

+ func (c *Config) SetVerboseDebug(enabled bool, logger Logger) *Config

type StdApplication

+ func (app *StdApplication) IsVerboseConfig() bool

+ func (app *StdApplication) SetVerboseConfig(enabled bool)

+ type VerboseAwareFeeder interface

+ SetVerboseDebug func(enabled bool, logger interface{ ... })

+ type VerboseLogger interface

+ Debug func(msg string, args ...any)

v1.3.2

Jun 28, 2025

v1.3.1

Jun 27, 2025

Changes in this version

+ type InstanceAwareConfigProvider struct

+ func NewInstanceAwareConfigProvider(cfg any, prefixFunc InstancePrefixFunc) *InstanceAwareConfigProvider

+ func (p *InstanceAwareConfigProvider) GetConfig() any

+ func (p *InstanceAwareConfigProvider) GetInstancePrefixFunc() InstancePrefixFunc

+ type InstanceAwareConfigSupport interface

+ GetInstanceConfigs func() map[string]interface{}

+ type InstanceAwareFeeder interface

+ FeedInstances func(instances interface{}) error

+ func NewInstanceAwareEnvFeeder(prefixFunc InstancePrefixFunc) InstanceAwareFeeder

+ type InstancePrefixFunc = feeders.InstancePrefixFunc

v1.3.0

Jun 11, 2025

Changes in this version

+ var ErrConstructorInvalidReturnCount = errors.New("constructor must return exactly two values (Module, error)")

+ var ErrConstructorInvalidReturnType = errors.New("constructor must return a Module as first value")

+ var ErrConstructorNotFunction = errors.New("constructor must be a function")

+ var ErrConstructorParameterServiceNotFound = errors.New("no service found for constructor parameter")

+ var ErrFieldCannotBeSet = errors.New("field cannot be set")

+ var ErrInterfaceConfigurationNil = errors.New("SatisfiesInterface is nil")

+ var ErrInterfaceConfigurationNotInterface = errors.New("SatisfiesInterface is not an interface type")

+ var ErrInvalidInterfaceConfiguration = errors.New("invalid interface configuration for required service")

+ var ErrServiceInterfaceIncompatible = errors.New("service does not implement required interface")

type Application

+ SetLogger func(logger Logger)

type StdApplication

+ func (app *StdApplication) SetLogger(logger Logger)

v1.2.11

Jun 10, 2025

v1.2.10

Jun 10, 2025

v1.2.9

Jun 10, 2025

Changes in this version

+ func CompareModuleInstances(original, current Module, moduleName string)

+ func DebugAllModuleInterfaces(app *StdApplication)

+ func DebugModuleInterfaces(app *StdApplication, moduleName string)

v1.2.8

Jun 9, 2025

v1.2.7

Jun 5, 2025

Changes in this version

+ var ErrUnsupportedExtension = errors.New("unsupported file extension")

v1.2.6

May 26, 2025

Changes in this version

+ var ErrDefaultValueParseError = errors.New("failed to parse default value")

v1.2.5

May 2, 2025

Changes in this version

+ var ErrConfigSectionNotFoundForTenant = errors.New("config section not found for tenant")

+ var ErrDefaultValueOverflowsFloat = errors.New("default float value overflows field type")

+ var ErrDefaultValueOverflowsInt = errors.New("default integer value overflows field type")

+ var ErrDefaultValueOverflowsUint = errors.New("default unsigned integer value overflows field type")

+ var ErrIncompatibleFieldKind = errors.New("incompatible field kind")

+ var ErrInvalidFieldKind = errors.New("invalid field kind")

+ var ErrMockTenantConfigsNotInitialized = errors.New("mock tenant configs not initialized")

+ var ErrUnexpectedFieldKind = errors.New("unexpected field kind")

+ var ErrUnsupportedFormatType = errors.New("unsupported format type")

+ var ErrUnsupportedTypeForDefault = errors.New("unsupported type for default value")

v1.2.4

May 1, 2025

v1.2.3

Apr 26, 2025

Changes in this version

type ServiceDependency

+ MatchByInterface bool

v1.2.2

Apr 17, 2025

Changes in this version

+ var ErrConfigInvalidFormat = errors.New("invalid configuration format")

+ var ErrConfigNotPointer = errors.New("config must be a non-nil pointer")

+ var ErrConfigNotStruct = errors.New("config must be a struct")

+ var ErrConfigRequiredFieldMissing = errors.New("required field(s) missing in config")

+ var ErrConfigValidationFailed = errors.New("configuration validation failed")

+ func GenerateSampleConfig(cfg interface{}, format string) ([]byte, error)

+ func ProcessConfigDefaults(cfg interface{}) error

+ func SaveSampleConfig(cfg interface{}, format, filePath string) error

+ func ValidateConfig(cfg interface{}) error

+ func ValidateConfigRequired(cfg interface{}) error

+ type ConfigValidator interface

+ Validate func() error

v1.2.1

Apr 7, 2025

v1.2.0

Apr 5, 2025

Changes in this version

+ type Configurable interface

+ RegisterConfig func(app Application) error

+ type Constructable interface

+ Constructor func() ModuleConstructor

+ type DependencyAware interface

+ Dependencies func() []string

+ type ServiceAware interface

+ ProvidesServices func() []ServiceProvider

+ RequiresServices func() []ServiceDependency

+ type Startable interface

+ Start func(ctx context.Context) error

+ type Stoppable interface

+ Stop func(ctx context.Context) error

type TenantService

+ RegisterTenantAwareModule func(module TenantAwareModule) error

v1.1.3

Apr 3, 2025

v1.1.2

Apr 3, 2025

v1.1.1

Apr 2, 2025

Changes in this version

+ var ErrCreatedNilProvider = errors.New("created nil provider for tenant section")

+ var ErrIncompatibleFieldTypes = errors.New("incompatible types for field assignment")

+ var ErrIncompatibleInterfaceValue = errors.New("incompatible interface value for field")

+ var ErrTenantSectionConfigNil = errors.New("tenant section config is nil after feeding")

v1.1.0

Apr 2, 2025

Changes in this version

+ var ErrAppContextNotInitialized = errors.New("application context not initialized")

+ var ErrApplicationNil = errors.New("application is nil")

+ var ErrCannotCopyMapToStruct = errors.New("cannot copy from map to non-struct")

+ var ErrCircularDependency = errors.New("circular dependency detected")

+ var ErrConfigCastFailed = errors.New("failed to cast config to expected type")

+ var ErrConfigFeederError = errors.New("config: feeder error")

+ var ErrConfigNil = errors.New("cannot create temp config: config is nil")

+ var ErrConfigNilPointer = errors.New("cannot create temp config: config pointer is nil")

+ var ErrConfigProviderNil = errors.New("failed to load app config: config provider is nil")

+ var ErrConfigSectionError = errors.New("failed to load app config: error triggered by section")

+ var ErrConfigSectionNotFound = errors.New("config section not found")

+ var ErrConfigSetupError = errors.New("config: setup error")

+ var ErrDestinationNotPointer = errors.New("destination must be a pointer")

+ var ErrFeedFailed = errors.New("feed error")

+ var ErrFeedKeyFailed = errors.New("feedKey error")

+ var ErrModuleDependencyMissing = errors.New("module depends on non-existent module")

+ var ErrOriginalOrLoadedNil = errors.New("original or loaded config is nil")

+ var ErrRequiredServiceNotFound = errors.New("required service not found for module")

+ var ErrServiceAlreadyRegistered = errors.New("service already registered")

+ var ErrServiceIncompatible = errors.New("service cannot be assigned to target")

+ var ErrServiceNil = errors.New("service is nil")

+ var ErrServiceNotFound = errors.New("service not found")

+ var ErrServiceWrongInterface = errors.New("service doesn't satisfy required interface")

+ var ErrServiceWrongType = errors.New("service doesn't satisfy required type")

+ var ErrSetupFailed = errors.New("setup error")

+ var ErrTargetNotPointer = errors.New("target must be a non-nil pointer")

+ var ErrTargetValueInvalid = errors.New("target value is invalid")

+ var ErrTenantConfigNotFound = errors.New("tenant config section not found")

+ var ErrTenantConfigProviderNil = errors.New("tenant config provider is nil")

+ var ErrTenantConfigValueNil = errors.New("tenant config value is nil")

+ var ErrTenantNotFound = errors.New("tenant not found")

+ var ErrTenantRegisterNilConfig = errors.New("cannot register nil config for tenant")

+ var ErrUnsupportedSourceType = errors.New("unsupported source type")

+ func LoadTenantConfigs(app Application, tenantService TenantService, params TenantConfigParams) error

type Application

+ func NewStdApplication(cp ConfigProvider, logger Logger) Application

+ ConfigSections func() map[string]ConfigProvider

+ type FileBasedTenantConfigLoader struct

+ func DefaultTenantConfigLoader(configDir string) *FileBasedTenantConfigLoader

+ func NewFileBasedTenantConfigLoader(params TenantConfigParams) *FileBasedTenantConfigLoader

+ func (l *FileBasedTenantConfigLoader) LoadTenantConfigurations(app Application, tenantService TenantService) error

+ type StandardTenantService struct

+ func NewStandardTenantService(logger Logger) *StandardTenantService

+ func (ts *StandardTenantService) GetTenantConfig(tenantID TenantID, section string) (ConfigProvider, error)

+ func (ts *StandardTenantService) GetTenants() []TenantID

+ func (ts *StandardTenantService) RegisterTenant(tenantID TenantID, configs map[string]ConfigProvider) error

+ func (ts *StandardTenantService) RegisterTenantAwareModule(module TenantAwareModule)

+ func (ts *StandardTenantService) RegisterTenantConfigSection(tenantID TenantID, section string, provider ConfigProvider) error

+ func (ts *StandardTenantService) RemoveTenant(tenantID TenantID) error

+ type StdApplication struct

+ func (app *StdApplication) ConfigProvider() ConfigProvider

+ func (app *StdApplication) ConfigSections() map[string]ConfigProvider

+ func (app *StdApplication) GetConfigSection(section string) (ConfigProvider, error)

+ func (app *StdApplication) GetService(name string, target any) error

+ func (app *StdApplication) GetTenantConfig(tenantID TenantID, section string) (ConfigProvider, error)

+ func (app *StdApplication) GetTenantService() (TenantService, error)

+ func (app *StdApplication) Init() error

+ func (app *StdApplication) Logger() Logger

+ func (app *StdApplication) RegisterConfigSection(section string, cp ConfigProvider)

+ func (app *StdApplication) RegisterModule(module Module)

+ func (app *StdApplication) RegisterService(name string, service any) error

+ func (app *StdApplication) Run() error

+ func (app *StdApplication) Start() error

+ func (app *StdApplication) Stop() error

+ func (app *StdApplication) SvcRegistry() ServiceRegistry

+ func (app *StdApplication) WithTenant(tenantID TenantID) (*TenantContext, error)

+ type TenantApplication interface

+ GetTenantConfig func(tenantID TenantID, section string) (ConfigProvider, error)

+ GetTenantService func() (TenantService, error)

+ WithTenant func(tenantID TenantID) (*TenantContext, error)

+ type TenantAwareConfig struct

+ func NewTenantAwareConfig(defaultConfig ConfigProvider, tenantService TenantService, ...) *TenantAwareConfig

+ func (tac *TenantAwareConfig) GetConfig() any

+ func (tac *TenantAwareConfig) GetConfigWithContext(ctx context.Context) any

+ type TenantAwareModule interface

+ OnTenantRegistered func(tenantID TenantID)

+ OnTenantRemoved func(tenantID TenantID)

+ type TenantAwareRegistry interface

+ GetServiceForTenant func(name string, tenantID TenantID, target any) error

+ type TenantConfigLoader interface

+ LoadTenantConfigurations func(app Application, tenantService TenantService) error

+ type TenantConfigParams struct

+ ConfigDir string

+ ConfigFeeders []Feeder

+ ConfigNameRegex *regexp.Regexp

+ type TenantConfigProvider struct

+ func NewTenantConfigProvider(defaultConfig ConfigProvider) *TenantConfigProvider

+ func (tcp *TenantConfigProvider) GetConfig() any

+ func (tcp *TenantConfigProvider) GetDefaultConfig() ConfigProvider

+ func (tcp *TenantConfigProvider) GetTenantConfig(tenantID TenantID, section string) (ConfigProvider, error)

+ func (tcp *TenantConfigProvider) HasTenantConfig(tenantID TenantID, section string) bool

+ func (tcp *TenantConfigProvider) SetTenantConfig(tenantID TenantID, section string, provider ConfigProvider)

+ type TenantContext struct

+ func NewTenantContext(ctx context.Context, tenantID TenantID) *TenantContext

+ func (tc *TenantContext) GetTenantID() TenantID

+ type TenantID string

+ func GetTenantIDFromContext(ctx context.Context) (TenantID, bool)

+ type TenantService interface

+ GetTenantConfig func(tenantID TenantID, section string) (ConfigProvider, error)

+ GetTenants func() []TenantID

+ RegisterTenant func(tenantID TenantID, configs map[string]ConfigProvider) error

v1.0.0

Mar 28, 2025

Changes in this version

+ type ConfigSetup interface

+ Setup func() error

+ type LoadAppConfigFunc func(*Application) error

+ var AppConfigLoader LoadAppConfigFunc = loadAppConfig

+ type ServiceProvider struct

+ Description string

+ Instance any

+ Name string

v0

v0.1.0

Mar 26, 2025

Changes in this version

+ var ConfigFeeders = []Feeder

+ type AppRegistry interface

+ SvcRegistry func() ServiceRegistry

+ type Application struct

+ func NewApplication(cp ConfigProvider, logger Logger) *Application

+ func (app *Application) ConfigProvider() ConfigProvider

+ func (app *Application) GetConfigSection(section string) (ConfigProvider, error)

+ func (app *Application) GetService(name string, target any) error

+ func (app *Application) Init() error

+ func (app *Application) Logger() Logger

+ func (app *Application) RegisterConfigSection(section string, cp ConfigProvider)

+ func (app *Application) RegisterModule(module Module)

+ func (app *Application) RegisterService(name string, service any) error

+ func (app *Application) Run() error

+ func (app *Application) Start() error

+ func (app *Application) Stop() error

+ func (app *Application) SvcRegistry() ServiceRegistry

+ type ComplexFeeder interface

+ FeedKey func(string, interface{}) error

+ type Config struct

+ StructKeys map[string]interface{}

+ func NewConfig() *Config

+ func (c *Config) AddStructKey(key string, target interface{}) *Config

+ func (c *Config) Feed() error

+ type ConfigProvider interface

+ GetConfig func() any

+ type Feeder = config.Feeder

+ type Logger interface

+ Debug func(msg string, args ...any)

+ Error func(msg string, args ...any)

+ Info func(msg string, args ...any)

+ Warn func(msg string, args ...any)

+ type Module interface

+ Dependencies func() []string

+ Init func(app *Application) error

+ Name func() string

+ ProvidesServices func() []Service

+ RegisterConfig func(app *Application)

+ RequiresServices func() []ServiceDependency

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ type ModuleConstructor func(app *Application, services map[string]any) (Module, error)

+ type ModuleRegistry map[string]Module

+ type ModuleWithConstructor interface

+ Constructor func() ModuleConstructor

+ type Service struct

+ Description string

+ Instance any

+ Name string

+ type ServiceDependency struct

+ Name string

+ Required bool

+ SatisfiesInterface reflect.Type

+ Type reflect.Type

+ type ServiceRegistry map[string]any

+ type StdConfigProvider struct

+ func NewStdConfigProvider(cfg any) *StdConfigProvider

+ func (s *StdConfigProvider) GetConfig() any

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL