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
ISPN-14907 Implement RESP "cluster shards" command #10930
Conversation
Let me cover this a bit more with tests for single nodes, too |
@jabolina open a new jira if you have two parts |
I'll put an on-hold on this momentarily while I work on some fixes first. |
Please add rows to the table in |
e2c76ef
to
2ff098d
Compare
@karesti Created a JIRA and updated this PR. |
2ff098d
to
0f671ea
Compare
bfa3068
to
e8d16ba
Compare
server/resp/src/main/java/org/infinispan/server/resp/RespCommand.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/RespCommand.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/RespCommand.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/connection/COMMAND.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
a86a01d
to
50b40a0
Compare
byte[] possibleBytes = bytes; | ||
if (length == possibleBytes.length) { | ||
boolean matches = true; | ||
for (int i = 0; i < possibleBytes.length; ++i) { |
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.
Technically this is adding an additional case insensitive char comparison, but I guess that is okay.
8534dae
to
927678f
Compare
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.
Changes look good, just a couple more things.
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/CLUSTER.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
927678f
to
36f28e9
Compare
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.
Another thought is we could retry or wait for a topology update to complete. But this is probably too complex for this with little benefit.
I am mainly just concerned about using a null owner and ignoring some backups when they aren't named... I think having something is better than just not including them.
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Show resolved
Hide resolved
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Outdated
Show resolved
Hide resolved
c07032f
to
475062d
Compare
Yeah, we could create all the required fields using the address.toString() as a placeholder for name and address. And we can say the node's health, so I put it to use |
server/resp/src/main/java/org/infinispan/server/resp/commands/cluster/SHARDS.java
Show resolved
Hide resolved
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.
LGTM, but there are CI failures.
475062d
to
8b847ef
Compare
Fixed the test. |
Integrated into main, thanks @jabolina ! |
https://issues.redhat.com/browse/ISPN-14229
CLUSTER SHARDS
command.This is part 1, do not close the JIRA yet.