Skip to content

Commit b5f5649

Browse files
committed
Rename ServicesContainer to ServiceContainer
1 parent cb6e6ec commit b5f5649

File tree

68 files changed

+580
-550
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

68 files changed

+580
-550
lines changed

benchmarks/src/jmh/java/software/amazon/jdbc/benchmarks/ConnectionPluginManagerBenchmarks.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@
6868
import software.amazon.jdbc.profile.ConfigurationProfile;
6969
import software.amazon.jdbc.profile.ConfigurationProfileBuilder;
7070
import software.amazon.jdbc.targetdriverdialect.TargetDriverDialect;
71-
import software.amazon.jdbc.util.FullServicesContainer;
71+
import software.amazon.jdbc.util.ServiceContainer;
7272
import software.amazon.jdbc.util.telemetry.DefaultTelemetryFactory;
7373
import software.amazon.jdbc.util.telemetry.GaugeCallable;
7474
import software.amazon.jdbc.util.telemetry.TelemetryContext;
@@ -95,7 +95,7 @@ public class ConnectionPluginManagerBenchmarks {
9595

9696
@Mock ConnectionProvider mockConnectionProvider;
9797
@Mock ConnectionWrapper mockConnectionWrapper;
98-
@Mock FullServicesContainer mockServicesContainer;
98+
@Mock ServiceContainer mockServiceContainer;
9999
@Mock PluginService mockPluginService;
100100
@Mock PluginManagerService mockPluginManagerService;
101101
@Mock TelemetryFactory mockTelemetryFactory;
@@ -140,7 +140,7 @@ public void setUpIteration() throws Exception {
140140
when(mockResultSet.getString(eq(FIELD_SESSION_ID))).thenReturn(WRITER_SESSION_ID);
141141
when(mockResultSet.getString(eq(FIELD_SERVER_ID)))
142142
.thenReturn("myInstance1.domain.com", "myInstance2.domain.com", "myInstance3.domain.com");
143-
when(mockServicesContainer.getPluginService()).thenReturn(mockPluginService);
143+
when(mockServiceContainer.getPluginService()).thenReturn(mockPluginService);
144144
when(mockPluginService.getCurrentConnection()).thenReturn(mockConnection);
145145
when(mockPluginService.getTelemetryFactory()).thenReturn(mockTelemetryFactory);
146146

@@ -166,11 +166,11 @@ public void setUpIteration() throws Exception {
166166
null,
167167
mockConnectionWrapper,
168168
telemetryFactory);
169-
pluginManager.init(mockServicesContainer, propertiesWithPlugins, mockPluginManagerService, configurationProfile);
169+
pluginManager.init(mockServiceContainer, propertiesWithPlugins, mockPluginManagerService, configurationProfile);
170170

171171
pluginManagerWithNoPlugins = new ConnectionPluginManager(mockConnectionProvider, null,
172172
mockConnectionWrapper, telemetryFactory);
173-
pluginManagerWithNoPlugins.init(mockServicesContainer, propertiesWithoutPlugins, mockPluginManagerService, null);
173+
pluginManagerWithNoPlugins.init(mockServiceContainer, propertiesWithoutPlugins, mockPluginManagerService, null);
174174
}
175175

176176
@TearDown(Level.Iteration)
@@ -182,15 +182,15 @@ public void tearDownIteration() throws Exception {
182182
public ConnectionPluginManager initConnectionPluginManagerWithNoPlugins() throws SQLException {
183183
final ConnectionPluginManager manager = new ConnectionPluginManager(mockConnectionProvider, null,
184184
mockConnectionWrapper, mockTelemetryFactory);
185-
manager.init(mockServicesContainer, propertiesWithoutPlugins, mockPluginManagerService, configurationProfile);
185+
manager.init(mockServiceContainer, propertiesWithoutPlugins, mockPluginManagerService, configurationProfile);
186186
return manager;
187187
}
188188

189189
@Benchmark
190190
public ConnectionPluginManager initConnectionPluginManagerWithPlugins() throws SQLException {
191191
final ConnectionPluginManager manager = new ConnectionPluginManager(mockConnectionProvider, null,
192192
mockConnectionWrapper, mockTelemetryFactory);
193-
manager.init(mockServicesContainer, propertiesWithPlugins, mockPluginManagerService, configurationProfile);
193+
manager.init(mockServiceContainer, propertiesWithPlugins, mockPluginManagerService, configurationProfile);
194194
return manager;
195195
}
196196

wrapper/src/main/java/software/amazon/jdbc/ConnectionPluginChainBuilder.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@
5151
import software.amazon.jdbc.plugin.staledns.AuroraStaleDnsPluginFactory;
5252
import software.amazon.jdbc.plugin.strategy.fastestresponse.FastestResponseStrategyPluginFactory;
5353
import software.amazon.jdbc.profile.ConfigurationProfile;
54-
import software.amazon.jdbc.util.FullServicesContainer;
54+
import software.amazon.jdbc.util.ServiceContainer;
5555
import software.amazon.jdbc.util.Messages;
5656
import software.amazon.jdbc.util.SqlState;
5757
import software.amazon.jdbc.util.StringUtils;
@@ -143,7 +143,7 @@ public PluginFactoryInfo(final ConnectionPluginFactory factory, final int weight
143143
}
144144

145145
public List<ConnectionPlugin> getPlugins(
146-
final FullServicesContainer servicesContainer,
146+
final ServiceContainer serviceContainer,
147147
final ConnectionProvider defaultConnProvider,
148148
final ConnectionProvider effectiveConnProvider,
149149
final PluginManagerService pluginManagerService,
@@ -218,11 +218,11 @@ public List<ConnectionPlugin> getPlugins(
218218
// make a chain of connection plugins
219219
plugins = new ArrayList<>(pluginFactories.size() + 1);
220220
for (final ConnectionPluginFactory factory : pluginFactories) {
221-
if (factory instanceof ServicesContainerPluginFactory) {
222-
ServicesContainerPluginFactory servicesContainerPluginFactory = (ServicesContainerPluginFactory) factory;
223-
plugins.add(servicesContainerPluginFactory.getInstance(servicesContainer, props));
221+
if (factory instanceof ServiceContainerPluginFactory) {
222+
ServiceContainerPluginFactory serviceContainerPluginFactory = (ServiceContainerPluginFactory) factory;
223+
plugins.add(serviceContainerPluginFactory.getInstance(serviceContainer, props));
224224
} else {
225-
plugins.add(factory.getInstance(servicesContainer.getPluginService(), props));
225+
plugins.add(factory.getInstance(serviceContainer.getPluginService(), props));
226226
}
227227
}
228228
} else {
@@ -231,7 +231,7 @@ public List<ConnectionPlugin> getPlugins(
231231

232232
// add default connection plugin to the tail
233233
final ConnectionPlugin defaultPlugin = new DefaultConnectionPlugin(
234-
servicesContainer.getPluginService(),
234+
serviceContainer.getPluginService(),
235235
defaultConnProvider,
236236
effectiveConnProvider,
237237
pluginManagerService);

wrapper/src/main/java/software/amazon/jdbc/ConnectionPluginFactory.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@
1717
package software.amazon.jdbc;
1818

1919
import java.util.Properties;
20-
import software.amazon.jdbc.util.FullServicesContainer;
20+
import software.amazon.jdbc.util.ServiceContainer;
2121

2222
/**
2323
* Interface for connection plugin factories. This class implements ways to initialize a connection
2424
* plugin.
2525
*
26-
* <p>Note: consider using {@link ServicesContainerPluginFactory} for new implementations as it provides access to all
27-
* services in the {@link FullServicesContainer}.
26+
* <p>Note: consider using {@link ServiceContainerPluginFactory} for new implementations as it provides access to all
27+
* services in the {@link ServiceContainer}.
2828
*/
2929
public interface ConnectionPluginFactory {
3030

wrapper/src/main/java/software/amazon/jdbc/ConnectionPluginManager.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848
import software.amazon.jdbc.plugin.staledns.AuroraStaleDnsPlugin;
4949
import software.amazon.jdbc.plugin.strategy.fastestresponse.FastestResponseStrategyPlugin;
5050
import software.amazon.jdbc.profile.ConfigurationProfile;
51-
import software.amazon.jdbc.util.FullServicesContainer;
51+
import software.amazon.jdbc.util.ServiceContainer;
5252
import software.amazon.jdbc.util.Messages;
5353
import software.amazon.jdbc.util.Utils;
5454
import software.amazon.jdbc.util.WrapperUtils;
@@ -99,7 +99,7 @@ public class ConnectionPluginManager implements CanReleaseResources, Wrapper {
9999
protected final @NonNull ConnectionProvider defaultConnProvider;
100100
protected final @Nullable ConnectionProvider effectiveConnProvider;
101101
protected final ConnectionWrapper connectionWrapper;
102-
protected FullServicesContainer servicesContainer;
102+
protected ServiceContainer serviceContainer;
103103
protected PluginService pluginService;
104104
protected TelemetryFactory telemetryFactory;
105105
protected boolean isTelemetryInUse;
@@ -169,27 +169,27 @@ public void unlock() {
169169
* <p>The {@link DefaultConnectionPlugin} will always be initialized and attached as the last
170170
* connection plugin in the chain.
171171
*
172-
* @param servicesContainer the service container for the services required by this class.
172+
* @param serviceContainer the service container for the services required by this class.
173173
* @param props the configuration of the connection
174174
* @param pluginManagerService a reference to a plugin manager service
175175
* @param configurationProfile a profile configuration defined by the user
176176
* @throws SQLException if errors occurred during the execution
177177
*/
178178
public void init(
179-
final FullServicesContainer servicesContainer,
179+
final ServiceContainer serviceContainer,
180180
final Properties props,
181181
final PluginManagerService pluginManagerService,
182182
@Nullable ConfigurationProfile configurationProfile) throws SQLException {
183183

184184
this.props = props;
185-
this.servicesContainer = servicesContainer;
186-
this.pluginService = servicesContainer.getPluginService();
187-
this.telemetryFactory = servicesContainer.getTelemetryFactory();
185+
this.serviceContainer = serviceContainer;
186+
this.pluginService = serviceContainer.getPluginService();
187+
this.telemetryFactory = serviceContainer.getTelemetryFactory();
188188
this.isTelemetryInUse = telemetryFactory.inUse();
189189

190190
ConnectionPluginChainBuilder pluginChainBuilder = new ConnectionPluginChainBuilder();
191191
this.plugins = pluginChainBuilder.getPlugins(
192-
this.servicesContainer,
192+
this.serviceContainer,
193193
this.defaultConnProvider,
194194
this.effectiveConnProvider,
195195
pluginManagerService,

wrapper/src/main/java/software/amazon/jdbc/Driver.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -56,10 +56,10 @@
5656
import software.amazon.jdbc.targetdriverdialect.TargetDriverDialect;
5757
import software.amazon.jdbc.targetdriverdialect.TargetDriverDialectManager;
5858
import software.amazon.jdbc.util.ConnectionUrlParser;
59-
import software.amazon.jdbc.util.CoreServicesContainer;
59+
import software.amazon.jdbc.util.CoreServiceContainer;
6060
import software.amazon.jdbc.util.DriverInfo;
61-
import software.amazon.jdbc.util.FullServicesContainer;
62-
import software.amazon.jdbc.util.FullServicesContainerImpl;
61+
import software.amazon.jdbc.util.ServiceContainer;
62+
import software.amazon.jdbc.util.StandardServiceContainer;
6363
import software.amazon.jdbc.util.Messages;
6464
import software.amazon.jdbc.util.PropertyUtils;
6565
import software.amazon.jdbc.util.RdsUtils;
@@ -112,12 +112,12 @@ public class Driver implements java.sql.Driver {
112112
private final MonitorService monitorService;
113113

114114
public Driver() {
115-
this(CoreServicesContainer.getInstance());
115+
this(CoreServiceContainer.getInstance());
116116
}
117117

118-
public Driver(CoreServicesContainer coreServicesContainer) {
119-
this.storageService = coreServicesContainer.getStorageService();
120-
this.monitorService = coreServicesContainer.getMonitorService();
118+
public Driver(CoreServiceContainer coreServiceContainer) {
119+
this.storageService = coreServiceContainer.getStorageService();
120+
this.monitorService = coreServiceContainer.getMonitorService();
121121
}
122122

123123
public static void register() throws SQLException {
@@ -239,12 +239,12 @@ public Connection connect(final String url, final Properties info) throws SQLExc
239239
effectiveConnectionProvider = configurationProfile.getConnectionProvider();
240240
}
241241

242-
FullServicesContainer
243-
servicesContainer = new FullServicesContainerImpl(
242+
ServiceContainer
243+
serviceContainer = new StandardServiceContainer(
244244
storageService, monitorService, defaultConnectionProvider, telemetryFactory);
245245

246246
return new ConnectionWrapper(
247-
servicesContainer,
247+
serviceContainer,
248248
props,
249249
driverUrl,
250250
defaultConnectionProvider,
@@ -419,7 +419,7 @@ public static void resetConnectionInitFunc() {
419419
}
420420

421421
public static void clearCaches() {
422-
CoreServicesContainer.getInstance().getStorageService().clearAll();
422+
CoreServiceContainer.getInstance().getStorageService().clearAll();
423423
RdsUtils.clearCache();
424424
RdsHostListProvider.clearAll();
425425
PluginServiceImpl.clearCache();
@@ -438,7 +438,7 @@ public static void clearCaches() {
438438
}
439439

440440
public static void releaseResources() {
441-
CoreServicesContainer.getInstance().getMonitorService().stopAndRemoveAll();
441+
CoreServiceContainer.getInstance().getMonitorService().stopAndRemoveAll();
442442
HostMonitorThreadContainer.releaseInstance();
443443
ConnectionProviderManager.releaseResources();
444444
HikariPoolsHolder.closeAllPools();

0 commit comments

Comments
 (0)