-
Notifications
You must be signed in to change notification settings - Fork 5.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: Bump github.com/aerospike/aerospike-client-go from 1.27.0 to 5.7.0 #10604
feat: Bump github.com/aerospike/aerospike-client-go from 1.27.0 to 5.7.0 #10604
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you so much for working on this! Just some minor comments for you to address.
Hi, Looking through this, I only had one question from your initial PR description:
Is this the reason for all the changes from |
@powersj Here For every node it currently returns the same host:port given in the config, ideally it should return the host:port of the node for which we are sending the metrics for. Shouldn't it send the host:port of the node it is fetching the metrics from? |
Yes, that change is correct. However, are you also changing the format of the node + port to node name? |
@powersj as per the README as well |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
My hesitation has been that this is changing a tag value. However, it is changing it to the correct value, so I'll approve this. Thanks
func (a *Aerospike) getNodeInfo(n *as.Node) (map[string]string, error) { | ||
stats, err := as.RequestNodeStats(n) | ||
func (a *Aerospike) getNodeInfo(n *as.Node, infoPolicy *as.InfoPolicy) (map[string]string, error) { | ||
stats, err := n.RequestInfo(infoPolicy) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hi, I know it's a little late, but I think this has introduced a bug. Shouldn't this be added to this method call?
stats, err := n.RequestInfo(infoPolicy) | |
stats, err := n.RequestInfo(infoPolicy, "statistics") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@Hipska Thanks, Let me quickly test it out and create a PR
@@ -465,6 +466,8 @@ func parseAerospikeValue(key string, v string) interface{} { | |||
return parsed | |||
} else if parsed, err := strconv.ParseBool(v); err == nil { | |||
return parsed | |||
} else if parsed, err := strconv.ParseFloat(v, 32); err == nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why are we doing 32-bit?
Required for all PRs:
resolves #10315
The changes are listed below:
enable_ssl
option would no longer be available.tls_name
, which should be set to the value oftls-name
undertls{}
stanza in the aerospike.conf if present.node_name
tag to return Node.GetName() which now correctly returns node name, instead of the host:port which was incorrect.