summaryrefslogtreecommitdiff
path: root/plugins/reload/watcher.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-19 18:10:39 +0300
committerGitHub <[email protected]>2021-01-19 18:10:39 +0300
commit0ff05b2732b4fd0783f959c94c54d7e39169f979 (patch)
treef50aa894ea4e5b402332f7f4a13b8c50ebb09126 /plugins/reload/watcher.go
parent75ebbaac89ce8ebc3ab8de47b16e137844cfcd8a (diff)
parentd8e42927b63a0b102ce10d465a10d64bb6c02e22 (diff)
Merge pull request #487 from spiral/refactor/server_log_messagesv2.0.0-beta9
refactor(errors, logs): Uniform all errors operations, Update server log level of the server log messages
Diffstat (limited to 'plugins/reload/watcher.go')
-rw-r--r--plugins/reload/watcher.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/plugins/reload/watcher.go b/plugins/reload/watcher.go
index 08c85af9..8dde38de 100644
--- a/plugins/reload/watcher.go
+++ b/plugins/reload/watcher.go
@@ -102,7 +102,7 @@ func NewWatcher(configs []WatcherConfig, log logger.Logger, options ...Options)
// initFs makes initial map with files
func (w *Watcher) initFs() error {
- const op = errors.Op("init fs")
+ const op = errors.Op("watcher_init_fs")
for srvName, config := range w.watcherConfigs {
fileList, err := w.retrieveFileList(srvName, config)
if err != nil {
@@ -148,7 +148,7 @@ func ConvertIgnored(ignored []string) (map[string]struct{}, error) {
// pass map from outside
func (w *Watcher) retrieveFilesSingle(serviceName, path string) (map[string]os.FileInfo, error) {
- const op = errors.Op("retrieve")
+ const op = errors.Op("watcher_retrieve_files_single")
stat, err := os.Stat(path)
if err != nil {
return nil, err
@@ -192,7 +192,7 @@ outer:
func (w *Watcher) StartPolling(duration time.Duration) error {
w.mu.Lock()
- const op = errors.Op("start polling")
+ const op = errors.Op("watcher_start_polling")
if w.started {
w.mu.Unlock()
return errors.E(op, errors.Str("already started"))