go_config_centor

README

go_config_centor

基于zookeeper的配置中心

Documentation

Index

• type Center
  • func NewCenter(Name string) (center *Center)
  • func (c *Center) GetKafkaAddresses() (addrArr []string, err error)
  • func (c *Center) GetZKHosts() (addrArr []string, err error)
  • func (c *Center) Open(options ...Option) (msg []string, err error)
• type FileConfig
  • func (f *FileConfig) Debug() bool
  • func (f *FileConfig) GetZKHosts() []string
• type Option
• type OptionLocalConfigPath
• type OptionOnlineMode
  • func NewOptionOnlineMode(remoteDir, zkConfigPath string) (o *OptionOnlineMode)
• type OptionZKConfigPath
• type PostgreSQLConfig
• type PublicConfig
• type RedisConfig
• type SQLConfig

Types

type Center

type Center struct {
	*viper.Viper
	// contains filtered or unexported fields
}

func NewCenter

func NewCenter(Name string) (center *Center)

func (*Center) GetKafkaAddresses

func (c *Center) GetKafkaAddresses() (addrArr []string, err error)

func (*Center) GetZKHosts

func (c *Center) GetZKHosts() (addrArr []string, err error)

func (*Center) Open

func (c *Center) Open(options ...Option) (msg []string, err error)

type FileConfig

type FileConfig struct {
	*viper.Viper
	// contains filtered or unexported fields
}

func (*FileConfig) Debug

func (f *FileConfig) Debug() bool

func (*FileConfig) GetZKHosts

func (f *FileConfig) GetZKHosts() []string

type Option

type Option interface {
	// contains filtered or unexported methods
}

type OptionLocalConfigPath

type OptionLocalConfigPath string

配置文件存储位置

type OptionOnlineMode

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

开启在线配置中心

func NewOptionOnlineMode

func NewOptionOnlineMode(remoteDir, zkConfigPath string) (o *OptionOnlineMode)

type OptionZKConfigPath

type OptionZKConfigPath string

type PostgreSQLConfig

type PostgreSQLConfig struct {
	Write SQLConfig
	Read  []SQLConfig
}

type PublicConfig

type PublicConfig struct {
	Redis RedisConfig
}

func (c *Center) Update() (err error) {
	err = c.prepareConfig(c.viper, path.Join(c.RemotePath, c.name), c.localPathName())

	if c.enablePublicConfig {
		err = c.prepareConfig(c.publicViper, path.Join(centerPrefix, publicConfigName), c.publicLocalPathName())
		c.SetPublicDefault()

		//同步线上公共配置
		err = c.syncPublic()
		if err != nil {
			err = fmt.Errorf("[config center]sync public config fail:\n%w", err)
			log.Error(err)
		}
	}

	return
}

type RedisConfig

type RedisConfig struct {
	Type       string
	MasterName string
	// A seed list of host:port addresses of cluster nodes.
	Addrs []string

	// The maximum number of retries before giving up. Command is retried
	// on network errors and MOVED/ASK redirects.
	// Default is 8 retries.
	MaxRedirects int

	// Enables read-only commands on slave nodes.
	ReadOnly bool
	// Allows routing read-only commands to the closest master or slave node.
	// It automatically enables ReadOnly.
	RouteByLatency bool
	// Allows routing read-only commands to the random master or slave node.
	// It automatically enables ReadOnly.
	RouteRandomly bool

	Password string

	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	// PoolSize applies per cluster node and not for the whole cluster.
	PoolSize           int
	MinIdleConns       int
	MaxConnAge         time.Duration
	PoolTimeout        time.Duration
	IdleTimeout        time.Duration
	IdleCheckFrequency time.Duration
}

type SQLConfig

type SQLConfig struct {
	Host     string
	Port     int
	User     string
	Password string
}