source

Jan 20, 2021

Changes in this version

+ var ErrIgnoreChange = errors.New("ignore key changed")

+ var ErrWriterInvalid = errors.New("writer is invalid")

type Manager

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

+ func (m *Manager) Marshal(w io.Writer) error

Apr 22, 2020

Changes in this version

type EventHandler

+ OnModuleEvent func(events []*event.Event)

type Manager

+ func (m *Manager) OnModuleEvent(event []*event.Event)

+ func (m *Manager) RegisterModuleListener(listenerObj event.ModuleListener, prefixes ...string) error

+ func (m *Manager) UnRegisterModuleListener(listenerObj event.ModuleListener, prefixes ...string) error

Mar 6, 2020

Changes in this version

+ var ErrKeyNotExist = errors.New("key does not exist")

Sep 23, 2019

Changes in this version

+ const DefaultPriority

+ func ToRvalueType(confValue interface{}, convertType reflect.Type) (returnValue reflect.Value, err error)

+ type ConfigSource interface

+ AddDimensionInfo func(labels map[string]string) error

+ Cleanup func() error

+ Delete func(key string) error

+ GetConfigurationByKey func(string) (interface{}, error)

+ GetConfigurations func() (map[string]interface{}, error)

+ GetPriority func() int

+ GetSourceName func() string

+ Set func(key string, value interface{}) error

+ SetPriority func(priority int)

+ Watch func(EventHandler) error

+ type EventHandler interface

+ OnEvent func(event *event.Event)

+ type Manager struct

+ ConfigurationMap map[string]string

+ Sources map[string]ConfigSource

+ func NewManager() *Manager

+ func (m *Manager) AddDimensionInfo(labels map[string]string) (map[string]string, error)

+ func (m *Manager) AddSource(source ConfigSource, priority int) error

+ func (m *Manager) Cleanup() error

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

+ func (m *Manager) Delete(k string) error

+ func (m *Manager) GetConfig(key string) interface{}

+ func (m *Manager) IsKeyExist(key string) bool

+ func (m *Manager) OnEvent(event *event.Event)

+ func (m *Manager) Refresh(sourceName string) error

+ func (m *Manager) RegisterListener(listenerObj event.Listener, keys ...string) error

+ func (m *Manager) Set(k string, v interface{}) error

+ func (m *Manager) UnRegisterListener(listenerObj event.Listener, keys ...string) error

+ func (m *Manager) Unmarshal(obj interface{}) error