config

Documentation

Index

• func NewConfigSource(client config_client.IConfigClient, opts ...Option) config.Source
• type Config
  • func (c *Config) Load() ([]*config.KeyValue, error)
  • func (c *Config) Watch() (config.Watcher, error)
• type Option
  • func CacheDir(cacheDir string) Option
  • func DataID(dataID string) Option
  • func Group(group string) Option
  • func LogDir(logDir string) Option
  • func LogLevel(logLevel string) Option
  • func TimeoutMs(timeoutMs uint64) Option
• type Watcher
  • func (w *Watcher) Close() error
  • func (w *Watcher) Next() ([]*config.KeyValue, error)
  • func (w *Watcher) Stop() error

Functions

func NewConfigSource

func NewConfigSource(client config_client.IConfigClient, opts ...Option) config.Source

Types

type Config

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

func (*Config) Load

func (c *Config) Load() ([]*config.KeyValue, error)

func (*Config) Watch

func (c *Config) Watch() (config.Watcher, error)

type Option

type Option func(*options)

func CacheDir

func CacheDir(cacheDir string) Option

func DataID

func DataID(dataID string) Option

func Group

func Group(group string) Option

func LogDir

func LogDir(logDir string) Option

func LogLevel

func LogLevel(logLevel string) Option

func TimeoutMs

func TimeoutMs(timeoutMs uint64) Option

type Watcher

type Watcher struct {
	context.Context
	// contains filtered or unexported fields
}

func (*Watcher) Close

func (w *Watcher) Close() error

func (*Watcher) Next

func (w *Watcher) Next() ([]*config.KeyValue, error)

func (*Watcher) Stop

func (w *Watcher) Stop() error