Skip to content

Commit

Permalink
fixes for ci
Browse files Browse the repository at this point in the history
  • Loading branch information
ayusheshan committed Oct 13, 2023
1 parent 85605f9 commit 1ef145a
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,26 +15,26 @@
* limitations under the License.
*/

package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.watcher;
package org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.subscriber;

import org.apache.shardingsphere.infra.state.cluster.ClusterState;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.subscriber.ClusterStatusSubscriber;
import org.junit.jupiter.api.extension.ExtendWith;
import org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.cluster.event.ClusterStatusChangedEvent;
import org.apache.shardingsphere.infra.state.cluster.ClusterState;
import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import org.apache.shardingsphere.metadata.persist.node.ComputeNode;
import org.mockito.junit.jupiter.MockitoExtension;

import static org.mockito.Mockito.verify;

@ExtendWith(MockitoExtension.class)
class ClusterStatusSubscriberTest {

@Mock
private ClusterPersistRepository repository;

@Test
void updateTest() {
ClusterStatusSubscriber clusterStatusSubscriber = new ClusterStatusSubscriber(repository, new EventBusContext());
Expand Down

0 comments on commit 1ef145a

Please sign in to comment.