loader

Documentation

Index

• type RemoteConfigurationLoader
  • func NewRemoteConfigurationLoader(props *mas.PropertiesConfiguration, etcdConfiguration *etcd.EtcdConfiguration) *RemoteConfigurationLoader
  • func (l *RemoteConfigurationLoader) AddRouterListener(listener config.RouterConfigurationListener)
  • func (l *RemoteConfigurationLoader) Close() error
  • func (l *RemoteConfigurationLoader) GetConfiguration() *config.RemoteClusterConfiguration
  • func (l *RemoteConfigurationLoader) Init()

Types

type RemoteConfigurationLoader

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

RemoteConfigurationLoader to load remote configuration from etcd

func NewRemoteConfigurationLoader

func NewRemoteConfigurationLoader(props *mas.PropertiesConfiguration,
	etcdConfiguration *etcd.EtcdConfiguration) *RemoteConfigurationLoader

@param props is yaml properties configuration entity @param etcdConfiguration is yaml etcd configuration entity

func (*RemoteConfigurationLoader) AddRouterListener

func (l *RemoteConfigurationLoader) AddRouterListener(listener config.RouterConfigurationListener)

AddRouterListener add a router configuration listener

func (*RemoteConfigurationLoader) Close

func (l *RemoteConfigurationLoader) Close() error

Close loader's etcdClient and set loader's listeners nil

func (*RemoteConfigurationLoader) GetConfiguration

func (l *RemoteConfigurationLoader) GetConfiguration() *config.RemoteClusterConfiguration

GetConfiguration form etcd

func (*RemoteConfigurationLoader) Init

func (l *RemoteConfigurationLoader) Init()

Init etcd start watch activeKey