commands

Mar 22, 2023

Changes in this version

+ func GetThroughputAnomalyDetectorByID(theiaClient restclient.Interface, name string) (tad anomalydetector.ThroughputAnomalyDetector, err error)

Dec 23, 2022

Changes in this version

+ var Command *cobra.Command

Oct 21, 2022

Changes in this version

+ var SetupTheiaClientAndConnection = setupTheiaClientAndConnection

+ func CreateTheiaManagerClient(k8sClient kubernetes.Interface, kubeconfig string, useClusterIP bool) (kubernetes.Interface, *portforwarder.PortForwarder, error)

+ func GetCaCrt(clientset kubernetes.Interface) (string, error)

+ func GetToken(clientset kubernetes.Interface) (string, error)

Aug 18, 2022

Changes in this version

+ func FormatTimestamp(timestamp time.Time) string

+ func ParseEndpoint(endpoint string) error

+ func ParseRecommendationID(recommendationID string) error

+ func SetupClickHouseConnection(clientset kubernetes.Interface, kubeconfig string, endpoint string, ...) (connect *sql.DB, portForward *portforwarder.PortForwarder, err error)

+ func TableOutput(table [][]string)

+ func TableOutputVertical(table [][]string)

Jun 16, 2022

Changes in this version

+ func CheckClickHousePod(clientset kubernetes.Interface) error

+ func CheckSparkOperatorPod(clientset kubernetes.Interface) error

+ func ConstStrToPointer(constStr string) *string

+ func CreateK8sClient(kubeconfig string) (kubernetes.Interface, error)

+ func Execute()

+ func GetServiceAddr(clientset kubernetes.Interface, serviceName string) (string, int, error)

+ func PolicyRecoPreCheck(clientset kubernetes.Interface) error

+ func ResolveKubeConfig(cmd *cobra.Command) (string, error)

+ func StartPortForward(kubeconfig string, service string, servicePort int, listenAddress string, ...) (*portforwarder.PortForwarder, error)

+ type SparkResourceArgs struct