controller

Documentation

Index

• Constants
• func CheckPodByLabel(client kubernetes.Interface, namespace string, label string) error
• func ConstStrToPointer(constStr string) *string
• func CreateSparkApplication(client kubernetes.Interface, namespace string, ...) error
• func DeleteSparkApplication(client kubernetes.Interface, name string, namespace string)
• func DeleteSparkResult(connect *sql.DB, query string, id string) (err error)
• func GetPolicyRecommendationIds(connect *sql.DB) ([]string, error)
• func GetResponseFromSparkMonitoringSvc(url string) ([]byte, error)
• func GetSparkAppProgress(baseUrl string) (completedStages int, totalStages int, err error)
• func GetSparkApplication(client kubernetes.Interface, name string, namespace string) (sparkApp sparkv1.SparkApplication, err error)
• func GetSparkMonitoringSvcDNS(id string, namespace string, sparkPort int) string
• func ListSparkApplication(client kubernetes.Interface, namespace string) (*sparkv1.SparkApplicationList, error)
• func ListSparkApplicationWithLabel(client kubernetes.Interface, label string) (*sparkv1.SparkApplicationList, error)
• func ValidateCluster(client kubernetes.Interface, namespace string) error

Constants

const (
	// Set resyncPeriod to 0 to disable resyncing.
	ResyncPeriod time.Duration = 0
	// How long to wait before retrying the processing of an Service change.
	MinRetryDelay = 5 * time.Second
	MaxRetryDelay = 300 * time.Second
	// Default number of workers processing an Service change.
	DefaultWorkers = 4
	// Time format for parsing input time
	InputTimeFormat  = "2006-01-02 15:04:05"
	K8sQuantitiesReg = "^([+-]?[0-9.]+)([eEinumkKMGTP]*[-+]?[0-9]*)$"
	// Spark related parameters for Policy Recommendation and Throughput Anomaly Detection
	// spark jobs
	SparkImage           = "projects.registry.vmware.com/antrea/theia-spark-jobs:latest"
	SparkImagePullPolicy = "IfNotPresent"
	SparkServiceAccount  = "theia-spark"
	SparkVersion         = "3.1.1"
	SparkPort            = 4040
)

Functions

func CheckPodByLabel

func CheckPodByLabel(client kubernetes.Interface, namespace string, label string) error

func ConstStrToPointer

func ConstStrToPointer(constStr string) *string

func CreateSparkApplication

func CreateSparkApplication(client kubernetes.Interface, namespace string, sparkApplication *sparkv1.SparkApplication) error

func DeleteSparkApplication

func DeleteSparkApplication(client kubernetes.Interface, name string, namespace string)

func DeleteSparkResult

func DeleteSparkResult(connect *sql.DB, query string, id string) (err error)

func GetPolicyRecommendationIds

func GetPolicyRecommendationIds(connect *sql.DB) ([]string, error)

func GetResponseFromSparkMonitoringSvc

func GetResponseFromSparkMonitoringSvc(url string) ([]byte, error)

func GetSparkAppProgress

func GetSparkAppProgress(baseUrl string) (completedStages int, totalStages int, err error)

func GetSparkApplication

func GetSparkApplication(client kubernetes.Interface, name string, namespace string) (sparkApp sparkv1.SparkApplication, err error)

func GetSparkMonitoringSvcDNS

func GetSparkMonitoringSvcDNS(id string, namespace string, sparkPort int) string

func ListSparkApplication

func ListSparkApplication(client kubernetes.Interface, namespace string) (*sparkv1.SparkApplicationList, error)

func ListSparkApplicationWithLabel

func ListSparkApplicationWithLabel(client kubernetes.Interface, label string) (*sparkv1.SparkApplicationList, error)

func ValidateCluster

func ValidateCluster(client kubernetes.Interface, namespace string) error