controller

package

v0.8.0 Latest Latest Go to latest Published: Oct 27, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/antrea-io/theia

Links

Open Source Insights

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 ¶

View Source

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 ¶

View Source

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 ¶ added in v0.6.0

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

func GetSparkMonitoringSvcDNS ¶

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

func HandleStaleDbEntries ¶ added in v0.6.0

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

func HandleStaleSparkApp ¶ added in v0.6.0

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 ¶ added in v0.6.0

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

func ValidateCluster ¶

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

Types ¶

type GcKey ¶ added in v0.6.0

type GcKey struct {
	RemoveStaleDbEntries bool
	RemoveStaleSparkApp  bool
	AddResync            bool
}

Source Files ¶

View all Source files

util.go

Directories ¶

Path	Synopsis
anomalydetector
networkpolicyrecommendation

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL