[Feat] [history server] Add actor task endpoint

historyserver/Dockerfile.collector

@@ -16,13 +16,14 @@ COPY cmd/collector/main.go cmd/collector/main.go
 COPY pkg/collector/ pkg/collector/
 COPY pkg/storage/ pkg/storage/
 COPY pkg/utils/ pkg/utils/
+COPY pkg/eventserver/ pkg/eventserver/
 
 # Build the collector binary.
 COPY Makefile Makefile
 RUN if [ "$ENABLE_RACE" = "true" ]; then \
-        make buildcollector-race GOOS=linux GOARCH=amd64; \
+    make buildcollector-race GOOS=linux GOARCH=amd64; \
     else \
-        make buildcollector GOOS=linux GOARCH=amd64; \
+    make buildcollector GOOS=linux GOARCH=amd64; \
     fi
 
 FROM ubuntu:22.04

historyserver/cmd/historyserver/main.go

@@ -21,14 +21,20 @@ func main() {
 	kubeconfigs := ""
 	runtimeClassConfigPath := "/var/collector-config/data"
 	dashboardDir := ""
+	useKubernetesProxy := false
 	flag.StringVar(&runtimeClassName, "runtime-class-name", "", "")
 	flag.StringVar(&rayRootDir, "ray-root-dir", "", "")
 	flag.StringVar(&kubeconfigs, "kubeconfigs", "", "")
 	flag.StringVar(&dashboardDir, "dashboard-dir", "/dashboard", "")
 	flag.StringVar(&runtimeClassConfigPath, "runtime-class-config-path", "", "") //"/var/collector-config/data"
+	flag.BoolVar(&useKubernetesProxy, "use-kubernetes-proxy", false, "")
 	flag.Parse()
 
-	cliMgr := historyserver.NewClientManager(kubeconfigs)
+	cliMgr, err := historyserver.NewClientManager(kubeconfigs, useKubernetesProxy)
+	if err != nil {
+		logrus.Errorf("Failed to create client manager: %v", err)
+		os.Exit(1)
+	}
 
 	jsonData := make(map[string]interface{})
 	if runtimeClassConfigPath != "" {
@@ -78,7 +84,11 @@ func main() {
 		logrus.Info("EventHandler shutdown complete")
 	}()
 
-	handler := historyserver.NewServerHandler(&globalConfig, dashboardDir, reader, cliMgr, eventHandler)
+	handler, err := historyserver.NewServerHandler(&globalConfig, dashboardDir, reader, cliMgr, eventHandler, useKubernetesProxy)
+	if err != nil {
+		logrus.Errorf("Failed to create server handler: %v", err)
+		os.Exit(1)
+	}
 
 	wg.Add(1)
 	go func() {