config

package

Go to main page

Versions in this module

v0

v0.27.0

Sep 17, 2023

v0.26.0

Jun 9, 2023

Changes in this version

+ var ErrInvalidEmptyPath = fmt.Errorf("invalid empty config path")

type Partial

+ func (p *Partial) Set(path string, value interface{}) (*Partial, error)

v0.25.0

Jun 8, 2023

v0.24.0

Jun 8, 2023

v0.23.0

May 29, 2023

Changes in this version

+ const UnknownDecoder

+ const UnknownSource

type Config

+ func NewConfig() *Config

+ func (c *Config) AddObserver(path string, callback Observer) error

+ func (c *Config) AddSource(id string, priority int, src Source) error

+ func (c *Config) Close() error

+ func (c *Config) HasObserver(path string) bool

+ func (c *Config) HasSource(id string) bool

+ func (c *Config) Partial(path string, def ...Partial) (*Partial, error)

+ func (c *Config) RemoveAllSources() error

+ func (c *Config) RemoveObserver(path string)

+ func (c *Config) RemoveSource(id string) error

+ func (c *Config) Source(id string) (Source, error)

+ func (c *Config) SourcePriority(id string, priority int) error

+ type Decoder interface

+ Decode func() (*Partial, error)

+ type DecoderStrategy interface

+ Accept func(format string) bool

+ Create func(args ...interface{}) (Decoder, error)

+ type ObsSource interface

+ Reload func() (bool, error)

+ type Observer func(interface{}, interface{})

type Partial

+ func (p *Partial) Entries() []string

+ func (p *Partial) Merge(src Partial)

+ func (p *Partial) Populate(path string, data interface{}, icase ...bool) (interface{}, error)

+ type SourceStrategy interface

+ Accept func(cfg *Partial) bool

+ Create func(cfg *Partial) (Source, error)

v0.22.0

May 10, 2023

Changes in this version

+ func Convert(val interface{}) interface

type Config

+ func (c *Config) Merge(src Config)

+ type IObsSource interface

+ Reload func() (bool, error)

v0.21.1

Apr 9, 2023

v0.21.0

Apr 6, 2023

v0.20.0

Mar 10, 2023

Changes in this version

+ const AggregateSourceType

+ const DirectorySourceType

+ const EnvironmentSourceType

+ const FileSourceType

+ const JSONDecoderFormat

+ const ObservableFileSourceType

+ const ObservableRestSourceType

+ const RestSourceType

+ const UnknownDecoderFormat

+ const UnknownSourceType

+ const YAMLDecoderFormat

+ var ErrDuplicateSource = fmt.Errorf("config source already registered")

+ var ErrInvalidFormat = fmt.Errorf("invalid config format")

+ var ErrInvalidSource = fmt.Errorf("invalid config source")

+ var ErrPathNotFound = fmt.Errorf("config path not found")

+ var ErrRestConfigNotFound = fmt.Errorf("rest config source config not found")

+ var ErrRestTimestampNotFound = fmt.Errorf("rest config source timestamp not found")

+ var ErrSourceNotFound = fmt.Errorf("config source not found")

type EnvSourceStrategy

+ func NewEnvSourceStrategy() *EnvSourceStrategy

type IDecoderFactory

+ func NewDecoderFactory() IDecoderFactory

type ISourceFactory

+ func NewSourceFactory() ISourceFactory

type JSONDecoderStrategy

+ func NewJSONDecoderStrategy() *JSONDecoderStrategy

type YAMLDecoderStrategy

+ func NewYAMLDecoderStrategy() *YAMLDecoderStrategy

v0.19.0

Feb 9, 2023

Changes in this version

type Config

+ func (c *Config) Entries() []string

type IConfig

+ Entries func() []string

type Manager

+ func (m *Manager) Entries() []string

v0.18.0

Feb 6, 2023

Changes in this version

+ const SourceStrategyAggregate

+ const SourceStrategyDirectory

+ const SourceStrategyEnvironment

+ const SourceStrategyFile

+ const SourceStrategyObservableFile

+ const SourceStrategyObservableRest

+ const SourceStrategyRest

+ const SourceStrategyUnknown

v0.17.1

Jan 22, 2023

v0.17.0

Dec 15, 2022

v0.16.0

Dec 14, 2022

Changes in this version

+ const AggregateSourceStrategyID

+ const AggregateSourceTag

+ const DecoderFactoryID

+ const DecoderStrategyTag

+ const DirSourceStrategyID

+ const EnvSourceStrategyID

