conf

README

conf

加载配置

从字符串中加载配置

var content = `[app] mode="dev"`
if err := conf.Load(bytes.NewBufferString(content), toml.Unmarshal); err != nil {
    panic(err)
}

从配置文件中加载配置

import (
    file_datasource "github.com/douyu/jupiter/pkg/datasource/file"
)

provider := file_datasource.NewDataSource(path)
if err := conf.Load(provider, toml.Unmarshal); err != nil {
    panic(err)
}

从etcd中加载配置

import (
   etcdv3_datasource "github.com/douyu/jupiter/pkg/datasource/etcdv3"
   "github.com/douyu/jupiter/client/etcdv3"
)
provider := etcdv3_datasource.NewDataSource(
    etcdv3.StdConfig("config_datasource").Build(),
    "/config/my-application",
)
if err := conf.Load(provider, json.Unmarshal); err != nil {
    panic(err)
}

Documentation

Index

• Constants
• Variables
• func Apply(conf map[string]interface{}) error
• func Debug(sep string)
• func Exists(key string) bool
• func Get(key string) interface{}
• func GetBool(key string) bool
• func GetDuration(key string) time.Duration
• func GetFloat64(key string) float64
• func GetInt(key string) int
• func GetInt64(key string) int64
• func GetInt64Slice(key string) []int64
• func GetSlice(key string) []interface{}
• func GetString(key string) string
• func GetStringMap(key string) map[string]interface{}
• func GetStringMapString(key string) map[string]string
• func GetStringMapStringSlice(key string) map[string][]string
• func GetStringSlice(key string) []string
• func GetTime(key string) time.Time
• func LoadFromDataSource(ds DataSource, unmarshaller Unmarshaller) error
• func LoadFromReader(r io.Reader, unmarshaller Unmarshaller) error
• func OnChange(fn func(*Configuration))
• func OnLoaded(fn func(*Configuration))
• func Register(scheme string, creator DataSourceCreatorFunc)
• func Reset()
• func Set(key string, val interface{})
• func Traverse(sep string) map[string]interface{}
• func UnmarshalKey(key string, rawVal interface{}, opts ...GetOption) error
• func UnmarshalWithExpect(key string, expect interface{}) interface{}
• type Configuration
  • func New() *Configuration
  • func (c *Configuration) Get(key string) interface{}
  • func (c *Configuration) GetBool(key string) bool
  • func (c *Configuration) GetDuration(key string) time.Duration
  • func (c *Configuration) GetFloat64(key string) float64
  • func (c *Configuration) GetInt(key string) int
  • func (c *Configuration) GetInt64(key string) int64
  • func (c *Configuration) GetInt64Slice(key string) []int64
  • func (c *Configuration) GetSlice(key string) []interface{}
  • func (c *Configuration) GetSliceStringMap(key string) []map[string]interface{}
  • func (c *Configuration) GetString(key string) string
  • func (c *Configuration) GetStringMap(key string) map[string]interface{}
  • func (c *Configuration) GetStringMapString(key string) map[string]string
  • func (c *Configuration) GetStringMapStringSlice(key string) map[string][]string
  • func (c *Configuration) GetStringSlice(key string) []string
  • func (c *Configuration) GetTime(key string) time.Time
  • func (c *Configuration) Load(content []byte, unmarshal Unmarshaller) error
  • func (c *Configuration) LoadEnvironments(prefix string)
  • func (c *Configuration) LoadFromDataSource(ds DataSource, unmarshaller Unmarshaller) error
  • func (c *Configuration) LoadFromReader(reader io.Reader, unmarshaller Unmarshaller) error
  • func (c *Configuration) OnChange(fn func(*Configuration))
  • func (c *Configuration) OnLoaded(fn func(*Configuration))
  • func (c *Configuration) Set(key string, val interface{}) error
  • func (c *Configuration) SetKeyDelim(delim string)
  • func (c *Configuration) Sub(key string) *Configuration
  • func (c *Configuration) UnmarshalKey(key string, rawVal interface{}, opts ...GetOption) error
  • func (c *Configuration) UnmarshalWithExpect(key string, expect interface{}) interface{}
  • func (c *Configuration) WriteConfig() error
• type DataSource
  • func NewDataSource(configAddr string) (DataSource, error)
• type DataSourceCreatorFunc
• type GetOption
  • func BuildinModule(module string) GetOption
  • func Module(module string) GetOption
  • func Namespace(namespace string) GetOption
  • func TagName(tag string) GetOption
  • func TagNameJSON() GetOption
  • func TagNameTOML() GetOption
  • func TagNameYAML() GetOption
• type GetOptions
• type Unmarshaller

