Skip to content

Commit

Permalink
Add minn connection per node property (#159)
Browse files Browse the repository at this point in the history
Co-authored-by: abandura <[email protected]>
  • Loading branch information
mrozk and abandura authored Nov 9, 2022
1 parent 20d2fec commit b9db0e5
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,7 @@ public ClientPolicy aerospikeClientPolicy(AerospikeProperties properties,
whenPresent(properties.getAuthMode(), p -> clientPolicy.authMode = p);
whenPresent(properties.getConnectTimeout(), p -> clientPolicy.timeout = (int) p.toMillis());
whenPresent(properties.getLoginTimeout(), p -> clientPolicy.loginTimeout = (int) p.toMillis());
whenPresent(properties.getMinConnsPerNode(), p -> clientPolicy.minConnsPerNode = p);
whenPresent(properties.getMaxConnsPerNode(), p -> clientPolicy.maxConnsPerNode = p);
whenPresent(properties.getConnPoolsPerNode(), p -> clientPolicy.connPoolsPerNode = p);
whenPresent(properties.getMaxSocketIdle(), p -> clientPolicy.maxSocketIdle = (int) p.getSeconds());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,11 @@ public class AerospikeProperties {
*/
private Duration loginTimeout;

/**
* Minimum number of synchronous connections allowed per server node
*/
private Integer minConnsPerNode;

/**
* Maximum number of connections allowed per server node.
*/
Expand Down

0 comments on commit b9db0e5

Please sign in to comment.