refactor: unified naming for module startup functions.

This commit is contained in:
Gordon 2024-03-19 12:27:41 +08:00
parent 993e97019a
commit 6e00ed3a02
2 changed files with 2 additions and 2 deletions

View File

@ -243,7 +243,7 @@ func checkKafka(config *config.GlobalConfig) error {
for _, requiredTopic := range requiredTopics { for _, requiredTopic := range requiredTopics {
if !isTopicPresent(requiredTopic, topics) { if !isTopicPresent(requiredTopic, topics) {
return errs.Wrap(err, fmt.Sprintf("Kafka doesn't contain topic: %v", requiredTopic)) return errs.WrapMsg(err, fmt.Sprintf("Kafka doesn't contain topic: %v", requiredTopic))
} }
} }

View File

@ -41,7 +41,7 @@ func CheckDirectory(cfg *config.Config) error {
for _, targetDir := range cfg.TargetDirs { for _, targetDir := range cfg.TargetDirs {
err := filepath.Walk(targetDir, func(path string, info os.FileInfo, err error) error { err := filepath.Walk(targetDir, func(path string, info os.FileInfo, err error) error {
if err != nil { if err != nil {
return errs.Wrap(err, fmt.Sprintf("error walking directory '%s'", targetDir)) return errs.WrapMsg(err, fmt.Sprintf("error walking directory '%s'", targetDir))
} }
// Skip if the directory is in the ignore list // Skip if the directory is in the ignore list