Skip to content

Commit e03789c

Browse files
JoeCquptJoeCqupt
authored
refactor: reorganize project files (#18)
1 parent 6ed3cc7 commit e03789c

File tree

59 files changed

+167
-113
lines changed

Some content is hidden

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

59 files changed

+167
-113
lines changed

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/bootstrap/ConsumerBootstrap.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/bootstrap/ConsumerBootstrap.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -14,25 +14,25 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.bootstrap;
17+
package io.github.xinfra.lab.rpc.core.bootstrap;
1818

1919
import io.github.xinfra.lab.rpc.cluster.Cluster;
20-
import io.github.xinfra.lab.rpc.cluster.ClusterFactory;
2120
import io.github.xinfra.lab.rpc.cluster.ClusterInvoker;
2221
import io.github.xinfra.lab.rpc.config.ConsumerConfig;
2322
import io.github.xinfra.lab.rpc.config.ReferenceConfig;
2423
import io.github.xinfra.lab.rpc.config.RegistryConfig;
25-
import io.github.xinfra.lab.rpc.filter.FilterChainBuilder;
26-
import io.github.xinfra.lab.rpc.invoker.ConsumerInvoker;
27-
import io.github.xinfra.lab.rpc.invoker.DirectConnectInvoker;
24+
import io.github.xinfra.lab.rpc.core.cluster.ClusterFactory;
25+
import io.github.xinfra.lab.rpc.core.filter.FilterChainBuilder;
26+
import io.github.xinfra.lab.rpc.core.invoker.ConsumerInvoker;
27+
import io.github.xinfra.lab.rpc.core.invoker.DirectConnectInvoker;
28+
import io.github.xinfra.lab.rpc.core.proxy.ProxyManager;
29+
import io.github.xinfra.lab.rpc.core.registry.DefaultAppServiceInstancesWatcher;
30+
import io.github.xinfra.lab.rpc.core.registry.RegistryManager;
31+
import io.github.xinfra.lab.rpc.core.transport.ClientTransportManager;
2832
import io.github.xinfra.lab.rpc.invoker.Invoker;
2933
import io.github.xinfra.lab.rpc.proxy.Proxy;
30-
import io.github.xinfra.lab.rpc.proxy.ProxyManager;
31-
import io.github.xinfra.lab.rpc.registry.DefaultAppServiceInstancesWatcher;
3234
import io.github.xinfra.lab.rpc.registry.Registry;
33-
import io.github.xinfra.lab.rpc.registry.RegistryManager;
3435
import io.github.xinfra.lab.rpc.transport.ClientTransport;
35-
import io.github.xinfra.lab.rpc.transport.ClientTransportManager;
3636
import java.io.Closeable;
3737
import java.io.IOException;
3838

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/bootstrap/ProviderBoostrap.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/bootstrap/ProviderBoostrap.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,22 +14,22 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.bootstrap;
17+
package io.github.xinfra.lab.rpc.core.bootstrap;
1818

1919
import com.google.common.collect.Lists;
2020
import io.github.xinfra.lab.rpc.config.ExporterConfig;
2121
import io.github.xinfra.lab.rpc.config.ProviderConfig;
2222
import io.github.xinfra.lab.rpc.config.RegistryConfig;
23-
import io.github.xinfra.lab.rpc.filter.FilterChainBuilder;
23+
import io.github.xinfra.lab.rpc.core.filter.FilterChainBuilder;
24+
import io.github.xinfra.lab.rpc.core.invoker.ProviderInvoker;
25+
import io.github.xinfra.lab.rpc.core.metadata.MetadataServiceImpl;
26+
import io.github.xinfra.lab.rpc.core.registry.RegistryManager;
27+
import io.github.xinfra.lab.rpc.core.transport.ServerTransportManager;
2428
import io.github.xinfra.lab.rpc.invoker.Invoker;
25-
import io.github.xinfra.lab.rpc.invoker.ProviderInvoker;
2629
import io.github.xinfra.lab.rpc.metadata.MetadataService;
27-
import io.github.xinfra.lab.rpc.metadata.MetadataServiceImpl;
2830
import io.github.xinfra.lab.rpc.registry.Registry;
29-
import io.github.xinfra.lab.rpc.registry.RegistryManager;
3031
import io.github.xinfra.lab.rpc.registry.ServiceInstance;
3132
import io.github.xinfra.lab.rpc.transport.ServerTransport;
32-
import io.github.xinfra.lab.rpc.transport.ServerTransportManager;
3333
import java.io.Closeable;
3434
import java.io.IOException;
3535
import java.util.ArrayList;

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/AbstractCluster.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/AbstractCluster.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,12 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster;
17+
package io.github.xinfra.lab.rpc.core.cluster;
1818

19-
import io.github.xinfra.lab.rpc.cluster.naming.DefaultNameService;
19+
import io.github.xinfra.lab.rpc.cluster.Cluster;
2020
import io.github.xinfra.lab.rpc.cluster.naming.NameService;
2121
import io.github.xinfra.lab.rpc.config.ReferenceConfig;
22+
import io.github.xinfra.lab.rpc.core.cluster.naming.DefaultNameService;
2223
import io.github.xinfra.lab.rpc.transport.ClientTransport;
2324

2425
public abstract class AbstractCluster implements Cluster {

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/AbstractClusterInvoker.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/AbstractClusterInvoker.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,16 +14,18 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster;
17+
package io.github.xinfra.lab.rpc.core.cluster;
1818

19+
import io.github.xinfra.lab.rpc.cluster.Cluster;
20+
import io.github.xinfra.lab.rpc.cluster.ClusterInvoker;
1921
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalancer;
20-
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalancerManger;
2122
import io.github.xinfra.lab.rpc.cluster.naming.NameService;
2223
import io.github.xinfra.lab.rpc.cluster.router.RouterChain;
2324
import io.github.xinfra.lab.rpc.config.ReferenceConfig;
2425
import io.github.xinfra.lab.rpc.config.ServiceConfig;
25-
import io.github.xinfra.lab.rpc.filter.FilterChainBuilder;
26-
import io.github.xinfra.lab.rpc.invoker.ConsumerInvoker;
26+
import io.github.xinfra.lab.rpc.core.cluster.loadblancer.LoadBalancerManger;
27+
import io.github.xinfra.lab.rpc.core.filter.FilterChainBuilder;
28+
import io.github.xinfra.lab.rpc.core.invoker.ConsumerInvoker;
2729
import io.github.xinfra.lab.rpc.invoker.Invocation;
2830
import io.github.xinfra.lab.rpc.invoker.InvocationResult;
2931
import io.github.xinfra.lab.rpc.invoker.Invoker;

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/ClusterFactory.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/ClusterFactory.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,9 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster;
17+
package io.github.xinfra.lab.rpc.core.cluster;
1818

19+
import io.github.xinfra.lab.rpc.cluster.Cluster;
1920
import io.github.xinfra.lab.rpc.config.ReferenceConfig;
2021
import io.github.xinfra.lab.rpc.transport.ClientTransport;
2122

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/FailFastClusterInvoker.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/FailFastClusterInvoker.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,9 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster;
17+
package io.github.xinfra.lab.rpc.core.cluster;
1818

19+
import io.github.xinfra.lab.rpc.cluster.Cluster;
1920
import io.github.xinfra.lab.rpc.invoker.Invocation;
2021
import io.github.xinfra.lab.rpc.invoker.InvocationResult;
2122
import io.github.xinfra.lab.rpc.registry.ServiceInstance;

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/FastFailCluster.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/FastFailCluster.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,11 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster;
17+
package io.github.xinfra.lab.rpc.core.cluster;
1818

19+
import io.github.xinfra.lab.rpc.cluster.ClusterInvoker;
1920
import io.github.xinfra.lab.rpc.config.ReferenceConfig;
20-
import io.github.xinfra.lab.rpc.filter.FilterChainBuilder;
21+
import io.github.xinfra.lab.rpc.core.filter.FilterChainBuilder;
2122
import io.github.xinfra.lab.rpc.transport.ClientTransport;
2223

2324
public class FastFailCluster extends AbstractCluster {

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/loadblancer/LoadBalancerFactory.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/loadblancer/LoadBalancerFactory.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,10 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster.loadblancer;
17+
package io.github.xinfra.lab.rpc.core.cluster.loadblancer;
18+
19+
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalanceType;
20+
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalancer;
1821

1922
public class LoadBalancerFactory {
2023

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/loadblancer/LoadBalancerManger.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/loadblancer/LoadBalancerManger.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,10 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster.loadblancer;
17+
package io.github.xinfra.lab.rpc.core.cluster.loadblancer;
1818

19+
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalanceType;
20+
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalancer;
1921
import java.util.HashMap;
2022
import java.util.Map;
2123

x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/cluster/loadblancer/RandomLoadBalancer.java renamed to x-rpc-core/src/main/java/io/github/xinfra/lab/rpc/core/cluster/loadblancer/RandomLoadBalancer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,9 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.github.xinfra.lab.rpc.cluster.loadblancer;
17+
package io.github.xinfra.lab.rpc.core.cluster.loadblancer;
1818

19+
import io.github.xinfra.lab.rpc.cluster.loadblancer.LoadBalancer;
1920
import io.github.xinfra.lab.rpc.invoker.Invocation;
2021
import io.github.xinfra.lab.rpc.registry.ServiceInstance;
2122
import java.util.List;

0 commit comments

Comments
 (0)