ridv/gorealis-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases 13 Packages Wiki Activity Actions

Minor error message clarification

Browse source
This commit is contained in:
Renan DelValle 2019-09-12 09:23:27 -07:00 • committed by Renan DelValle
parent d67b8ca1d7
commit fe4a0dc06e
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
realis.go
View file

@ -192,7 +192,7 @@ func Trace() ClientOption {
func newTJSONTransport(url string, timeout time.Duration, config *clientConfig) (thrift.TTransport, error) { func newTJSONTransport(url string, timeout time.Duration, config *clientConfig) (thrift.TTransport, error) {
trans, err := defaultTTransport(url, timeout, config) trans, err := defaultTTransport(url, timeout, config)
if err != nil { if err != nil {
return nil, errors.Wrap(err, "Error creating realis") return nil, errors.Wrap(err, "error creating realis")
} }
httpTrans := (trans).(*thrift.THttpClient) httpTrans := (trans).(*thrift.THttpClient)
httpTrans.SetHeader("Content-Type", "application/x-thrift") httpTrans.SetHeader("Content-Type", "application/x-thrift")
@ -203,7 +203,7 @@ func newTJSONTransport(url string, timeout time.Duration, config *clientConfig)
func newTBinTransport(url string, timeout time.Duration, config *clientConfig) (thrift.TTransport, error) { func newTBinTransport(url string, timeout time.Duration, config *clientConfig) (thrift.TTransport, error) {
trans, err := defaultTTransport(url, timeout, config) trans, err := defaultTTransport(url, timeout, config)
if err != nil { if err != nil {
return nil, errors.Wrap(err, "Error creating realis") return nil, errors.Wrap(err, "error creating realis")
} }
httpTrans := (trans).(*thrift.THttpClient) httpTrans := (trans).(*thrift.THttpClient)
httpTrans.DelHeader("Content-Type") // Workaround for using thrift HttpPostClient httpTrans.DelHeader("Content-Type") // Workaround for using thrift HttpPostClient
@ -258,7 +258,7 @@ func NewClient(options ...ClientOption) (*Client, error) {
if config.zkOptions != nil { if config.zkOptions != nil {
url, err = LeaderFromZKOpts(config.zkOptions...) url, err = LeaderFromZKOpts(config.zkOptions...)
if err != nil { if err != nil {
return nil, NewTemporaryError(errors.Wrap(err, "leaderFromZK error")) return nil, NewTemporaryError(errors.Wrap(err, "unable to determine leader from zookeeper"))
} }
config.logger.Println("Scheduler URL from ZK: ", url) config.logger.Println("Scheduler URL from ZK: ", url)
} else if config.cluster != nil { } else if config.cluster != nil {
@ -267,7 +267,7 @@ func NewClient(options ...ClientOption) (*Client, error) {
url, err = LeaderFromZK(*config.cluster) url, err = LeaderFromZK(*config.cluster)
// If ZK is configured, throw an error if the leader is unable to be determined // If ZK is configured, throw an error if the leader is unable to be determined
if err != nil { if err != nil {
return nil, NewTemporaryError(errors.Wrap(err, "LeaderFromZK error")) return nil, NewTemporaryError(errors.Wrap(err, "unable to determine leader from zookeeper"))
} }
config.logger.Println("Scheduler URL from ZK: ", url) config.logger.Println("Scheduler URL from ZK: ", url)
} else if config.url != "" { } else if config.url != "" {