configuration

Documentation

Index

• Constants
• type CacheFileInfo
• type CachePersistHandler
  • func NewCachePersistHandler(persistDir string, maxWriteRetry int, maxReadRetry int, ...) (*CachePersistHandler, error)
  • func (cph *CachePersistHandler) DeleteCacheFromFile(fileName string)
  • func (cph *CachePersistHandler) LoadMessageFromFile(relativeFile string, message interface{}) error
  • func (cph *CachePersistHandler) SaveMessageToFile(fileName string, svcResp interface{})
• type ConfigFileFlow
  • func NewConfigFileFlow(connector configconnector.ConfigConnector, chain configfilter.Chain, ...) (*ConfigFileFlow, error)
  • func (c *ConfigFileFlow) CreateConfigFile(namespace, fileGroup, fileName, content string) error
  • func (c *ConfigFileFlow) Destroy()
  • func (c *ConfigFileFlow) GetConfigFile(req *model.GetConfigFileRequest) (model.ConfigFile, error)
  • func (c *ConfigFileFlow) PublishConfigFile(namespace, fileGroup, fileName string) error
  • func (c *ConfigFileFlow) UpdateConfigFile(namespace, fileGroup, fileName, content string) error
• type ConfigFileRepo
  • func (r *ConfigFileRepo) AddChangeListener(listener ConfigFileRepoChangeListener)
  • func (r *ConfigFileRepo) GetContent() string
  • func (r *ConfigFileRepo) GetNotifiedVersion() uint64
• type ConfigFileRepoChangeListener
• type ConfigFlow
  • func NewConfigFlow(connector configconnector.ConfigConnector, chain configfilter.Chain, ...) (*ConfigFlow, error)
• type ConfigGroupFlow
  • func (flow *ConfigGroupFlow) GetConfigGroup(namespace, fileGroup string) (model.ConfigFileGroup, error)
• type ConfigGroupRepo
  • func (repo *ConfigGroupRepo) AddChangeListener(listener func(*configconnector.ConfigGroupResponse))

Constants

const (
	// PatternService is the pattern of service name
	PatternService = "config#%s#%s#%s"
	// CacheSuffix filesystem suffix
	CacheSuffix = ".json"
	// PatternGlob is the pattern of glob
	PatternGlob = "#?*#?*#?*"
)

const (
	NotExistedFileContent = string("@@not_existed@@")
)

const (
	PullConfigMaxRetryTimes = 3
)

Types

type CacheFileInfo

type CacheFileInfo struct {
	Msg      proto.Message
	FileInfo os.FileInfo
}

CacheFileInfo 文件信息

type CachePersistHandler

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

CachePersistHandler 持久化工具类

func NewCachePersistHandler

func NewCachePersistHandler(persistDir string, maxWriteRetry int,
	maxReadRetry int, retryInterval time.Duration) (*CachePersistHandler, error)

NewCachePersistHandler create persistence handler

func (*CachePersistHandler) DeleteCacheFromFile

func (cph *CachePersistHandler) DeleteCacheFromFile(fileName string)

DeleteCacheFromFile 删除缓存文件

func (*CachePersistHandler) LoadMessageFromFile

func (cph *CachePersistHandler) LoadMessageFromFile(relativeFile string, message interface{}) error

LoadMessageFromFile 从相对文件中加载缓存

func (*CachePersistHandler) SaveMessageToFile

func (cph *CachePersistHandler) SaveMessageToFile(fileName string, svcResp interface{})

SaveMessageToFile 按服务来进行缓存存储

type ConfigFileFlow

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

ConfigFileFlow 配置中心核心服务门面类

func NewConfigFileFlow

func NewConfigFileFlow(connector configconnector.ConfigConnector, chain configfilter.Chain,
	conf config.Configuration) (*ConfigFileFlow, error)

NewConfigFileFlow 创建配置中心服务

func (*ConfigFileFlow) CreateConfigFile

func (c *ConfigFileFlow) CreateConfigFile(namespace, fileGroup, fileName, content string) error

CreateConfigFile 创建配置文件

func (*ConfigFileFlow) Destroy

func (c *ConfigFileFlow) Destroy()

Destroy 销毁服务

func (*ConfigFileFlow) GetConfigFile

func (c *ConfigFileFlow) GetConfigFile(req *model.GetConfigFileRequest) (model.ConfigFile, error)

GetConfigFile 获取配置文件

func (*ConfigFileFlow) PublishConfigFile

func (c *ConfigFileFlow) PublishConfigFile(namespace, fileGroup, fileName string) error

PublishConfigFile 发布配置文件

func (*ConfigFileFlow) UpdateConfigFile

func (c *ConfigFileFlow) UpdateConfigFile(namespace, fileGroup, fileName, content string) error

UpdateConfigFile 更新配置文件

type ConfigFileRepo

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

ConfigFileRepo 服务端配置文件代理类，从服务端拉取配置并同步数据

func (*ConfigFileRepo) AddChangeListener

func (r *ConfigFileRepo) AddChangeListener(listener ConfigFileRepoChangeListener)

AddChangeListener 添加配置文件变更监听器

func (*ConfigFileRepo) GetContent

func (r *ConfigFileRepo) GetContent() string

GetContent 获取配置文件内容

func (*ConfigFileRepo) GetNotifiedVersion

func (r *ConfigFileRepo) GetNotifiedVersion() uint64

type ConfigFileRepoChangeListener

type ConfigFileRepoChangeListener func(configFileMetadata model.ConfigFileMetadata, newContent string) error

ConfigFileRepoChangeListener 远程配置文件发布监听器

type ConfigFlow

type ConfigFlow struct {
	*ConfigFileFlow
	*ConfigGroupFlow
}

func NewConfigFlow

func NewConfigFlow(connector configconnector.ConfigConnector, chain configfilter.Chain,
	configuration config.Configuration) (*ConfigFlow, error)

NewConfigFlow 创建配置中心服务

type ConfigGroupFlow

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

func (*ConfigGroupFlow) GetConfigGroup

func (flow *ConfigGroupFlow) GetConfigGroup(namespace, fileGroup string) (model.ConfigFileGroup, error)

type ConfigGroupRepo

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

ConfigGroupRepo 服务端配置文件代理类，从服务端拉取配置并同步数据

func (*ConfigGroupRepo) AddChangeListener

func (repo *ConfigGroupRepo) AddChangeListener(listener func(*configconnector.ConfigGroupResponse))