source

Documentation

Overview

Package source manage all the config source and merge configs by precedence

Index

• Constants
• func ToRvalueType(confValue interface{}, convertType reflect.Type) (returnValue reflect.Value, err error)
• type ConfigSource
• type EventHandler
• type Manager
  • 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

Constants

const (
	//DefaultPriority gives the default priority
	DefaultPriority = -1
)

Functions

func ToRvalueType

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

ToRvalueType Deserializes the object to a particular type

Types

type ConfigSource

type ConfigSource interface {
	Set(key string, value interface{}) error
	Delete(key string) error
	GetConfigurations() (map[string]interface{}, error)
	GetConfigurationByKey(string) (interface{}, error)
	Watch(EventHandler) error
	GetPriority() int
	SetPriority(priority int)
	Cleanup() error
	GetSourceName() string

	AddDimensionInfo(labels map[string]string) error
}

ConfigSource get key values from a system, like file system, key value store, memory etc

type EventHandler

type EventHandler interface {
	OnEvent(event *event.Event)
}

EventHandler handles config change event

type Manager

type Manager struct {
	Sources map[string]ConfigSource

	ConfigurationMap map[string]string
	// contains filtered or unexported fields
}

Manager manage all sources and config from them

func NewManager

func NewManager() *Manager

NewManager creates an object of Manager

func (*Manager) AddDimensionInfo

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

AddDimensionInfo adds the dimensionInfo to the list of which configurations needs to be pulled

func (*Manager) AddSource

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

AddSource adds a source to configurationManager

func (*Manager) Cleanup

func (m *Manager) Cleanup() error

Cleanup close and cleanup config manager channel

func (*Manager) Configs

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

Configs returns all the key values

func (*Manager) Delete

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

Delete call Delete of all sources

func (*Manager) GetConfig

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

GetConfig returns the value for a particular key from cache

func (*Manager) IsKeyExist

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

IsKeyExist check if key exist in cache

func (*Manager) OnEvent

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

OnEvent Triggers actions when an event is generated

func (*Manager) Refresh

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

Refresh reload the configurations of a source

func (*Manager) RegisterListener

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

RegisterListener Function to Register all listener for different key changes

func (*Manager) Set

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

Set call set of all sources

func (*Manager) UnRegisterListener

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

UnRegisterListener remove listener

func (*Manager) Unmarshal

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

Unmarshal function is used in the case when user want his yaml file to be unmarshalled to structure pointer Unmarshal function accepts a pointer and in called function anyone can able to get the data in passed object Unmarshal only accepts a pointer values Unmarshal returns error if obj values are 0. nil and value type. Procedure:

1. Unmarshal first checks the passed object type using reflection.
2. Based on type Unmarshal function will check and set the values ex: If type is basic types like int, string, float then it will assigb directly values, If type is map, ptr and struct then it will again send for unmarshal until it find the basic type and set the values