config

Documentation

Index

• func InitConfigFromConsul(path string) error
• func InitConfigFromEtcd(path string) error
• func InitConfigFromLocal(path string) error
• func InitConfigFromNacos(path string) error
• type BizConfig
• type Config
• type ConfigSource
• type ConsumerConfig
• type Global
• type GlobalConfig
  • func GetGlobalStaticConfig() *GlobalConfig
• type Hertz
• type Kafka
• type LocalConfigSource
  • func NewLocalConfigSource() *LocalConfigSource
  • func (l *LocalConfigSource) Close() error
  • func (l *LocalConfigSource) Load(path string) (*GlobalConfig, error)
  • func (l *LocalConfigSource) Watch() (<-chan *GlobalConfig, error)
• type Log
• type MongoConfig
• type MySQL
• type MySQLConfig
• type ProducerConfig
• type Prometheus
• type RedisConfig
• type Registry
• type Selector
• type Service

Functions

func InitConfigFromConsul

func InitConfigFromConsul(path string) error

func InitConfigFromEtcd

func InitConfigFromEtcd(path string) error

func InitConfigFromLocal

func InitConfigFromLocal(path string) error

func InitConfigFromNacos

func InitConfigFromNacos(path string) error

Types

type BizConfig

type BizConfig struct {
	AppID                 string `yaml:"app_id"`
	InitRedisCacheTimeout int    `yaml:"init_redis_cache_timeout"`
	BusinessID            int    `yaml:"business_id"`
	ShareDomain           string `yaml:"share_domain"`
}

type Config

type Config struct {
	Name       string   `yaml:"name"`
	ServerAddr []string `yaml:"server_addr"`
	Namespace  string   `yaml:"namespace"`
	Username   string   `yaml:"username"`
	Password   string   `yaml:"password"`
}

type ConfigSource

type ConfigSource interface {
	Load(path string) (*GlobalConfig, error)
	Watch() (<-chan *GlobalConfig, error)
	Close() error
}

type ConsumerConfig

type ConsumerConfig struct {
	Key        string            `yaml:"key"`
	Address    []string          `yaml:"address"`
	Group      string            `yaml:"group"`
	Topic      string            `yaml:"topic"`
	Partition  int               `yaml:"partition"`
	Offset     int64             `yaml:"offset"`
	SaslConfig *kafka.SaslConfig `yaml:"sasl_config"`
	TlsConfig  *kafka.TlsConfig  `yaml:"tls_config"`
}

type Global

type Global struct {
	NameSpace     string `yaml:"namespace"`
	EnvName       string `yaml:"env_name"`
	LocalIP       string `yaml:"local_ip"`
	ContainerName string `yaml:"container_name"`
}

type GlobalConfig

type GlobalConfig struct {
	Global     *Global                 `yaml:"global"`     // Global config
	BizConfig  *BizConfig              `yaml:"biz_config"` // Biz config
	Hertz      *Hertz                  `yaml:"hertz"`      // Hertz Server config
	Log        *Log                    `yaml:"log"`        // Log config
	Registry   *Registry               `yaml:"registry"`   // Registry center config
	Selector   *Selector               `yaml:"selector"`   // Selector config
	Config     *Config                 `yaml:"config"`     // Config center config
	Prometheus *Prometheus             `yaml:"prometheus"` // Prometheus config
	Kafka      *Kafka                  `yaml:"kafka"`      // Kafka config
	MySQL      map[string]*MySQLConfig `yaml:"mysql"`      // MySQL config
	Redis      map[string]*RedisConfig `yaml:"redis"`      // Redis config
	Mongo      *MongoConfig            `yaml:"mongo"`      // Mongo config
	Minio      *minio.Config           `yaml:"minio"`      // Minio config
}

var (
	GlobalStaticConfig *GlobalConfig
)

func GetGlobalStaticConfig

func GetGlobalStaticConfig() *GlobalConfig

type Hertz

