go_config_centor

README

go_config_centor

基于zookeeper的配置中心

Documentation

Index

• func SetLogger(logger log.Logger)
• type Center
  • func NewCenter(Path, Name string) (center *Center)
  • func (c *Center) EnablePublicConfig(b bool)
  • func (c *Center) GetBool(key string) bool
  • func (c *Center) GetDuration(key string) time.Duration
  • func (c *Center) GetFileConfig(fileName string) *FileConfig
  • func (c *Center) GetFloat64(key string) float64
  • func (c *Center) GetHBaseThrift() string
  • func (c *Center) GetHBaseThrift2() string
  • func (c *Center) GetInt(key string) int
  • func (c *Center) GetInt32(key string) int32
  • func (c *Center) GetInt64(key string) int64
  • func (c *Center) GetIntSlice(key string) []int
  • func (c *Center) GetKafkaAddresses() (addrArr []string, err error)
  • func (c *Center) GetPublicPostgres() *PostgreSQLConfig
  • func (c *Center) GetPublicRedis() *RedisConfig
  • func (c *Center) GetSizeInBytes(key string) uint
  • func (c *Center) GetString(key string) string
  • func (c *Center) GetStringMap(key string) map[string]interface{}
  • func (c *Center) GetStringMapString(key string) map[string]string
  • func (c *Center) GetStringMapStringSlice(key string) map[string][]string
  • func (c *Center) GetStringSlice(key string) []string
  • func (c *Center) GetTime(key string) time.Time
  • func (c *Center) GetUint(key string) uint
  • func (c *Center) GetUint32(key string) uint32
  • func (c *Center) GetUint64(key string) uint64
  • func (c *Center) Open() (err error)
  • func (c *Center) SetDefault(key string, value interface{})
  • func (c *Center) SetOnlineMode(b bool)
  • func (c *Center) SetPublicDefault()
  • func (c *Center) Sync() (err error)
  • func (c *Center) Update() (err error)
• type FileConfig
  • func (f *FileConfig) Debug() bool
  • func (f *FileConfig) GetZKHosts() []string
  • func (f *FileConfig) Sync() error
• type PostgreSQLConfig
• type RedisConfig
• type SQLConfig

Functions

func SetLogger

func SetLogger(logger log.Logger)

Types

type Center

type Center struct {
	RemotePath string
	// contains filtered or unexported fields
}

func NewCenter

func NewCenter(Path, Name string) (center *Center)

func (*Center) EnablePublicConfig

func (c *Center) EnablePublicConfig(b bool)

func (*Center) GetBool

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

func (*Center) GetDuration

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

func (*Center) GetFileConfig

func (c *Center) GetFileConfig(fileName string) *FileConfig

func (*Center) GetFloat64

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

func (*Center) GetHBaseThrift

func (c *Center) GetHBaseThrift() string

func (*Center) GetHBaseThrift2

func (c *Center) GetHBaseThrift2() string

func (*Center) GetInt

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

func (*Center) GetInt32

func (c *Center) GetInt32(key string) int32

func (*Center) GetInt64

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

func (*Center) GetIntSlice

func (c *Center) GetIntSlice(key string) []int

func (*Center) GetKafkaAddresses

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

func (*Center) GetPublicPostgres

func (c *Center) GetPublicPostgres() *PostgreSQLConfig

func (*Center) GetPublicRedis

func (c *Center) GetPublicRedis() *RedisConfig

func (*Center) GetSizeInBytes

func (c *Center) GetSizeInBytes(key string) uint

func (*Center) GetString

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

func (*Center) GetStringMap

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

func (*Center) GetStringMapString

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

func (*Center) GetStringMapStringSlice

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

func (*Center) GetStringSlice

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

func (*Center) GetTime

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

func (*Center) GetUint

func (c *Center) GetUint(key string) uint

func (*Center) GetUint32

func (c *Center) GetUint32(key string) uint32

func (*Center) GetUint64

func (c *Center) GetUint64(key string) uint64

func (*Center) Open

func (c *Center) Open() (err error)

func (*Center) SetDefault

func (c *Center) SetDefault(key string, value interface{})

func (*Center) SetOnlineMode

func (c *Center) SetOnlineMode(b bool)

func (*Center) SetPublicDefault

func (c *Center) SetPublicDefault()

func (*Center) Sync

func (c *Center) Sync() (err error)

func (*Center) Update

func (c *Center) Update() (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

func (*FileConfig) Sync

func (f *FileConfig) Sync() error

type PostgreSQLConfig

type PostgreSQLConfig struct {
	Write SQLConfig
	Read  []SQLConfig
}

type RedisConfig

type RedisConfig struct {
	// 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
}