diff --git a/config/support/config_loader.go b/config/support/config_loader.go index 61f1b31ce96e78f8f50b97e29a2f6f867c2618e8..b223615f89aa3912ed63ae8876921e48d9e1b5c2 100644 --- a/config/support/config_loader.go +++ b/config/support/config_loader.go @@ -88,6 +88,13 @@ func consumerInit(confConFile string) error { return fmt.Errorf("yaml.Unmarshal() = error:%s", jerrors.ErrorStack(err)) } + if consumerConfig.RequestTimeout, err = time.ParseDuration(consumerConfig.Request_Timeout); err != nil { + return jerrors.Annotatef(err, "time.ParseDuration(Request_Timeout{%#v})", consumerConfig.Request_Timeout) + } + if consumerConfig.ConnectTimeout, err = time.ParseDuration(consumerConfig.Connect_Timeout); err != nil { + return jerrors.Annotatef(err, "time.ParseDuration(Connect_Timeout{%#v})", consumerConfig.Connect_Timeout) + } + gxlog.CInfo("consumer config{%#v}\n", consumerConfig) return nil } @@ -128,7 +135,7 @@ type ConsumerConfig struct { Connect_Timeout string `default:"100ms" yaml:"connect_timeout" json:"connect_timeout,omitempty"` ConnectTimeout time.Duration - Request_Timeout string `yaml:"request_timeout" default:"5s" json:"request_timeout,omitempty"` // 500ms, 1m + Request_Timeout string `yaml:"request_timeout" default:"5s" json:"request_timeout,omitempty"` RequestTimeout time.Duration // codec & selector & transport & registry diff --git a/examples/jsonrpc/go-client/app/client.go b/examples/jsonrpc/go-client/app/client.go index ee934a04f8d1879c4332c306c2d2a72fa572b7a7..aacb37e4006204ec69ff5a148f12b47e2e76b29f 100644 --- a/examples/jsonrpc/go-client/app/client.go +++ b/examples/jsonrpc/go-client/app/client.go @@ -75,7 +75,7 @@ func main() { } func initProfiling() { - if !support.GetProviderConfig().Pprof_Enabled { + if !support.GetConsumerConfig().Pprof_Enabled { return } const ( @@ -91,7 +91,7 @@ func initProfiling() { if err != nil { panic("cat not get local ip!") } - addr = ip + ":" + strconv.Itoa(support.GetProviderConfig().Pprof_Port) + addr = ip + ":" + strconv.Itoa(support.GetConsumerConfig().Pprof_Port) log.Info("App Profiling startup on address{%v}", addr+PprofPath) go func() {