cmd

Documentation

Index

• func Execute()
• type Config
• type Server
  • func NewServer(config *Config) *Server
  • func (s *Server) CommitCaptureTask(ctx *gin.Context)
  • func (s *Server) CommitDiagnoseTask(ctx *gin.Context)
  • func (s *Server) DownloadCaptureFile(ctx *gin.Context)
  • func (s *Server) GetEvent(ctx *gin.Context)
  • func (s *Server) GetExporterConfig(ctx *gin.Context)
  • func (s *Server) GetFlowGraph(ctx *gin.Context)
  • func (s *Server) ListCaptureTasks(ctx *gin.Context)
  • func (s *Server) ListDiagnoseTasks(ctx *gin.Context)
  • func (s *Server) ListNamespaces(ctx *gin.Context)
  • func (s *Server) ListNodes(ctx *gin.Context)
  • func (s *Server) ListPods(ctx *gin.Context)
  • func (s *Server) PingMesh(ctx *gin.Context)
  • func (s *Server) Run()
  • func (s *Server) RunAgentServer(port int, done <-chan struct{})
  • func (s *Server) RunHTTPServer(port int, done <-chan struct{})
  • func (s *Server) UpdateExporterConfig(ctx *gin.Context)
• type ServerConfig

Functions

func Execute

func Execute()

Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the rootCmd.

Types

type Config

type Config struct {
	LogLevel   string         `yaml:"logLevel"`
	Kubernetes k8s.Config     `yaml:"k8s"`
	Server     ServerConfig   `yaml:"server"`
	Controller service.Config `yaml:"controller"`
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(config *Config) *Server

func (*Server) CommitCaptureTask

func (s *Server) CommitCaptureTask(ctx *gin.Context)

CommitCaptureTask commit capture task

func (*Server) CommitDiagnoseTask

func (s *Server) CommitDiagnoseTask(ctx *gin.Context)

CommitDiagnoseTask commit diagnose task

func (*Server) DownloadCaptureFile

func (s *Server) DownloadCaptureFile(ctx *gin.Context)

DownloadCaptureFile download capture file

func (*Server) GetEvent

func (s *Server) GetEvent(ctx *gin.Context)

func (*Server) GetExporterConfig

func (s *Server) GetExporterConfig(ctx *gin.Context)

func (*Server) GetFlowGraph

func (s *Server) GetFlowGraph(ctx *gin.Context)

func (*Server) ListCaptureTasks

func (s *Server) ListCaptureTasks(ctx *gin.Context)

ListCaptureTasks list all capture task

func (*Server) ListDiagnoseTasks

func (s *Server) ListDiagnoseTasks(ctx *gin.Context)

ListDiagnoseTasks list all diagnose task

func (*Server) ListNamespaces

func (s *Server) ListNamespaces(ctx *gin.Context)

func (*Server) ListNodes

func (s *Server) ListNodes(ctx *gin.Context)

func (*Server) ListPods

func (s *Server) ListPods(ctx *gin.Context)

func (*Server) PingMesh

func (s *Server) PingMesh(ctx *gin.Context)

func (*Server) Run

func (s *Server) Run()

func (*Server) RunAgentServer

func (s *Server) RunAgentServer(port int, done <-chan struct{})

func (*Server) RunHTTPServer

func (s *Server) RunHTTPServer(port int, done <-chan struct{})

func (*Server) UpdateExporterConfig

func (s *Server) UpdateExporterConfig(ctx *gin.Context)

type ServerConfig

type ServerConfig struct {
	AgentPort int `yaml:"agentPort"`
	HTTPPort  int `yaml:"httpPort"`
}