watcher

Documentation

Index

• type Config
• type ConfigMap
• type Namespace
• type Watcher
  • func New(ctx context.Context, cfg Config) (*Watcher, error)
  • func (w *Watcher) Config() ConfigMap
  • func (w *Watcher) MockFS(fs afero.Fs)
  • func (w *Watcher) ReloadConfig(log nlogger.Provider) error
  • func (w *Watcher) TriggerEvent()

Types

type Config

type Config struct {
	Log           nlogger.Provider
	File          string
	WatchInterval time.Duration
}

Config holds the watcher config

type ConfigMap

type ConfigMap map[string]map[string]map[string]Namespace

ConfigMap holds the app config

type Namespace

type Namespace struct {
	ReleaseKey string            `yaml:"releaseKey" json:"releaseKey"`
	Properties map[string]string `yaml:"properties" json:"properties"`
	Yml        string            `yaml:"yml" json:"yml"`
	Yaml       string            `yaml:"yaml" json:"yaml"`
	JSON       string            `yaml:"json" json:"json"`
	XML        string            `yaml:"xml" json:"xml"`
}

Namespace holds the namespace config

type Watcher

type Watcher struct {
	UpdateEvent <-chan struct{}
	// contains filtered or unexported fields
}

Watcher holds information for the watcher

func New

func New(ctx context.Context, cfg Config) (*Watcher, error)

New returns a new Watcher

func (*Watcher) Config

func (w *Watcher) Config() ConfigMap

Config returns a stored read-only ConfigMap

func (*Watcher) MockFS

func (w *Watcher) MockFS(fs afero.Fs)

MockFS injects mocked fs into Watcher this should only be called immediately after watcher is initialized since it's not a thread safe operation

func (*Watcher) ReloadConfig

func (w *Watcher) ReloadConfig(log nlogger.Provider) error

ReloadConfig reloads file config without senging an update event

func (*Watcher) TriggerEvent

func (w *Watcher) TriggerEvent()

TriggerEvent triggers the update event