+ const FileSourceStrategyID

+ const FormatJSON

+ const FormatUnknown

+ const FormatYAML

+ const ID

+ const JSONDecoderStrategyID

+ const LoaderID

+ const ObservableFileSourceStrategyID

+ const ObservableRestSourceStrategyID

+ const RestSourceStrategyID

+ const SourceAggregate

+ const SourceDirectory

+ const SourceEnv

+ const SourceFactoryID

+ const SourceFile

+ const SourceObservableFile

+ const SourceObservableRest

+ const SourceRest

+ const SourceStrategyTag

+ const SourceUnknown

+ const YAMLDecoderStrategyID

+ type AggregateSource struct

+ func NewAggregateSource(configs []IConfig) (*AggregateSource, error)

+ type AggregateSourceStrategy struct

+ func (s AggregateSourceStrategy) Accept(config IConfig) bool

+ func (s AggregateSourceStrategy) Create(_ IConfig) (ISource, error)

+ type Config map[interface{}]interface

+ func (c *Config) Bool(path string, def ...bool) (bool, error)

+ func (c *Config) Config(path string, def ...Config) (IConfig, error)

+ func (c *Config) Float(path string, def ...float64) (float64, error)

+ func (c *Config) Get(path string, def ...interface{}) (interface{}, error)

+ func (c *Config) Has(path string) bool

+ func (c *Config) Int(path string, def ...int) (int, error)

+ func (c *Config) List(path string, def ...[]interface{}) ([]interface{}, error)

+ func (c *Config) Populate(path string, data interface{}, icase ...bool) (interface{}, error)

+ func (c *Config) String(path string, def ...string) (string, error)

+ func (c Config) Clone() Config

+ type DecoderFactory []IDecoderStrategy

+ func (f *DecoderFactory) Register(strategy IDecoderStrategy) error

+ func (f DecoderFactory) Create(format string, args ...interface{}) (IDecoder, error)

+ type DirSource struct

+ func NewDirSource(path, format string, recursive bool, fs afero.Fs, ...) (*DirSource, error)

+ type DirSourceStrategy struct

+ func NewDirSourceStrategy(fs afero.Fs, decoderFactory IDecoderFactory) (*DirSourceStrategy, error)

+ func (s DirSourceStrategy) Accept(config IConfig) bool

+ func (s DirSourceStrategy) Create(config IConfig) (ISource, error)

+ type EnvSource struct

+ func NewEnvSource(mappings map[string]string) (*EnvSource, error)

+ type EnvSourceStrategy struct

+ func (s EnvSourceStrategy) Accept(config IConfig) bool

+ func (s EnvSourceStrategy) Create(config IConfig) (ISource, error)

+ type FileSource struct

+ func NewFileSource(path, format string, fs afero.Fs, decoderFactory IDecoderFactory) (*FileSource, error)

+ type FileSourceStrategy struct

+ func NewFileSourceStrategy(fs afero.Fs, decoderFactory IDecoderFactory) (*FileSourceStrategy, error)

+ func (s FileSourceStrategy) Accept(config IConfig) bool

+ func (s FileSourceStrategy) Create(config IConfig) (ISource, error)

type IConfig

+ Config func(path string, def ...Config) (IConfig, error)

+ Populate func(path string, data any, icase ...bool) (any, error)

type IManager

+ AddObserver func(path string, callback IObserver) error

+ HasObserver func(path string) bool

+ RemoveObserver func(path string)

+ type IObservableSource interface

+ Reload func() (bool, error)

+ type JSONDecoder struct

+ func NewJSONDecoder(reader io.Reader) (*JSONDecoder, error)

+ func (d *JSONDecoder) Close() error

+ func (d JSONDecoder) Decode() (IConfig, error)

+ type JSONDecoderStrategy struct

+ func (JSONDecoderStrategy) Accept(format string) bool

+ func (JSONDecoderStrategy) Create(args ...interface{}) (IDecoder, error)

+ type Loader struct

+ func NewLoader(manager IManager, sourceFactory ISourceFactory) (*Loader, error)

+ func (l Loader) Load() error

+ type Manager struct

+ func (m *Manager) AddObserver(path string, callback IObserver) error

+ func (m *Manager) AddSource(id string, priority int, src ISource) error

+ func (m *Manager) Bool(path string, def ...bool) (bool, error)

+ func (m *Manager) Close() error

+ func (m *Manager) Config(path string, def ...Config) (IConfig, error)

+ func (m *Manager) Float(path string, def ...float64) (float64, error)

