bug5627: fixed parameter name

This commit is contained in:
Axel Uhl
2023-01-05 10:58:26 +01:00
parent 198833f13e
commit c9fd774c80
4 changed files with 12 additions and 11 deletions
@@ -134,13 +134,14 @@ extends ApplicationReplicaSet<ShardingKey, MetricsT, ProcessT> {
/**
* Returns a {@link ShardTargetGroupName} that is created from an (user-) entered shard name ({@code shardName}).
* {@link ShardTargetGroupName} contains the target group name and the replica set name.
*
* @param shardName
* (User-) entered name for the shard.
* @param targetGroupNamePrefix TODO
* @return
* ShardName created from {@code shardName}.
* (User-) entered name for the shard.
* @param targetGroupNamePrefix
* a prefix for the target group name; must not be {@code null} but may be empty
* @return {@link ShardTargetGroupName} created from {@code shardName}.
* @throws Exception
* throws when {@code shardName} is not valid or is not parse-able to a shardName.
* throws when {@code shardName} is not valid or is not parse-able to a shardName.
*/
ShardTargetGroupName getNewShardName(String shardName, String targetGroupNamePrefix) throws Exception;
@@ -41,11 +41,11 @@ public interface AwsInstance<ShardingKey> extends Host {
boolean isManagedByAutoScalingGroup();
/**
* Finds out whether this instance is managed by the particular {@code autoScalingGroup} passed as parameter. The
* Finds out whether this instance is managed by any of the {@code autoScalingGroups} passed as parameter. The
* implementation checks the {@link #AWS_AUTOSCALING_GROUP_NAME_TAG} tag's value and compares it to the
* {@code autoScalingGroup}'s name.
*/
boolean isManagedByAutoScalingGroup(Iterable<AwsAutoScalingGroup> autoScalingGroup);
boolean isManagedByAutoScalingGroup(Iterable<AwsAutoScalingGroup> autoScalingGroups);
default String getId() {
return getInstanceId();
@@ -275,10 +275,10 @@ public class AwsInstanceImpl<ShardingKey> implements AwsInstance<ShardingKey> {
}
@Override
public boolean isManagedByAutoScalingGroup(Iterable<AwsAutoScalingGroup> autoScalingGroup) {
return getInstance().tags().stream().filter(tag -> !Util.isEmpty(autoScalingGroup)
public boolean isManagedByAutoScalingGroup(Iterable<AwsAutoScalingGroup> autoScalingGroups) {
return getInstance().tags().stream().filter(tag -> !Util.isEmpty(autoScalingGroups)
&& tag.key().equals(AWS_AUTOSCALING_GROUP_NAME_TAG)
&& Util.stream(autoScalingGroup).filter(t -> t.getName().equals(tag.value())).findAny().isPresent())
&& Util.stream(autoScalingGroups).filter(t -> t.getName().equals(tag.value())).findAny().isPresent())
.findAny().isPresent();
}
@@ -35,7 +35,7 @@ public interface ApplicationProcess<ShardingKey, MetricsT extends ApplicationPro
ProcessT extends ApplicationProcess<ShardingKey, MetricsT, ProcessT>>
extends Process<RotatingFileBasedLog, MetricsT> {
public static String HEALTH_CHECK_PATH = "/gwt/status";
String HEALTH_CHECK_PATH = "/gwt/status";
static Logger logger = Logger.getLogger(ApplicationProcess.class.getName());
static String REPLICATION_STATUS_POST_URL_PATH_AND_QUERY = ReplicationServletActions.REPLICATION_SERVLET_BASE_PATH+"?"+ReplicationServletActions.ACTION_PARAMETER_NAME+"="+