memory

Documentation

Index

• func Data(d []byte) config.SourceOption
• type Source
  • func NewSource(opts ...config.SourceOption) *Source
  • func (s *Source) Read() (*config.ChangeSet, error)
  • func (s *Source) String() string
  • func (s *Source) Update(data []byte)
  • func (s *Source) Watch() (config.SourceWatcher, error)
• type Watcher
  • func (w *Watcher) Next() (*config.ChangeSet, error)
  • func (w *Watcher) Stop() error

Functions

func Data

func Data(d []byte) config.SourceOption

Types

type Source

type Source struct {
	sync.RWMutex
	ChangeSet *config.ChangeSet
	Watchers  map[string]*Watcher
}

func NewSource

func NewSource(opts ...config.SourceOption) *Source

func (*Source) Read

func (s *Source) Read() (*config.ChangeSet, error)

func (*Source) String

func (s *Source) String() string

func (*Source) Update

func (s *Source) Update(data []byte)

Update allows manual updates of the config data.

func (*Source) Watch

func (s *Source) Watch() (config.SourceWatcher, error)

type Watcher

type Watcher struct {
	Id      string
	Updates chan *config.ChangeSet
	Source  *Source
}

func (*Watcher) Next

func (w *Watcher) Next() (*config.ChangeSet, error)

func (*Watcher) Stop

func (w *Watcher) Stop() error