Constants

const DefaultEnvPrefix = "APP_"

Variables

var (
	//ErrConfigAddr not config
	ErrConfigAddr = errors.New("no config... ")
	// ErrInvalidDataSource defines an error that the scheme has been registered
	ErrInvalidDataSource = errors.New("invalid data source, please make sure the scheme has been registered")
)

var ErrInvalidKey = errors.New("invalid key, maybe not exist in config")

ErrInvalidKey ...

Functions

func Apply

func Apply(conf map[string]interface{}) error

Apply ...

func Debug

func Debug(sep string)

Debug ...

func Exists

func Exists(key string) bool

Exists returns whether key exists

func Get

func Get(key string) interface{}

Get returns an interface. For a specific value use one of the Get____ methods.

func GetBool

func GetBool(key string) bool

GetBool returns the value associated with the key as a boolean with default defaultConfiguration.

func GetDuration

func GetDuration(key string) time.Duration

GetDuration returns the value associated with the key as a duration with default defaultConfiguration.

func GetFloat64

func GetFloat64(key string) float64

GetFloat64 returns the value associated with the key as a float64 with default defaultConfiguration.

func GetInt

func GetInt(key string) int

GetInt returns the value associated with the key as an integer with default defaultConfiguration.

func GetInt64

func GetInt64(key string) int64

GetInt64 returns the value associated with the key as an integer with default defaultConfiguration.

func GetInt64Slice

func GetInt64Slice(key string) []int64

GetInt64Slice returns the value associated with the key as a slice of int64s, stop when error occurs.

func GetSlice

func GetSlice(key string) []interface{}

GetSlice returns the value associated with the key as a slice of strings with default defaultConfiguration.

func GetString

func GetString(key string) string

GetString returns the value associated with the key as a string with default defaultConfiguration.

func GetStringMap

func GetStringMap(key string) map[string]interface{}

GetStringMap returns the value associated with the key as a map of interfaces with default defaultConfiguration.

func GetStringMapString

func GetStringMapString(key string) map[string]string

GetStringMapString returns the value associated with the key as a map of strings with default defaultConfiguration.

func GetStringMapStringSlice

func GetStringMapStringSlice(key string) map[string][]string

GetStringMapStringSlice returns the value associated with the key as a map to a slice of strings with default defaultConfiguration.

func GetStringSlice

func GetStringSlice(key string) []string

GetStringSlice returns the value associated with the key as a slice of strings with default defaultConfiguration.

func GetTime

func GetTime(key string) time.Time

GetTime returns the value associated with the key as time with default defaultConfiguration.

func LoadFromDataSource

func LoadFromDataSource(ds DataSource, unmarshaller Unmarshaller) error

LoadFromDataSource load configuration from data source if data source supports dynamic config, a monitor goroutinue would be

func LoadFromReader

func LoadFromReader(r io.Reader, unmarshaller Unmarshaller) error

Load loads configuration from provided provider with default defaultConfiguration.

func OnChange

func OnChange(fn func(*Configuration))

OnChange 注册change回调函数

func OnLoaded

func OnLoaded(fn func(*Configuration))

func Register

func Register(scheme string, creator DataSourceCreatorFunc)

Register registers a dataSource creator function to the registry

func Reset

func Reset()

Reset resets all to default settings.

func Set

func Set(key string, val interface{})

Set set config value for key

func Traverse

func Traverse(sep string) map[string]interface{}

Traverse ...

func UnmarshalKey

func UnmarshalKey(key string, rawVal interface{}, opts ...GetOption) error

UnmarshalKey takes a single key and unmarshal it into a Struct with default defaultConfiguration.

func UnmarshalWithExpect

func UnmarshalWithExpect(key string, expect interface{}) interface{}

UnmarshalWithExpect unmarshal key, returns expect if failed

Types

type Configuration

type Configuration struct {
	// contains filtered or unexported fields
}

Configuration provides configuration for application.

func New

func New() *Configuration

New constructs a new Configuration with provider.

func (*Configuration) Get

func (c *Configuration) Get(key string) interface{}

Get returns the value associated with the key

func (*Configuration) GetBool

func (c *Configuration) GetBool(key string) bool

GetBool returns the value associated with the key as a boolean.

func (*Configuration) GetDuration

func (c *Configuration) GetDuration(key string) time.Duration

GetDuration returns the value associated with the key as a duration.

func (*Configuration) GetFloat64

func (c *Configuration) GetFloat64(key string) float64

GetFloat64 returns the value associated with the key as a float64.

func (*Configuration) GetInt

func (c *Configuration) GetInt(key string) int

GetInt returns the value associated with the key as an integer.

