Documentation
¶
Index ¶
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckClickHousePod ¶
func CheckClickHousePod(clientset kubernetes.Interface) error
func CheckSparkOperatorPod ¶
func CheckSparkOperatorPod(clientset kubernetes.Interface) error
func ConstStrToPointer ¶
func CreateK8sClient ¶
func CreateK8sClient(kubeconfig string) (kubernetes.Interface, error)
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.
func GetServiceAddr ¶
func PolicyRecoPreCheck ¶
func PolicyRecoPreCheck(clientset kubernetes.Interface) error
func StartPortForward ¶
func StartPortForward(kubeconfig string, service string, servicePort int, listenAddress string, listenPort int) (*portforwarder.PortForwarder, error)
Types ¶
type SparkResourceArgs ¶
type SparkResourceArgs struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.