dynamicloading

A library for dynamically loading configurations

Use

需要实现Observer接口，可以参考一下代码中的ObserverImpl

package main

import (
	"fmt"
	"time"

	"github.com/dream-kzx/dynamicloading"
	"github.com/dream-kzx/dynamicloading/source/file"
)

type ObserverImpl struct {
}

func (t *ObserverImpl) UpdateConfig(configData interface{}) {
	fmt.Println(string(configData.([]byte)))
}

func main() {
	fileSource := file.NewSource("conf/conf.json", true)
	impl := ObserverImpl{}

	manager := dynamicloading.New(fileSource, dynamicloading.WithPeriod(2000))
	manager.Register(&impl)
	_ = manager.Start()

	time.Sleep(30 * time.Second)
}

自定义日志

可以通过实现github.com/dream-kzx/dynamicloading/logger的Logger接口，来定制日志

import(
  "github.com/dream-kzx/dynamicloading/logger"
)

log := &logger.DefaultLogger{}

manager := dynamicloading.New(fileSource, dynamicloading.WithPeriod(2000), dynamicloading.WithLogger(log))

自定义配置源

需要实现ConfigSource接口，可以参考source/file/file.go

type ConfigSource interface {
	Read() (interface{}, error)
}

GitHub

View Github