config

Documentation

Index

• Constants
• func Get(key string) (interface{}, bool)
• func GetAll() map[string]interface{}
• func GetOrDefault(key string, def interface{}) (interface{}, bool)
• func Register(key string, prov Provider) error
• func Resolve() error
• type CfgBlockComponent
• type CfgBlockPipeline
• type CfgBlockSystem
• type CfgBlockSystemAdmin
• type CfgBlockSystemMetrics
• type CfgBlockSystemMetricsReceiver
• type Provider
• type ProviderList
  • func (p ProviderList) Len() int
  • func (p ProviderList) Less(i, j int) bool
  • func (p ProviderList) Swap(i, j int)
• type ProviderOptions
• type Registry
• type YAMLConfig

Constants

const (
	YML_CFG_KEY_SYS  = "global.system"
	YML_CFG_KEY_COMP = "global.components"
	YML_CFG_KEY_PPL  = "global.pipeline"
)

Functions

func Get

func Get(key string) (interface{}, bool)

func GetAll

func GetAll() map[string]interface{}

func GetOrDefault

func GetOrDefault(key string, def interface{}) (interface{}, bool)

func Register

func Register(key string, prov Provider) error

func Resolve

func Resolve() error

Types

type CfgBlockComponent

type CfgBlockComponent struct {
	Module      string
	Plugin      string
	Constructor string
	Params      map[string]interface{}
}

type CfgBlockPipeline

type CfgBlockPipeline struct {
	Links   []string
	Connect string
	Routes  map[string]string
}

type CfgBlockSystem

type CfgBlockSystem struct {
	Maxprocs int
	Admin    CfgBlockSystemAdmin
	Metrics  CfgBlockSystemMetrics
}

type CfgBlockSystemAdmin

type CfgBlockSystemAdmin struct {
	Enabled  bool
	BindAddr string `yaml:"bind_addr"`
}

type CfgBlockSystemMetrics

type CfgBlockSystemMetrics struct {
	Enabled  bool
	Interval int
	Receiver CfgBlockSystemMetricsReceiver
}

type CfgBlockSystemMetricsReceiver

type CfgBlockSystemMetricsReceiver struct {
	Type   string
	Params map[string]string
}

type Provider

type Provider interface {
	Setup() error
	DependsOn() []string
	Resolve() error
	GetName() string
	GetWeight() uint32
	GetOptions() ProviderOptions
	GetValue(string) (interface{}, bool)
}

type ProviderList

type ProviderList []Provider

func (ProviderList) Len

func (p ProviderList) Len() int

func (ProviderList) Less

func (p ProviderList) Less(i, j int) bool

func (ProviderList) Swap

func (p ProviderList) Swap(i, j int)

type ProviderOptions

type ProviderOptions uint64

const (
	ProviderOptionsFileCache ProviderOptions = 1 << iota
	ProviderOptionsTrustOldCache
)

type Registry

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

type YAMLConfig

type YAMLConfig struct {
	System     *CfgBlockSystem
	Components map[string]CfgBlockComponent
	Pipeline   map[string]CfgBlockPipeline
}