+ func (m *Manager) Get(path string, def ...interface{}) (interface{}, error)

+ func (m *Manager) Has(path string) bool

+ func (m *Manager) HasObserver(path string) bool

+ func (m *Manager) HasSource(id string) bool

+ func (m *Manager) Int(path string, def ...int) (int, error)

+ func (m *Manager) List(path string, def ...[]interface{}) ([]interface{}, error)

+ func (m *Manager) Populate(path string, data interface{}, icase ...bool) (interface{}, error)

+ func (m *Manager) RemoveAllSources() error

+ func (m *Manager) RemoveObserver(path string)

+ func (m *Manager) RemoveSource(id string) error

+ func (m *Manager) Source(id string) (ISource, error)

+ func (m *Manager) SourcePriority(id string, priority int) error

+ func (m *Manager) String(path string, def ...string) (string, error)

+ type ObservableFileSource struct

+ func NewObservableFileSource(path, format string, fs afero.Fs, decoderFactory IDecoderFactory) (*ObservableFileSource, error)

+ func (s *ObservableFileSource) Reload() (bool, error)

+ type ObservableFileSourceStrategy struct

+ func NewObservableFileSourceStrategy(fs afero.Fs, decoderFactory IDecoderFactory) (*ObservableFileSourceStrategy, error)

+ func (s ObservableFileSourceStrategy) Accept(config IConfig) bool

+ func (s ObservableFileSourceStrategy) Create(config IConfig) (ISource, error)

+ type ObservableRestSource struct

+ func NewObservableRestSource(client httpClient, uri, format string, decoderFactory IDecoderFactory, ...) (*ObservableRestSource, error)

+ func (s *ObservableRestSource) Reload() (bool, error)

+ type ObservableRestSourceStrategy struct

+ func NewObservableRestSourceStrategy(decoderFactory IDecoderFactory) (*ObservableRestSourceStrategy, error)

+ func (s ObservableRestSourceStrategy) Accept(config IConfig) bool

+ func (s ObservableRestSourceStrategy) Create(config IConfig) (ISource, error)

+ type RestSource struct

+ func NewRestSource(client httpClient, uri, format string, decoderFactory IDecoderFactory, ...) (*RestSource, error)

+ type RestSourceStrategy struct

+ func NewRestSourceStrategy(decoderFactory IDecoderFactory) (*RestSourceStrategy, error)

+ func (s RestSourceStrategy) Accept(config IConfig) bool

+ func (s RestSourceStrategy) Create(config IConfig) (ISource, error)

+ type Source struct

+ func (s *Source) Get(path string, def ...interface{}) (interface{}, error)

+ func (s *Source) Has(path string) bool

+ type SourceFactory []ISourceStrategy

+ func (f *SourceFactory) Register(strategy ISourceStrategy) error

+ func (f SourceFactory) Create(config IConfig) (ISource, error)

+ type YAMLDecoder struct

+ func NewYAMLDecoder(reader io.Reader) (*YAMLDecoder, error)

+ func (d *YAMLDecoder) Close() error

+ func (d YAMLDecoder) Decode() (IConfig, error)

+ type YAMLDecoderStrategy struct

+ func (YAMLDecoderStrategy) Accept(format string) bool

+ func (YAMLDecoderStrategy) Create(args ...interface{}) (IDecoder, error)

v0.10.0

Jul 18, 2022

Changes in this version

+ const ContainerDecoderFactoryID

+ const ContainerDecoderStrategyJSONID

+ const ContainerDecoderStrategyTag

+ const ContainerDecoderStrategyYAMLID

+ const ContainerID

+ const ContainerLoaderID

+ const ContainerSourceContainerPartialTag

+ const ContainerSourceFactoryID

+ const ContainerSourceStrategyContainerID

+ const ContainerSourceStrategyDirID

+ const ContainerSourceStrategyEnvID

+ const ContainerSourceStrategyFileID

+ const ContainerSourceStrategyFileObservableID

+ const ContainerSourceStrategyRestID

+ const ContainerSourceStrategyRestObservableID

+ const ContainerSourceStrategyTag

+ const DecoderFormatJSON

+ const DecoderFormatUnknown

+ const DecoderFormatYAML

+ const EnvID

+ const SourceTypeContainer

+ const SourceTypeDirectory

+ const SourceTypeEnv

+ const SourceTypeFile

+ const SourceTypeObservableFile

+ const SourceTypeObservableRest

+ const SourceTypeRest

+ const SourceTypeUnknown

