Skip to content

Commit

Permalink
chore(io): clean up io binder and logs
Browse files Browse the repository at this point in the history
Signed-off-by: Jiyong Huang <huangjy@emqx.io>
  • Loading branch information
ngjaying committed Sep 20, 2024
1 parent 2d58919 commit fcb1c2d
Show file tree
Hide file tree
Showing 9 changed files with 21 additions and 363 deletions.
342 changes: 0 additions & 342 deletions etc/sources/sql.json

This file was deleted.

8 changes: 0 additions & 8 deletions etc/sources/sql.yaml

This file was deleted.

3 changes: 1 addition & 2 deletions internal/meta/msgUtil.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
// Copyright 2021 EMQ Technologies Co., Ltd.
// Copyright 2021-2024 EMQ Technologies Co., Ltd.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -52,7 +52,6 @@ func ReadUiMsgDir() error {

for _, entry := range dirEntries {
fName := entry.Name()
kconf.Log.Infof("uiMsg file : %s", fName)
fPath := path.Join(dir, fName)
if conf, err := ini.Load(fPath); nil != err {
return err
Expand Down
1 change: 0 additions & 1 deletion internal/meta/sinkMeta.go
Original file line number Diff line number Diff line change
Expand Up @@ -253,7 +253,6 @@ func ReadSinkMetaFile(filePath string, installed bool) error {
return err
}
loadConfigOperatorForSink(strings.TrimSuffix(finame, `.json`))
conf.Log.Infof("Loading metadata file for sink: %s", finame)
return nil
}

Expand Down
2 changes: 0 additions & 2 deletions internal/meta/sourceMeta.go
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,6 @@ func ReadSourceMetaDir(scanChecker InstallChecker, lookupChecker InstallChecker)
if err = ReadSourceMetaFile(path.Join(confDir, "mqtt_source.json"), true, false); nil != err {
return err
}
conf.Log.Infof("Loading metadata file for source : %s", "mqtt_source.json")

for _, entry := range dirEntries {
fileName := entry.Name()
Expand All @@ -145,7 +144,6 @@ func ReadSourceMetaDir(scanChecker InstallChecker, lookupChecker InstallChecker)
if err = ReadSourceMetaFile(filePath, isScan, isLookup); nil != err {
return err
}
conf.Log.Infof("Loading metadata file for source : %s", fileName)
} else {
conf.Log.Warnf("Find source metadata file but not installed : %s", fileName)
}
Expand Down
Loading

0 comments on commit fcb1c2d

Please sign in to comment.