Skip to content

Commit

Permalink
Polish #3741 (#3746)
Browse files Browse the repository at this point in the history
Add HSCAN NOVALUES in pipelines and transactions
  • Loading branch information
sazzad16 authored Feb 28, 2024
1 parent f64dbb4 commit ab6f058
Show file tree
Hide file tree
Showing 5 changed files with 26 additions and 4 deletions.
10 changes: 10 additions & 0 deletions src/main/java/redis/clients/jedis/PipeliningBase.java
Original file line number Diff line number Diff line change
Expand Up @@ -706,6 +706,11 @@ public Response<ScanResult<Map.Entry<String, String>>> hscan(String key, String
return appendCommand(commandObjects.hscan(key, cursor, params));
}

@Override
public Response<ScanResult<String>> hscanNoValues(String key, String cursor, ScanParams params) {
return appendCommand(commandObjects.hscanNoValues(key, cursor, params));
}

@Override
public Response<Long> hstrlen(String key, String field) {
return appendCommand(commandObjects.hstrlen(key, field));
Expand Down Expand Up @@ -1972,6 +1977,11 @@ public Response<ScanResult<Map.Entry<byte[], byte[]>>> hscan(byte[] key, byte[]
return appendCommand(commandObjects.hscan(key, cursor, params));
}

@Override
public Response<ScanResult<byte[]>> hscanNoValues(byte[] key, byte[] cursor, ScanParams params) {
return appendCommand(commandObjects.hscanNoValues(key, cursor, params));
}

@Override
public Response<Long> hstrlen(byte[] key, byte[] field) {
return appendCommand(commandObjects.hstrlen(key, field));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,12 +47,12 @@ default ScanResult<Map.Entry<byte[], byte[]>> hscan(byte[] key, byte[] cursor) {
return hscan(key, cursor, new ScanParams());
}

ScanResult<Map.Entry<byte[], byte[]>> hscan(byte[] key, byte[] cursor, ScanParams params);

default ScanResult<byte[]> hscanNoValues(byte[] key, byte[] cursor) {
return hscanNoValues(key, cursor, new ScanParams());
}

ScanResult<Map.Entry<byte[], byte[]>> hscan(byte[] key, byte[] cursor, ScanParams params);

ScanResult<byte[]> hscanNoValues(byte[] key, byte[] cursor, ScanParams params);

long hstrlen(byte[] key, byte[] field);
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/redis/clients/jedis/commands/HashCommands.java
Original file line number Diff line number Diff line change
Expand Up @@ -47,12 +47,12 @@ default ScanResult<Map.Entry<String, String>> hscan(String key, String cursor) {
return hscan(key, cursor, new ScanParams());
}

ScanResult<Map.Entry<String, String>> hscan(String key, String cursor, ScanParams params);

default ScanResult<String> hscanNoValues(String key, String cursor) {
return hscanNoValues(key, cursor, new ScanParams());
}

ScanResult<Map.Entry<String, String>> hscan(String key, String cursor, ScanParams params);

ScanResult<String> hscanNoValues(String key, String cursor, ScanParams params);

long hstrlen(String key, String field);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,12 @@ default Response<ScanResult<Map.Entry<byte[], byte[]>>> hscan(byte[] key, byte[]

Response<ScanResult<Map.Entry<byte[], byte[]>>> hscan(byte[] key, byte[] cursor, ScanParams params);

default Response<ScanResult<byte[]>> hscanNoValues(byte[] key, byte[] cursor) {
return hscanNoValues(key, cursor, new ScanParams());
}

Response<ScanResult<byte[]>> hscanNoValues(byte[] key, byte[] cursor, ScanParams params);

Response<Long> hstrlen(byte[] key, byte[] field);

}
Original file line number Diff line number Diff line change
Expand Up @@ -50,5 +50,11 @@ default Response<ScanResult<Map.Entry<String, String>>> hscan(String key, String

Response<ScanResult<Map.Entry<String, String>>> hscan(String key, String cursor, ScanParams params);

default Response<ScanResult<String>> hscanNoValues(String key, String cursor) {
return hscanNoValues(key, cursor, new ScanParams());
}

Response<ScanResult<String>> hscanNoValues(String key, String cursor, ScanParams params);

Response<Long> hstrlen(String key, String field);
}

0 comments on commit ab6f058

Please sign in to comment.