dynamic_watched_configuration.go

package manyfaced

import (
	"github.com/nienie/manyfaced/configuration"
	"github.com/nienie/manyfaced/poll"
	"github.com/nienie/manyfaced/property"
	"github.com/nienie/manyfaced/source"
)

//DynamicWatchedConfiguration ...
type DynamicWatchedConfiguration struct {
	*configuration.MapConfiguration
	propertyUpdater *property.DynamicPropertyUpdater
	Source          source.WatchedConfigurationSource
}

//NewDynamicWatchedConfiguration ...
func NewDynamicWatchedConfiguration(source source.WatchedConfigurationSource) (*DynamicWatchedConfiguration, error) {
	cfg := &DynamicWatchedConfiguration{
		MapConfiguration: configuration.NewMapConfiguration(nil),
		propertyUpdater:  &property.DynamicPropertyUpdater{},
		Source:           source,
	}
	currentData, err := source.GetCurrentData()
	if err != nil {
		return nil, err
	}
	result := poll.NewFullWatchedUpdatedResult(currentData)
	cfg.UpdateConfiguration(result)
	cfg.Source.AddUpdateListener(cfg)
	return cfg, nil
}

//UpdateConfiguration ...
func (c *DynamicWatchedConfiguration) UpdateConfiguration(result *poll.WatchedUpdateResult) {
	c.propertyUpdater.UpdateProperties(result, c)
}

//Close ...
func (c *DynamicWatchedConfiguration) Close() {
	c.Source.StopWatching()
}