controller

Documentation

Index

• Constants
• Variables
• 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 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 GetSparkJobIds(connect *sql.DB, tableName string) ([]string, error)
• func GetSparkMonitoringSvcDNS(id string, namespace string, sparkPort int) string
• func HandleStaleDbEntries(clickhouseConnect *sql.DB, client kubernetes.Interface, job, tableName string, ...) error
• func HandleStaleSparkApp(client kubernetes.Interface, sparkAppLabel string, ...) error
• func ListSparkApplicationWithLabel(client kubernetes.Interface, label string) (*sparkv1.SparkApplicationList, error)
• func RunClickHouseQuery(connect *sql.DB, query string, id string) (err error)
• func ValidateCluster(client kubernetes.Interface, namespace string) error
• type GcKey

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
)

Variables

var (
	ListSparkApplication = ListSparkApplicationWithLabel
)

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 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 GetSparkJobIds

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

func GetSparkMonitoringSvcDNS

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

func HandleStaleDbEntries

func HandleStaleDbEntries(clickhouseConnect *sql.DB, client kubernetes.Interface, job, tableName string, ifResourceExists func(string, string) error, idPrefix string) error

func HandleStaleSparkApp

func HandleStaleSparkApp(client kubernetes.Interface, sparkAppLabel string, ifResourceExists func(string, string) error) error

func ListSparkApplicationWithLabel

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

func RunClickHouseQuery

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

func ValidateCluster

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

Types

type GcKey

type GcKey struct {
	RemoveStaleDbEntries bool
	RemoveStaleSparkApp  bool
	AddResync            bool
}