[Refactor] New EPD

.github/CODEOWNERS

@@ -16,8 +16,7 @@
 /python/sglang/srt/constrained @hnyls2002 @DarkSharpness @JustinTong0323
 /python/sglang/srt/disaggregation @ByronHsu @hnyls2002 @ShangmingCai @HaiShaw @Duyi-Wang @sogalin
 /python/sglang/srt/disaggregation/ascend @ping1jing2 @iforgetmyname
-/python/sglang/srt/disaggregation/encode_receiver.py @ShangmingCai @liusy58 @ZhengWG @gty111
-/python/sglang/srt/disaggregation/encode_server.py @ShangmingCai @liusy58 @ZhengWG @gty111
+/python/sglang/srt/disaggregation/encoder @ShangmingCai @liusy58 @ZhengWG @gty111
 /python/sglang/srt/disaggregation/mori @Duyi-Wang @kkHuang-amd @HaiShaw @Lzy17 @billishyahao
 /python/sglang/srt/distributed @yizhang2077 @merrymercy @ch-wan
 /python/sglang/srt/distributed/device_communicators/mooncake_transfer_engine.py @ShangmingCai @stmatengss

python/sglang/launch_server.py

@@ -18,13 +18,13 @@ def run_server(server_args):
     if server_args.encoder_only:
         # For encoder disaggregation
         if server_args.smg_grpc_mode or server_args.grpc_mode:
-            from sglang.srt.disaggregation.encode_grpc_server import (
+            from sglang.srt.disaggregation.encoder.grpc_server import (
                 serve_grpc_encoder,
             )
 
             asyncio.run(serve_grpc_encoder(server_args))
         else:
-            from sglang.srt.disaggregation.encode_server import launch_server
+            from sglang.srt.disaggregation.encoder.http_server import launch_server
 
             launch_server(server_args)
     elif server_args.smg_grpc_mode: