This is an automated email from the ASF dual-hosted git repository.
mattisonchao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new cad3c464be0 [cleanup][broker] Delete methods marked Lombok @Getter
(#21462)
cad3c464be0 is described below
commit cad3c464be04f074911d05fde0685ae696feeae9
Author: Qiang Zhao <mattisonc...@apache.org>
AuthorDate: Mon Oct 30 20:23:40 2023 +0800
[cleanup][broker] Delete methods marked Lombok @Getter (#21462)
---
.../org/apache/pulsar/broker/PulsarService.java | 68 ----------------------
1 file changed, 68 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index 9a202c28c2a..84e044df0bf 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -1301,12 +1301,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
this.getWorkerConfig().map(WorkerConfig::getStateStorageServiceUrl).orElse(null));
}
- /**
- * Get the current pulsar state.
- */
- public State getState() {
- return this.state;
- }
/**
* check the current pulsar service is running, including Started and Init
state.
@@ -1348,16 +1342,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
+ "is not enabled, probably functionsWorkerEnabled is set to
false"));
}
- /**
- * Get a reference of the current <code>BrokerService</code> instance
associated with the current
- * <code>PulsarService</code> instance.
- *
- * @return a reference of the current <code>BrokerService</code> instance.
- */
- public BrokerService getBrokerService() {
- return this.brokerService;
- }
-
public BookKeeper getBookKeeperClient() {
return getManagedLedgerClientFactory().getBookKeeperClient();
}
@@ -1366,10 +1350,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
return getManagedLedgerClientFactory().getManagedLedgerFactory();
}
- public ManagedLedgerStorage getManagedLedgerClientFactory() {
- return managedLedgerClientFactory;
- }
-
/**
* First, get <code>LedgerOffloader</code> from local map cache,
* create new <code>LedgerOffloader</code> if not in cache or
@@ -1448,22 +1428,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
return schemaStorage;
}
- public ScheduledExecutorService getExecutor() {
- return executor;
- }
-
- public ExecutorProvider getTransactionExecutorProvider() {
- return transactionExecutorProvider;
- }
-
- public ScheduledExecutorService getLoadManagerExecutor() {
- return loadManagerExecutor;
- }
-
- public OrderedExecutor getOrderedExecutor() {
- return orderedExecutor;
- }
-
public BookKeeperClientFactory newBookKeeperClientFactory() {
return new BookKeeperClientFactoryImpl();
}
@@ -1645,22 +1609,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
return this.adminClient;
}
- public MetricsGenerator getMetricsGenerator() {
- return metricsGenerator;
- }
-
- public TransactionMetadataStoreService
getTransactionMetadataStoreService() {
- return transactionMetadataStoreService;
- }
-
- public TransactionBufferProvider getTransactionBufferProvider() {
- return transactionBufferProvider;
- }
-
- public TransactionBufferClient getTransactionBufferClient() {
- return transactionBufferClient;
- }
-
/**
* Gets the broker service URL (non-TLS) associated with the internal
listener.
*/
@@ -1734,14 +1682,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
: config.getWebServicePort().orElseThrow());
}
- public TopicPoliciesService getTopicPoliciesService() {
- return topicPoliciesService;
- }
-
- public ResourceUsageTransportManager getResourceUsageTransportManager() {
- return resourceUsageTransportManager;
- }
-
public synchronized void
addPrometheusRawMetricsProvider(PrometheusRawMetricsProvider metricsProvider) {
if (metricsServlet == null) {
if (pendingMetricsProviders == null) {
@@ -1827,14 +1767,6 @@ public class PulsarService implements AutoCloseable,
ShutdownService {
return brokerService.getListenPortTls();
}
- public MetadataStoreExtended getLocalMetadataStore() {
- return localMetadataStore;
- }
-
- public CoordinationService getCoordinationService() {
- return coordinationService;
- }
-
public static WorkerConfig
initializeWorkerConfigFromBrokerConfig(ServiceConfiguration brokerConfig,
String
workerConfigFile) throws IOException {
WorkerConfig workerConfig = WorkerConfig.load(workerConfigFile);
