This is an automated email from the ASF dual-hosted git repository.
zhongxjian pushed a commit to branch release-0.2.0
in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
The following commit(s) were added to refs/heads/release-0.2.0 by this push:
new e0435432 delete comet
e0435432 is described below
commit e04354320d214db3ac9c30a14eea9bf2b67dac8b
Author: mfordjody <[email protected]>
AuthorDate: Mon Jun 2 11:10:16 2025 +0800
delete comet
---
comet/galaxy/comet-agent/app/cmd.go | 85 ---------------------------------
comet/galaxy/comet-agent/main.go | 13 -----
comet/galaxy/comet-discovery/app/cmd.go | 11 -----
comet/galaxy/comet-discovery/main.go | 13 -----
comet/pkg/cmd/cmd.go | 10 ----
5 files changed, 132 deletions(-)
diff --git a/comet/galaxy/comet-agent/app/cmd.go
b/comet/galaxy/comet-agent/app/cmd.go
deleted file mode 100644
index 95ddaf85..00000000
--- a/comet/galaxy/comet-agent/app/cmd.go
+++ /dev/null
@@ -1,85 +0,0 @@
-package app
-
-import (
- "context"
- "fmt"
- "github.com/apache/dubbo-kubernetes/comet/pkg/cmd"
- "github.com/spf13/cobra"
-)
-
-func NewRootCommand() *cobra.Command {
- rootCmd := &cobra.Command{
- Use: "comet-agent",
- SilenceUsage: true,
- }
- cmd.AddFlags(rootCmd)
- return rootCmd
-}
-
-func newProxyCommand() *cobra.Command {
- return &cobra.Command{
- Use: "proxy",
- Short: "XDS proxy agent",
- FParseErrWhitelist: cobra.FParseErrWhitelist{
- UnknownFlags: true,
- },
- RunE: func(c *cobra.Command, args []string) error {
- err := initProxy(args)
- if err != nil {
- return err
- }
- proxyConfig, err :=
config.ConstructProxyConfig(proxyArgs.MeshConfigFile, proxyArgs.ServiceCluster,
options.ProxyConfigEnv, proxyArgs.Concurrency)
- if err != nil {
- return fmt.Errorf("failed to get proxy config:
%v", err)
- }
- if out, err := protomarshal.ToYAML(proxyConfig); err !=
nil {
- log.Infof("Failed to serialize to YAML: %v",
err)
- } else {
- log.Infof("Effective config: %s", out)
- }
-
- secOpts, err := options.NewSecurityOptions(proxyConfig,
proxyArgs.StsPort, proxyArgs.TokenManagerPlugin)
- if err != nil {
- return err
- }
-
- // If we are using a custom template file (for control
plane proxy, for example), configure this.
- if proxyArgs.TemplateFile != "" &&
proxyConfig.CustomConfigFile == "" {
- proxyConfig.ProxyBootstrapTemplatePath =
proxyArgs.TemplateFile
- }
-
- envoyOptions := envoy.ProxyConfig{
- LogLevel: proxyArgs.ProxyLogLevel,
- ComponentLogLevel:
proxyArgs.ProxyComponentLogLevel,
- LogAsJSON: loggingOptions.JSONEncoding,
- NodeIPs: proxyArgs.IPAddresses,
- Sidecar: proxyArgs.Type ==
model.SidecarProxy,
- OutlierLogPath: proxyArgs.OutlierLogPath,
- }
- agentOptions := options.NewAgentOptions(&proxyArgs,
proxyConfig, sds)
- agent := istioagent.NewAgent(proxyConfig, agentOptions,
secOpts, envoyOptions)
- ctx, cancel :=
context.WithCancelCause(context.Background())
- defer cancel(errors.New("application shutdown"))
- defer agent.Close()
-
- // If a status port was provided, start handling status
probes.
- if proxyConfig.StatusPort > 0 {
- if err := initStatusServer(ctx, proxyConfig,
- agentOptions.EnvoyPrometheusPort,
proxyArgs.EnableProfiling, agent, cancel); err != nil {
- return err
- }
- }
-
- // On SIGINT or SIGTERM, cancel the context, triggering
a graceful shutdown
- go cmd.WaitSignalFunc(cancel)
-
- // Start in process SDS, dns server, xds proxy, and
Envoy.
- wait, err := agent.Run(ctx)
- if err != nil {
- return err
- }
- wait()
- return nil
- },
- }
-}
diff --git a/comet/galaxy/comet-agent/main.go b/comet/galaxy/comet-agent/main.go
deleted file mode 100644
index fbbb9db8..00000000
--- a/comet/galaxy/comet-agent/main.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package main
-
-import (
- "github.com/apache/dubbo-kubernetes/comet/galaxy/comet-agent/app"
- "os"
-)
-
-func main() {
- rootCmd := app.NewRootCommand()
- if err := rootCmd.Execute(); err != nil {
- os.Exit(-1)
- }
-}
diff --git a/comet/galaxy/comet-discovery/app/cmd.go
b/comet/galaxy/comet-discovery/app/cmd.go
deleted file mode 100644
index cd74db7c..00000000
--- a/comet/galaxy/comet-discovery/app/cmd.go
+++ /dev/null
@@ -1,11 +0,0 @@
-package app
-
-import "github.com/spf13/cobra"
-
-func NewRootCommand() *cobra.Command {
- rootCmd := &cobra.Command{
- Use: "pilot-discovery",
- SilenceUsage: true,
- }
- return rootCmd
-}
diff --git a/comet/galaxy/comet-discovery/main.go
b/comet/galaxy/comet-discovery/main.go
deleted file mode 100644
index 7e4d4ad0..00000000
--- a/comet/galaxy/comet-discovery/main.go
+++ /dev/null
@@ -1,13 +0,0 @@
-package main
-
-import (
- "github.com/apache/dubbo-kubernetes/comet/galaxy/comet-discovery/app"
- "os"
-)
-
-func main() {
- rootCmd := app.NewRootCommand()
- if err := rootCmd.Execute(); err != nil {
- os.Exit(-1)
- }
-}
diff --git a/comet/pkg/cmd/cmd.go b/comet/pkg/cmd/cmd.go
deleted file mode 100644
index ab77cf8d..00000000
--- a/comet/pkg/cmd/cmd.go
+++ /dev/null
@@ -1,10 +0,0 @@
-package cmd
-
-import (
- "flag"
- "github.com/spf13/cobra"
-)
-
-func AddFlags(rootCmd *cobra.Command) {
- rootCmd.PersistentFlags().AddGoFlagSet(flag.CommandLine)
-}
