cfgmgr

package

v1.0.2 Latest Latest Go to latest Published: Sep 7, 2023 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/qcdong2016/duck

Documentation ¶

Index ¶

type Config
- func (c *Config[T]) Get() *T
- func (c *Config[T]) Set(t *T)
type ConfigManager
- func New(w Watcher) *ConfigManager
type EtcdWatcher
- func NewEtcdWatcher(et *etcd.Etcd) *EtcdWatcher
type FileWatcher
- func NewFileWatcher(path string) *FileWatcher
type LoadData
- func (d *LoadData) IsMatch(file string) bool
type LoadFunc
- func AtomicLoad[T any](dest *Config[T], unmarshalFn unmarshaler) LoadFunc
type LoadFuncWithName
type Watcher

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config[T any] struct {
	// contains filtered or unexported fields
}

func (*Config[T]) Get ¶

func (c *Config[T]) Get() *T

func (*Config[T]) Set ¶

func (c *Config[T]) Set(t *T)

type ConfigManager ¶

type ConfigManager struct {
	Etcd *etcd.Etcd

	Watcher Watcher
	// contains filtered or unexported fields
}

func New ¶

func New(w Watcher) *ConfigManager

func (*ConfigManager) Close ¶

func (m *ConfigManager) Close()

func (*ConfigManager) GetErr ¶

func (m *ConfigManager) GetErr(file, md5 string) string

func (*ConfigManager) Load ¶

func (m *ConfigManager) Load(file string)

func (*ConfigManager) LoadAll ¶

func (m *ConfigManager) LoadAll()

func (*ConfigManager) Start ¶

func (m *ConfigManager) Start()

func (*ConfigManager) Watch ¶

func (m *ConfigManager) Watch(file string, f LoadFunc)

func (*ConfigManager) WatchAndLoad ¶

func (m *ConfigManager) WatchAndLoad(file string, f LoadFunc)

func (*ConfigManager) WatchPrefix ¶

func (m *ConfigManager) WatchPrefix(file string, f LoadFuncWithName)

type EtcdWatcher ¶

type EtcdWatcher struct {
	Etcd *etcd.Etcd
	// contains filtered or unexported fields
}

func NewEtcdWatcher ¶

func NewEtcdWatcher(et *etcd.Etcd) *EtcdWatcher

func (*EtcdWatcher) GetFileNames ¶

func (m *EtcdWatcher) GetFileNames() ([]string, error)

func (*EtcdWatcher) Init ¶

func (m *EtcdWatcher) Init() error

func (*EtcdWatcher) IsExists ¶

func (m *EtcdWatcher) IsExists(name string) bool

func (*EtcdWatcher) ReadFile ¶

func (m *EtcdWatcher) ReadFile(name string) ([]byte, error)

func (*EtcdWatcher) Start ¶

func (m *EtcdWatcher) Start(closeCh chan struct{}, dispatch func(string, []byte))

func (*EtcdWatcher) Stop ¶

func (m *EtcdWatcher) Stop() error

func (*EtcdWatcher) WriteFile ¶

func (m *EtcdWatcher) WriteFile(name string, content []byte) error

type FileWatcher ¶

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

func NewFileWatcher ¶

func NewFileWatcher(path string) *FileWatcher

func (*FileWatcher) GetFileNames ¶

func (m *FileWatcher) GetFileNames() (ret []string, err error)

func (*FileWatcher) Init ¶

func (m *FileWatcher) Init() error

func (*FileWatcher) IsExists ¶

func (m *FileWatcher) IsExists(name string) bool

func (*FileWatcher) ReadFile ¶

func (m *FileWatcher) ReadFile(name string) ([]byte, error)

func (*FileWatcher) Start ¶

func (m *FileWatcher) Start(closeCh chan struct{}, dispatch func(string, []byte))

func (*FileWatcher) Stop ¶

func (m *FileWatcher) Stop() error

func (*FileWatcher) WriteFile ¶

func (m *FileWatcher) WriteFile(name string, content []byte) error

type LoadData ¶

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

func (*LoadData) IsMatch ¶

func (d *LoadData) IsMatch(file string) bool

type LoadFunc ¶

type LoadFunc func(buf []byte) error

func AtomicLoad ¶

func AtomicLoad[T any](dest *Config[T], unmarshalFn unmarshaler) LoadFunc

xxconfig := Config[T]{} ConfigManager.Watch("config.json", AtomicLoad(&xxconfig, json.Unmarshal)) cfg := xxconfig.Get()

type LoadFuncWithName ¶

type LoadFuncWithName func(file string, buf []byte) error

type Watcher ¶

type Watcher interface {
	Init() error
	Start(closeCh chan struct{}, dispatch func(string, []byte))
	Stop() error
	GetFileNames() ([]string, error)
	ReadFile(name string) ([]byte, error)
	WriteFile(name string, content []byte) error
	IsExists(name string) bool
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL