From 8424f6ddfef4ae9f5402cc65560b54d6c1d429c4 Mon Sep 17 00:00:00 2001 From: wangjian Date: Fri, 24 Mar 2023 08:44:08 +0800 Subject: [PATCH] fix --- config/config.yaml | 5 ++++- go.mod | 5 +++-- main.go | 6 +----- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/config/config.yaml b/config/config.yaml index 436acca..5f10d79 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -12,4 +12,7 @@ consul: tags: - mq functions: - - name: echo-sf \ No newline at end of file + - name: echo-sf + - name: task-request + - name: task-response + - name: task-execute \ No newline at end of file diff --git a/go.mod b/go.mod index 8115a31..63bbe83 100644 --- a/go.mod +++ b/go.mod @@ -3,6 +3,8 @@ module hpds_mq go 1.19 require ( + git.hpds.cc/Component/network v0.0.0-20221012021659-2433c68452d5 + git.hpds.cc/pavement/hpds_node v0.0.0-20230307094826-753c4fe9c877 github.com/hashicorp/consul/api v1.15.3 github.com/spf13/cobra v1.6.0 github.com/spf13/viper v1.13.0 @@ -14,8 +16,6 @@ require ( cloud.google.com/go/compute v1.6.1 // indirect cloud.google.com/go/firestore v1.6.1 // indirect git.hpds.cc/Component/mq_coder v0.0.0-20221010064749-174ae7ae3340 // indirect - git.hpds.cc/Component/network v0.0.0-20221012021659-2433c68452d5 // indirect - git.hpds.cc/pavement/hpds_node v0.0.0-20221023053316-37f7ba99eab3 // indirect github.com/armon/go-metrics v0.3.10 // indirect github.com/coreos/go-semver v0.3.0 // indirect github.com/coreos/go-systemd/v22 v22.3.2 // indirect @@ -86,3 +86,4 @@ require ( gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 // indirect gopkg.in/yaml.v2 v2.4.0 // indirect ) + diff --git a/main.go b/main.go index cb06ead..41a08c9 100644 --- a/main.go +++ b/main.go @@ -16,17 +16,13 @@ var ( ) func init() { - //rootCmd.PersistentFlags().StringVarP(&cmd.ConfigFileFlag, "config", "c", cmd.ConfigFileFlag, "The configuration file path") - //rootCmd.PersistentFlags().StringVarP(&cmd.ConsulAddress, "remote", "r", cmd.ConsulAddress, "The configuration remote consul address") - rootCmd.AddCommand(cmd.NewStartCmd()) //cmd.NewStartCmd() } func main() { - if err := rootCmd.Execute(); err != nil { - fmt.Fprint(os.Stderr, err.Error()) + _, _ = fmt.Fprint(os.Stderr, err.Error()) os.Exit(1) } }