type Hertz struct {
	App             string    `yaml:"app"`
	Server          string    `yaml:"server"`
	BinPath         string    `yaml:"bin_path"`
	ConfPath        string    `yaml:"conf_path"`
	DataPath        string    `yaml:"data_path"`
	EnablePprof     bool      `yaml:"enable_pprof"`
	EnableGzip      bool      `yaml:"enable_gzip"`
	EnableAccessLog bool      `yaml:"enable_access_log"`
	Service         []Service `yaml:"service"`
}

type Kafka

type Kafka struct {
	Producer []*ProducerConfig `yaml:"producer"`
	Consumer []*ConsumerConfig `yaml:"consumer"`
}

type LocalConfigSource

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

func NewLocalConfigSource

func NewLocalConfigSource() *LocalConfigSource

func (*LocalConfigSource) Close

func (l *LocalConfigSource) Close() error

func (*LocalConfigSource) Load

func (l *LocalConfigSource) Load(path string) (*GlobalConfig, error)

func (*LocalConfigSource) Watch

func (l *LocalConfigSource) Watch() (<-chan *GlobalConfig, error)

type Log

type Log struct {
	LogMode       string `yaml:"log_mode"`
	LogLevel      string `yaml:"log_level"`
	LogFileName   string `yaml:"log_file_name"`
	LogMaxSize    int    `yaml:"log_max_size"`
	LogMaxBackups int    `yaml:"log_max_backups"`
	LogMaxAge     int    `yaml:"log_max_age"`
	LogCompress   bool   `yaml:"log_compress"`
}

type MongoConfig

type MongoConfig struct {
	Path        string `yaml:"path"`
	Username    string `yaml:"username"`
	Password    string `yaml:"password"`
	MaxPoolSize int    `yaml:"max_pool_size"`
	MinPoolSize int    `yaml:"min_pool_size"`
	Database    string `yaml:"database"`
}

type MySQL

type MySQL struct {
	Host            string `yaml:"host"`
	Port            int    `yaml:"port"`
	Username        string `yaml:"username"`
	Password        string `yaml:"password"`
	Database        string `yaml:"database"`
	MultiStatements int    `yaml:"multi_statements"`
	Charset         string `yaml:"charset"`
	MaxOpenConns    int    `yaml:"max_open_conns"`
	MaxIdleConns    int    `yaml:"max_idle_conns"`
}

type MySQLConfig

type MySQLConfig struct {
	Masters []*MySQL `yaml:"masters"`
	Slaves  []*MySQL `yaml:"slaves"`
}

type ProducerConfig

type ProducerConfig struct {
	Key           string            `yaml:"key"`
	Address       []string          `yaml:"address"`
	Async         bool              `yaml:"async"`
	Topic         string            `yaml:"topic"`
	Ack           int               `yaml:"ack"`
	CompressCodec string            `yaml:"compress_codec"`
	SaslConfig    *kafka.SaslConfig `yaml:"sasl_config"`
	TlsConfig     *kafka.TlsConfig  `yaml:"tls_config"`
}

type Prometheus

type Prometheus struct {
	Enable bool   `yaml:"enable"`
	Addr   string `yaml:"addr"`
	Path   string `yaml:"path"`
}

type RedisConfig

type RedisConfig struct {
	Host        string `yaml:"host"`
	Port        int    `yaml:"port"`
	Password    string `yaml:"password"`
	PoolSize    int    `yaml:"pool_size"`
	IdleTimeout int    `yaml:"idle_timeout"`
	DB          int    `yaml:"db"`
}

type Registry

type Registry struct {
	Name            string   `yaml:"name"`
	RegistryAddress []string `yaml:"registry_address"`
	Namespace       string   `yaml:"namespace"`
	Username        string   `yaml:"username"`
	Password        string   `yaml:"password"`
}

type Selector

type Selector struct {
	Name       string   `yaml:"name"`
	ServerAddr []string `yaml:"server_addr"`
	Namespace  string   `yaml:"namespace"`
	Username   string   `yaml:"username"`
	Password   string   `yaml:"password"`
}

type Service

type Service struct {
	Name    string `yaml:"name"`
	Address string `yaml:"addr"`
}