func (*Configuration) GetInt64

func (c *Configuration) GetInt64(key string) int64

GetInt64 returns the value associated with the key as an integer.

func (*Configuration) GetInt64Slice

func (c *Configuration) GetInt64Slice(key string) []int64

GetInt64Slice returns the value associated with the key as a slice of int64s.

func (*Configuration) GetSlice

func (c *Configuration) GetSlice(key string) []interface{}

GetSlice returns the value associated with the key as a slice of strings.

func (*Configuration) GetSliceStringMap

func (c *Configuration) GetSliceStringMap(key string) []map[string]interface{}

GetSliceStringMap returns the value associated with the slice of maps.

func (*Configuration) GetString

func (c *Configuration) GetString(key string) string

GetString returns the value associated with the key as a string.

func (*Configuration) GetStringMap

func (c *Configuration) GetStringMap(key string) map[string]interface{}

GetStringMap returns the value associated with the key as a map of interfaces.

func (*Configuration) GetStringMapString

func (c *Configuration) GetStringMapString(key string) map[string]string

GetStringMapString returns the value associated with the key as a map of strings.

func (*Configuration) GetStringMapStringSlice

func (c *Configuration) GetStringMapStringSlice(key string) map[string][]string

GetStringMapStringSlice returns the value associated with the key as a map to a slice of strings.

func (*Configuration) GetStringSlice

func (c *Configuration) GetStringSlice(key string) []string

GetStringSlice returns the value associated with the key as a slice of strings.

func (*Configuration) GetTime

func (c *Configuration) GetTime(key string) time.Time

GetTime returns the value associated with the key as time.

func (*Configuration) Load

func (c *Configuration) Load(content []byte, unmarshal Unmarshaller) error

Load ...

func (*Configuration) LoadEnvironments

func (c *Configuration) LoadEnvironments(prefix string)

LoadEnvironments reads os environments with prefix such as APP_ PREFIX_FIELD1_FIELD2 will be translated into prefix.field1.field2

func (*Configuration) LoadFromDataSource

func (c *Configuration) LoadFromDataSource(ds DataSource, unmarshaller Unmarshaller) error

LoadFromDataSource ...

func (*Configuration) LoadFromReader

func (c *Configuration) LoadFromReader(reader io.Reader, unmarshaller Unmarshaller) error

Load loads configuration from provided data source.

func (*Configuration) OnChange

func (c *Configuration) OnChange(fn func(*Configuration))

OnChange 注册change回调函数

func (*Configuration) OnLoaded

func (c *Configuration) OnLoaded(fn func(*Configuration))

func (*Configuration) Set

func (c *Configuration) Set(key string, val interface{}) error

Set ...

func (*Configuration) SetKeyDelim

func (c *Configuration) SetKeyDelim(delim string)

SetKeyDelim set keyDelim of a defaultConfiguration instance.

func (*Configuration) Sub

func (c *Configuration) Sub(key string) *Configuration

Sub returns new Configuration instance representing a sub tree of this instance.

func (*Configuration) UnmarshalKey

func (c *Configuration) UnmarshalKey(key string, rawVal interface{}, opts ...GetOption) error

UnmarshalKey takes a single key and unmarshal it into a Struct.

func (*Configuration) UnmarshalWithExpect

func (c *Configuration) UnmarshalWithExpect(key string, expect interface{}) interface{}

UnmarshalWithExpect unmarshal key, returns expect if failed

func (*Configuration) WriteConfig

func (c *Configuration) WriteConfig() error

WriteConfig ...

type DataSource

type DataSource interface {
	ReadConfig() ([]byte, error)
	IsConfigChanged() <-chan struct{}
	io.Closer
}

DataSource ...

func NewDataSource

func NewDataSource(configAddr string) (DataSource, error)

NewDataSource ..

type DataSourceCreatorFunc

type DataSourceCreatorFunc func() DataSource

DataSourceCreatorFunc represents a dataSource creator function

type GetOption

type GetOption func(o *GetOptions)

GetOption ...

func BuildinModule

func BuildinModule(module string) GetOption

func Module

func Module(module string) GetOption

func Namespace

func Namespace(namespace string) GetOption

func TagName

func TagName(tag string) GetOption

设置Tag

func TagNameJSON

func TagNameJSON() GetOption

func TagNameTOML

func TagNameTOML() GetOption

func TagNameYAML

func TagNameYAML() GetOption

type GetOptions

type GetOptions struct {
	TagName   string
	Namespace string
	Module    string
}

GetOption ...

type Unmarshaller

type Unmarshaller = func([]byte, interface{}) error

Unmarshaller ...