pkg

Documentation

Index

• Variables
• func LoadConf(config interface{}, opts ...OptionFunc)
• func ReadWatcher(f *File, conf *Config)
• func StrVal(value interface{}) string
• func TempFileWithText(text string) (*os.File, error)
• func TempFilenameWithText(text string) (string, error)
• type ChangeSet
  • func (c *ChangeSet) HashMd5() string
• type Config
  • func Load(opts ...OptionFunc) *Config
  • func New() *Config
  • func (s *Config) GetAuth() *confs.JwtConfig
  • func (s *Config) GetDB() *confs.DBConfig
  • func (s *Config) GetLog() *confs.LogConfig
  • func (s *Config) GetMq() *confs.MqConfig
  • func (s *Config) GetPlugins() *confs.PluginConfig
  • func (s *Config) GetRedis() *confs.RedisConfig
  • func (s *Config) GetRegister() *confs.RegistryConfig
  • func (s *Config) GetRpcClient() *confs.RpcClientConf
  • func (s *Config) GetRpcServer() *confs.RpcServerConf
  • func (s *Config) GetServer() *confs.ServerConfig
  • func (s *Config) GetWsCore() *confs.WsConfig
• type ConfigItem
• type Encoder
  • func NewJsonEncoder() Encoder
  • func NewYamlEncoder() Encoder
• type File
  • func LoadFile(opts ...OptionFunc) (*File, error)
  • func (f *File) GetBytes() []byte
  • func (f *File) GetConf() FileMap
  • func (f *File) GetString() string
  • func (f *File) Read() (*File, error)
  • func (f *File) Reload(conf *Config) *File
  • func (f *File) Watch() (WatcherInter, error)
  • func (f *File) YamlMerge(conf *Config) bool
• type FileMap
• type OptionFunc
  • func WithPath(path string) OptionFunc
• type Options
• type ValueInter
  • func GetPath[T wrapAble](path ...string) ValueInter[T]
• type WatcherInter
• type WrapInter

Variables

var GlobalConf = make(FileMap)

Functions

func LoadConf

func LoadConf(config interface{}, opts ...OptionFunc)

LoadConf 构建指定的 config配置实例

func ReadWatcher

func ReadWatcher(f *File, conf *Config)

ReadWatcher 循环监听配置文件修改

func StrVal

func StrVal(value interface{}) string

StrVal 获取变量的字符串值 * @浮点型 3.0将会转换成字符串3, "3" * @非数值或字符类型的变量将会被转换成JSON格式字符串

func TempFileWithText

func TempFileWithText(text string) (*os.File, error)

TempFileWithText 传入text 创建文件并写入内容 注意：调用者需要在外部关闭文件句柄，并通过 file.Stat()获取文件信息，再通过filename 手动删除临时文件 os.Remove

func TempFilenameWithText

func TempFilenameWithText(text string) (string, error)

TempFilenameWithText 创建文件并写入指定内容, 返回文件完整的绝对路径。 注意：调用者无需手动关闭文件句柄，但需要调用 os.Remove(filename) 函数来临时删除文件

Types

type ChangeSet

type ChangeSet struct {
	Data      []byte
	CheckMd5  string //md5校验值确保唯一
	Format    string
	Source    string
	Timestamp time.Time
}

ChangeSet 文件源，data存放文件源所包含的内容，其余字段声明文件的路径等fileInfo信息

func (*ChangeSet) HashMd5

func (c *ChangeSet) HashMd5() string

type Config

type Config struct {
	*confs.ServerConfig
	*confs.JwtConfig
	*confs.LogConfig
	*confs.RegistryConfig
	*confs.DBConfig
	*confs.RedisConfig
	*confs.MqConfig
	*confs.PluginConfig
	*confs.RpcServerConf
	*confs.RpcClientConf
	*confs.WsConfig
}

func Load

func Load(opts ...OptionFunc) *Config

Load 构建整个Config

func New

func New() *Config

func (*Config) GetAuth

func (s *Config) GetAuth() *confs.JwtConfig

func (*Config) GetDB

func (s *Config) GetDB() *confs.DBConfig

func (*Config) GetLog

func (s *Config) GetLog() *confs.LogConfig

func (*Config) GetMq

func (s *Config) GetMq() *confs.MqConfig

func (*Config) GetPlugins

func (s *Config) GetPlugins() *confs.PluginConfig

func (*Config) GetRedis

func (s *Config) GetRedis() *confs.RedisConfig

func (*Config) GetRegister

func (s *Config) GetRegister() *confs.RegistryConfig

func (*Config) GetRpcClient

func (s *Config) GetRpcClient() *confs.RpcClientConf

func (*Config) GetRpcServer

func (s *Config) GetRpcServer() *confs.RpcServerConf

func (*Config) GetServer

func (s *Config) GetServer() *confs.ServerConfig

func (*Config) GetWsCore

func (s *Config) GetWsCore() *confs.WsConfig

type ConfigItem

type ConfigItem interface {
	IsLoad() bool
}

type Encoder

type Encoder interface {
	Encode(interface{}) ([]byte, error) //编码
	Decode([]byte, interface{}) error   //解码
	String() string                     //返回文件名字
}

func NewJsonEncoder

func NewJsonEncoder() Encoder

func NewYamlEncoder

func NewYamlEncoder() Encoder

type File

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

func LoadFile

func LoadFile(opts ...OptionFunc) (*File, error)

func (*File) GetBytes

func (f *File) GetBytes() []byte

func (*File) GetConf

func (f *File) GetConf() FileMap

func (*File) GetString

func (f *File) GetString() string

func (*File) Read

func (f *File) Read() (*File, error)

func (*File) Reload

func (f *File) Reload(conf *Config) *File

func (*File) Watch

func (f *File) Watch() (WatcherInter, error)

func (*File) YamlMerge

func (f *File) YamlMerge(conf *Config) bool

type FileMap

type FileMap map[string]interface{}

type OptionFunc

type OptionFunc func(o *Options)

func WithPath

func WithPath(path string) OptionFunc

type Options

type Options struct {
	Encoding map[string]Encoder
	// contains filtered or unexported fields
}

type ValueInter

type ValueInter[T wrapAble] interface {
	Value() WrapInter[T]
}

func GetPath

func GetPath[T wrapAble](path ...string) ValueInter[T]

type WatcherInter

type WatcherInter interface {
	Next(config *Config) (*File, error)
	Stop() error
}

type WrapInter

type WrapInter[T wrapAble] interface {
	Unwrap() T
	UnwrapOr(T) T
	UnwrapFunc(fn func())
}