modular

package module

Go to main page

Versions in this module

v1

v1.4.3

Sep 11, 2025

Changes in this version

+ const EventTypeApplicationFailed

+ const EventTypeApplicationStarted

+ const EventTypeApplicationStopped

+ const EventTypeConfigChanged

+ const EventTypeConfigLoaded

+ const EventTypeConfigReloadFailed

+ const EventTypeConfigReloadNoop

+ const EventTypeConfigReloadStart

+ const EventTypeConfigReloadSuccess

+ const EventTypeConfigValidated

+ const EventTypeHealthAggregateUpdated

+ const EventTypeModuleFailed

+ const EventTypeModuleInitialized

+ const EventTypeModuleRegistered

+ const EventTypeModuleStarted

+ const EventTypeModuleStopped

+ const EventTypeServiceRegistered

+ const EventTypeServiceRequested

+ const EventTypeServiceUnregistered

+ const ModuleLifecycleSchema

+ 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 ErrLoggerNotSet = errors.New("logger not set in application builder")

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

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

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

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

+ 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 DetectBaseConfigStructure() bool

+ func EnableMemguardForTesting(provider SecretProvider)

+ func GetBaseConfigFeeder() feeders.Feeder

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

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

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

+ func InitializeSecretProvider(config SecretProviderConfig, logger Logger) error

+ func IsBaseConfigEnabled() bool

+ func IsErrCircularDependency(err error) bool

+ func IsSynchronousNotification(ctx context.Context) bool

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

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

+ 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 SetBaseConfig(configDir, environment string)

+ func ValidateCloudEvent(event cloudevents.Event) error

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

+ func WithSynchronousNotification(ctx context.Context) 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

+ ServiceIntrospector func() ServiceIntrospector

+ type ApplicationBuilder struct

+ func NewApplicationBuilder() *ApplicationBuilder

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

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

+ type ApplicationBuilderExtension struct

+ type ApplicationDecorator interface

+ GetInnerApplication func() Application

+ type ApplicationOption func(*StdApplication) error

+ func WithDynamicReload(config DynamicReloadConfig) ApplicationOption

+ func WithHealthAggregator(config HealthAggregatorConfig) ApplicationOption

+ 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) GetTenantGuard() TenantGuard

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

+ func (d *BaseApplicationDecorator) Health() (HealthAggregator, 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) RegisterHealthProvider(moduleName string, provider HealthProvider, optional bool) error

+ 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) RequestReload(sections ...string) error

+ func (d *BaseApplicationDecorator) Run() error

+ func (d *BaseApplicationDecorator) ServiceIntrospector() ServiceIntrospector

+ 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 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 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 CloudEvent = cloudevents.Event

type ComplexFeeder

+ func GetBaseConfigComplexFeeder() ComplexFeeder

type Config

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

+ type ConfigChange struct

+ FieldPath string

+ NewValue any

+ OldValue any

+ Section string

+ Source string

+ type ConfigDecorator interface

+ DecorateConfig func(base ConfigProvider) ConfigProvider

+ Name func() string

+ func InstanceAwareConfig() ConfigDecorator

+ func TenantAwareConfigDecorator(loader TenantLoader) ConfigDecorator

+ 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 DefaultFieldTracker

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

+ type DependencyEdge struct

+ From string

+ InterfaceType reflect.Type

+ ServiceName string

+ To string

+ Type EdgeType

+ 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 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 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 EventObserver interface

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

+ 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 FieldChange struct

+ ChangeType ChangeType

+ FieldPath string

+ IsSensitive bool

+ NewValue interface{}

+ OldValue interface{}

+ ValidationResult *ValidationResult

+ 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 FunctionalObserver struct

+ func (f *FunctionalObserver) ObserverID() string

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

+ 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 InterfaceMatch struct

+ Consumer string

+ InterfaceType reflect.Type

+ Provider string

+ Required bool

+ ServiceName string

+ 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 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 ModuleAwareFeeder interface

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

+ type ModuleLifecyclePayload struct

+ Action string

+ Metadata map[string]interface{}

+ Name string

+ Subject string

+ Timestamp time.Time

+ Version string

+ 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

+ GetRegisteredEventTypes func() []string

+ 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 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 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

+ func WithTenantGuardMode(mode TenantGuardMode) Option

+ func WithTenantGuardModeConfig(config TenantGuardConfig) Option

+ 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 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 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 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) InitWithApp(appToPass Application) error

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

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

+ func (app *StdApplication) ServiceIntrospector() ServiceIntrospector

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

+ type StdDynamicFieldParser struct

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

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

+ 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) GetTenantGuard() TenantGuard

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

+ func (d *TenantAwareDecorator) Start() error

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

+ 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 TenantLoader interface

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

+ 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

+ 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.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