configmgr

Documentation

Index

• Constants
• Variables
• func InitialiseApolloConfig(appConfig *config.AppConfig)
• func InitialiseNacosConfig(param vo.NacosClientParam, dataId, format, group string)
• func LoadFromApollo(appConfig *config.AppConfig)
• func LoadFromNacos(param vo.NacosClientParam, dataId, format, group string) error
• type BaseApolloListener
  • func (c *BaseApolloListener) OnNewestChange(event *storage.FullChangeEvent)
• type NacosChangeEvent
• type NacosConfigListenerParam
• type NacosConfigMgr
  • func NewNacosConfigMgr(dataIds []string, group string, format nacosConfigType, namespaceId string, ...) *NacosConfigMgr
  • func (m *NacosConfigMgr) AddChangeListener(param NacosConfigListenerParam)
  • func (m *NacosConfigMgr) CallbackOnChange(namespace, group, dataId, data, old string)
  • func (m *NacosConfigMgr) Listeners() cache.ConcurrentMap

Constants

const (
	DotenvConfigFormat nacosConfigType = "dotenv"
	YamlConfigFormat   nacosConfigType = "yaml"
)

Variables

var ApolloClient agollo.Client

var NewConfigClient = clients.NewConfigClient

var StartWithConfig = agollo.StartWithConfig

var StringReader = func(s string) io.Reader {
	return strings.NewReader(s)
}

Functions

func InitialiseApolloConfig

func InitialiseApolloConfig(appConfig *config.AppConfig)

func InitialiseNacosConfig

func InitialiseNacosConfig(param vo.NacosClientParam, dataId, format, group string)

func LoadFromApollo

func LoadFromApollo(appConfig *config.AppConfig)

func LoadFromNacos

func LoadFromNacos(param vo.NacosClientParam, dataId, format, group string) error

Types

type BaseApolloListener

type BaseApolloListener struct {
	SkippedFirstEvent bool
	Lock              sync.Mutex
}

func (*BaseApolloListener) OnNewestChange

func (c *BaseApolloListener) OnNewestChange(event *storage.FullChangeEvent)

type NacosChangeEvent

type NacosChangeEvent struct {
	Namespace, Group, DataId string
	Changes                  map[string]maputils.Change
}

type NacosConfigListenerParam

type NacosConfigListenerParam struct {
	DataId   string
	OnChange func(event *NacosChangeEvent)
}

type NacosConfigMgr

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

var NacosClient *NacosConfigMgr

func NewNacosConfigMgr

func NewNacosConfigMgr(dataIds []string, group string, format nacosConfigType, namespaceId string, client config_client.IConfigClient, listeners cache.ConcurrentMap) *NacosConfigMgr

func (*NacosConfigMgr) AddChangeListener

func (m *NacosConfigMgr) AddChangeListener(param NacosConfigListenerParam)

func (*NacosConfigMgr) CallbackOnChange

func (m *NacosConfigMgr) CallbackOnChange(namespace, group, dataId, data, old string)

func (*NacosConfigMgr) Listeners

func (m *NacosConfigMgr) Listeners() cache.ConcurrentMap