pkg

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 19, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

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())
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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