package org.ehcache.management.registry;
import org.ehcache.management.ManagementRegistryService;
import org.ehcache.management.ManagementRegistryServiceConfiguration;
import org.ehcache.management.providers.statistics.LatencyHistogramConfiguration;
import org.terracotta.management.model.context.Context;
import java.util.Arrays;
import java.util.Collection;
import java.util.Objects;
import java.util.TreeSet;
import java.util.UUID;
import java.util.concurrent.atomic.AtomicLong;
public class DefaultManagementRegistryConfiguration implements ManagementRegistryServiceConfiguration {
private static final AtomicLong COUNTER = new AtomicLong();
private final Collection<String> tags = new TreeSet<>();
private final String instanceId = UUID.randomUUID().toString();
private Context context = Context.empty();
private String collectorExecutorAlias = "collectorExecutor";
private LatencyHistogramConfiguration latencyHistogramConfiguration = LatencyHistogramConfiguration.DEFAULT;
public DefaultManagementRegistryConfiguration() {
setCacheManagerAlias("cache-manager-" + COUNTER.getAndIncrement());
}
public DefaultManagementRegistryConfiguration setCacheManagerAlias(String alias) {
return setContext(Context.create("cacheManagerName", alias));
}
public DefaultManagementRegistryConfiguration setContext(Context context) {
if (!this.context.contains("cacheManagerName") && !context.contains("cacheManagerName")) {
throw new IllegalArgumentException("'cacheManagerName' is missing from context");
}
this.context = this.context.with(context);
return this;
}
public DefaultManagementRegistryConfiguration setCollectorExecutorAlias(String collectorExecutorAlias) {
this.collectorExecutorAlias = collectorExecutorAlias;
return this;
}
public DefaultManagementRegistryConfiguration addTags(String... tags) {
this.tags.addAll(Arrays.asList(tags));
return this;
}
public DefaultManagementRegistryConfiguration addTag(String tag) {
return addTags(tag);
}
@Override
public Context getContext() {
return context;
}
public String getCacheManagerAlias() {
return getContext().get("cacheManagerName");
}
@Override
public String getCollectorExecutorAlias() {
return this.collectorExecutorAlias;
}
@Override
public Collection<String> getTags() {
return tags;
}
@Override
public String getInstanceId() {
return instanceId;
}
@Override
public LatencyHistogramConfiguration getLatencyHistogramConfiguration() {
return latencyHistogramConfiguration;
}
public DefaultManagementRegistryConfiguration setLatencyHistogramConfiguration(LatencyHistogramConfiguration latencyHistogramConfiguration) {
this.latencyHistogramConfiguration = Objects.requireNonNull(latencyHistogramConfiguration);
return this;
}
@Override
public Class<ManagementRegistryService> getServiceType() {
return ManagementRegistryService.class;
}
@Override
public String toString() {
return "DefaultManagementRegistryConfiguration{" + "context=" + context +
", tags=" + tags +
", collectorExecutorAlias='" + collectorExecutorAlias + '\'' +
", instanceId='" + instanceId + '\'' +
", latencyHistogramConfiguration='" + latencyHistogramConfiguration + '\'' +
'}';
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
DefaultManagementRegistryConfiguration that = (DefaultManagementRegistryConfiguration) o;
return Objects.equals(tags, that.tags) &&
Objects.equals(instanceId, that.instanceId) &&
Objects.equals(context, that.context) &&
Objects.equals(collectorExecutorAlias, that.collectorExecutorAlias) &&
Objects.equals(latencyHistogramConfiguration, that.latencyHistogramConfiguration);
}
@Override
public int hashCode() {
return Objects.hash(tags, instanceId, context, collectorExecutorAlias);
}
}