+ var DefaultFileFormat = env.String(EnvID + "_DEFAULT_FILE_FORMAT", DecoderFormatYAML)

+ var DefaultRestFormat = env.String(EnvID + "_DEFAULT_REST_FORMAT", DecoderFormatJSON)

+ var LoaderActive = env.Bool(EnvID + "_LOADER_ACTIVE", true)

+ var LoaderSourceFormat = env.String(EnvID + "_LOADER_SOURCE_FORMAT", DecoderFormatYAML)

+ var LoaderSourceID = env.String(EnvID + "_LOADER_SOURCE_ID", "_sources")

+ var LoaderSourceListPath = env.String(EnvID + "_LOADER_SOURCE_LIST_PATH", "configs")

+ var LoaderSourcePath = env.String(EnvID + "_LOADER_SOURCE_PATH", "config/config.yaml")

+ var ObserveFrequency = env.Int(EnvID + "_OBSERVE_FREQUENCY", 0)

+ var PathSeparator = env.String(EnvID + "_PATH_SEPARATOR", ".")

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type IConfig interface

+ Bool func(path string, def ...bool) (bool, error)

+ Float func(path string, def ...float64) (float64, error)

+ Get func(path string, def ...interface{}) (interface{}, error)

+ Has func(path string) bool

+ Int func(path string, def ...int) (int, error)

+ List func(path string, def ...[]interface{}) ([]interface{}, error)

+ Partial func(path string, def ...Partial) (Partial, error)

+ String func(path string, def ...string) (string, error)

+ func GetSourceContainerPartials(c slate.ServiceContainer) ([]IConfig, error)

+ type IDecoder interface

+ Decode func() (IConfig, error)

+ type IDecoderFactory interface

+ Create func(format string, args ...interface{}) (IDecoder, error)

+ Register func(strategy IDecoderStrategy) error

+ func GetDecoderFactory(c slate.ServiceContainer) (IDecoderFactory, error)

+ type IDecoderStrategy interface

+ Accept func(format string) bool

+ Create func(args ...interface{}) (IDecoder, error)

+ func GetDecoderStrategies(c slate.ServiceContainer) ([]IDecoderStrategy, error)

+ type ILoader interface

+ Load func() error

+ func GetLoader(c slate.ServiceContainer) (ILoader, error)

+ type IManager interface

+ AddSource func(id string, priority int, src ISource) error

+ HasSource func(id string) bool

+ RemoveAllSources func() error

+ RemoveSource func(id string) error

+ Source func(id string) (ISource, error)

+ SourcePriority func(id string, priority int) error

+ func Get(c slate.ServiceContainer) (IManager, error)

+ func NewManager(period time.Duration) IManager

+ type IObservable interface

+ AddObserver func(path string, callback IObserver) error

+ HasObserver func(path string) bool

+ RemoveObserver func(path string)

+ type IObserver func(interface{}, interface{})

+ type ISource interface

+ Get func(path string, def ...interface{}) (interface{}, error)

+ Has func(path string) bool

+ type ISourceFactory interface

+ Create func(sourceType string, args ...interface{}) (ISource, error)

+ CreateFromConfig func(cfg IConfig) (ISource, error)

+ Register func(strategy ISourceStrategy) error

+ func GetSourceFactory(c slate.ServiceContainer) (ISourceFactory, error)

+ type ISourceObservable interface

+ Reload func() (bool, error)

+ type ISourceStrategy interface

+ Accept func(sourceType string) bool

+ AcceptFromConfig func(cfg IConfig) bool

+ Create func(args ...interface{}) (ISource, error)

+ CreateFromConfig func(cfg IConfig) (ISource, error)

+ func GetSourceStrategies(c slate.ServiceContainer) ([]ISourceStrategy, error)

+ type Partial map[interface{}]interface

+ func (p *Partial) Bool(path string, def ...bool) (bool, error)

+ func (p *Partial) Float(path string, def ...float64) (float64, error)

+ func (p *Partial) Get(path string, def ...interface{}) (interface{}, error)

+ func (p *Partial) Has(path string) bool

+ func (p *Partial) Int(path string, def ...int) (int, error)

+ func (p *Partial) List(path string, def ...[]interface{}) ([]interface{}, error)

+ func (p *Partial) Partial(path string, def ...Partial) (Partial, error)

+ func (p *Partial) String(path string, def ...string) (string, error)

+ func (p Partial) Clone() Partial

+ type Provider struct

+ func (p Provider) Boot(c slate.ServiceContainer) error

+ func (p Provider) Register(c slate.ServiceContainer) error

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