config

Documentation

Index

• Constants
• Variables
• func IsCoreConfigLoaded() bool
• func IsRegistryFileExists() bool
• func LoadCoreConfig() error
• func WatchRuntimeConfFromEtcd(stop chan error) <-chan RespConfig
• type ClientConfig
• type CollectorConfigGroup
• type CoreConfig
• type RegistryInfo
  • func ReadRegistryFile() (*RegistryInfo, error)
  • func Registry(reg_url string) (*RegistryInfo, error)
• type RespConfig
• type RuntimeConfig
  • func LoadRuntimeConfigFromFiles() (rc RuntimeConfig, err error)
  • func ReadRuntimeConfig(r io.Reader) (rc RuntimeConfig, err error)
• type Strategy
  • func (s *Strategy) GetString() string
  • func (s *Strategy) IsValid() bool
• type Transport_dummy

Constants

const (
	FILE     Strategy = "file"
	ETCD              = "etcd"
	REGISTRY          = "registry"
)

const (
	VERSION = "v0.0.1"
)

Variables

var (
	LOG_DIR              = ""
	LOG_FILE             = "hickwall.log"
	LOG_FILEPATH         = ""
	SHARED_DIR           = ""
	CORE_CONF_FILEPATH   = ""
	CONF_FILEPATH        = ""
	CONF_GROUP_DIRECTORY = ""
	REGISTRY_FILEPATH    = ""
)

var (
	ERR_REGISTRY_REVOKED = errors.New("registry has been revoked!")
)

var (
	ETCD_URL_PAT = regexp.MustCompile(`^http[s]?://.*(:\d+)?[/]?`)
)

Functions

func IsCoreConfigLoaded

func IsCoreConfigLoaded() bool

func IsRegistryFileExists

func IsRegistryFileExists() bool

func LoadCoreConfig

func LoadCoreConfig() error

func WatchRuntimeConfFromEtcd

func WatchRuntimeConfFromEtcd(stop chan error) <-chan RespConfig

Types

type ClientConfig

type ClientConfig struct {
	HeartBeat_Interval string            `json:"heartbeat_interval"`
	Tags               map[string]string `json:"tags"`
	Hostname           string            `json:"hostname"`
	Metric_Enabled     bool              `json:"metric_enabled"`
	Metric_Interval    string            `json:"metric_interval"`

	Transport_dummy    *Transport_dummy                   `json:"transport_dummy"` // for testing purpose
	Transport_file     *b_conf.Transport_file             `json:"transport_file"`
	Transport_influxdb []*b_conf.Transport_influxdb       `json:"transport_influxdb"`
	Transport_kafka    *b_conf.Transport_kafka            `json:"transport_kafka"`
	Subscribe_kafka    []*c_conf.Config_KafkaSubscription `json:"subscribe_kafka"` // subscribe kafka
}

type CollectorConfigGroup

type CollectorConfigGroup struct {
	Prefix         string               `json:"prefix"`
	Collector_ping []c_conf.Config_Ping `json:"collector_ping"`
}

type CoreConfig

type CoreConfig struct {
	Log_level         string   `json:"log_level"`         // possible values: trace, debug, info, warn, error, critical
	Log_file_maxsize  int      `json:"log_file_maxsize"`  // TODO: log_file_maxsize
	Log_file_maxrolls int      `json:"log_file_maxrolls"` // TODO: log_file_maxrolls
	Config_Strategy   Strategy `json:"config_strategy"`   // possible values:  file, etcd, registry
	Etcd_url          string   `json:"etcd_url"`          // etcd config
	Etcd_path         string   `json:"etcd_path"`
	Registry_Server   string   `json:"registry_server"` // registry server config
}

var (
	CoreConf CoreConfig // only file

)

public variables ---------------------------------------------------------------

type RegistryInfo

type RegistryInfo struct {
	Etcd_registry_endpoint string `json:"etcd_registry_endpoint"`
	Etcd_config_endpoing   string `json:"etcd_config_endpoint"`
	Etcd_url               string `json:"etcd_url"`
	Cookie                 string `json:"cookie"`
}

func ReadRegistryFile

func ReadRegistryFile() (*RegistryInfo, error)

func Registry

func Registry(reg_url string) (*RegistryInfo, error)

type RespConfig

type RespConfig struct {
	Config RuntimeConfig
	Err    error
}

type RuntimeConfig

type RuntimeConfig struct {
	Client ClientConfig           `json:"client"`
	Groups []CollectorConfigGroup `json:"groups"`
}

func LoadRuntimeConfigFromFiles

func LoadRuntimeConfigFromFiles() (rc RuntimeConfig, err error)

func ReadRuntimeConfig

func ReadRuntimeConfig(r io.Reader) (rc RuntimeConfig, err error)

type Strategy

type Strategy string

func (*Strategy) GetString

func (s *Strategy) GetString() string

func (*Strategy) IsValid

func (s *Strategy) IsValid() bool

type Transport_dummy

type Transport_dummy struct {
	Name      string
	Jamming   newcore.Interval
	Printting bool
	Detail    bool
}