This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 93630a64a1f Remove useless ProcessListClusterPersistRepositoryFixture
(#34977)
93630a64a1f is described below
commit 93630a64a1f6aca27c20e33efd5f5728fe1c57b7
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Thu Mar 13 23:24:34 2025 +0800
Remove useless ProcessListClusterPersistRepositoryFixture (#34977)
---
...ProcessListClusterPersistRepositoryFixture.java | 102 ---------------------
...ode.repository.cluster.ClusterPersistRepository | 1 -
2 files changed, 103 deletions(-)
diff --git
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/fixture/ProcessListClusterPersistRepositoryFixture.java
b/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/fixture/ProcessListClusterPersistRepositoryFixture.java
deleted file mode 100644
index 1d5c79f6a84..00000000000
---
a/mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/fixture/ProcessListClusterPersistRepositoryFixture.java
+++ /dev/null
@@ -1,102 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.mode.manager.cluster.fixture;
-
-import org.apache.shardingsphere.infra.instance.ComputeNodeInstanceContext;
-import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
-import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration;
-import
org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener;
-import
org.apache.shardingsphere.mode.repository.cluster.lock.holder.DistributedLockHolder;
-import
org.apache.shardingsphere.mode.repository.cluster.lock.impl.props.DefaultLockTypedProperties;
-
-import java.util.Collections;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-
-public final class ProcessListClusterPersistRepositoryFixture implements
ClusterPersistRepository {
-
- private static final Map<String, String> REGISTRY_DATA = new
LinkedHashMap<>();
-
- @Override
- public void init(final ClusterPersistRepositoryConfiguration config, final
ComputeNodeInstanceContext computeNodeInstanceContext) {
- }
-
- @Override
- public String query(final String key) {
- return REGISTRY_DATA.get(key);
- }
-
- @Override
- public List<String> getChildrenKeys(final String key) {
- return Collections.singletonList("db");
- }
-
- @Override
- public boolean isExisted(final String key) {
- return false;
- }
-
- @Override
- public void persist(final String key, final String value) {
- REGISTRY_DATA.put(key, value);
- }
-
- @Override
- public void update(final String key, final String value) {
- }
-
- @Override
- public void persistEphemeral(final String key, final String value) {
- REGISTRY_DATA.put(key, value);
- }
-
- @Override
- public boolean persistExclusiveEphemeral(final String key, final String
value) {
- return true;
- }
-
- @Override
- public DistributedLockHolder getDistributedLockHolder() {
- return new DistributedLockHolder("default", this, new
DefaultLockTypedProperties(new Properties()));
- }
-
- @Override
- public void delete(final String key) {
- REGISTRY_DATA.remove(key);
- }
-
- @Override
- public void watch(final String key, final DataChangedEventListener
listener) {
- }
-
- @Override
- public void removeDataListener(final String key) {
- }
-
- @Override
- public void close() {
- REGISTRY_DATA.clear();
- }
-
- @Override
- public String getType() {
- return "PROCESS_FIXTURE";
- }
-}
diff --git
a/mode/type/cluster/core/src/test/resources/META-INF/services/org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository
b/mode/type/cluster/core/src/test/resources/META-INF/services/org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository
index 47f7944926f..ff885a79247 100644
---
a/mode/type/cluster/core/src/test/resources/META-INF/services/org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository
+++
b/mode/type/cluster/core/src/test/resources/META-INF/services/org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository
@@ -16,4 +16,3 @@
#
org.apache.shardingsphere.mode.manager.cluster.fixture.ClusterPersistRepositoryFixture
-org.apache.shardingsphere.mode.manager.cluster.fixture.ProcessListClusterPersistRepositoryFixture
