util

Documentation

Index

• Constants
• Variables
• func GetServiceAddress(svc *corev1.Service, portName string) (string, error)
• func GetServiceDNS(svc *corev1.Service) string
• func SetBootStrapImageStruct(dep *appsv1.Deployment, componentspec v1alpha1.AlamedaComponentSpec, ...)
• func SetDaemonSetImagePullPolicy(ds *appsv1.DaemonSet, ctn string, imagePullPolicy corev1.PullPolicy)
• func SetDaemonSetImageStruct(ds *appsv1.DaemonSet, value interface{}, ctn string)
• func SetImagePullPolicy(dep *appsv1.Deployment, ctn string, imagePullPolicy corev1.PullPolicy)
• func SetImageStruct(dep *appsv1.Deployment, value interface{}, ctn string)
• func SetStatefulSetImagePullPolicy(sts *appsv1.StatefulSet, ctn string, imagePullPolicy corev1.PullPolicy)
• func SetStatefulsetImageStruct(ss *appsv1.StatefulSet, value interface{}, ctn string)
• func SetStorageToMountPath(dep *appsv1.Deployment, storagestructs []v1alpha1.StorageSpec, ctn string, ...)
• func SetStorageToPersistentVolumeClaimSpec(pvc *corev1.PersistentVolumeClaim, storagestructs []v1alpha1.StorageSpec, ...)
• func SetStorageToVolumeSource(dep *appsv1.Deployment, storagestructs []v1alpha1.StorageSpec, ...)
• func StringInSlice(str string, list []string) bool
• func StringSliceDelete(slice1 []string, slice2 []string) []string
• type GroupEnums

Constants

const (
	FedemeterGroup GroupEnums = "alameda/fedemeter"
	AlamedaGroup   GroupEnums = "alameda"
	GrafanaGroup   GroupEnums = "grafana"
	InfluxDBGroup  GroupEnums = "influxdb"
	//deployment name
	AlamedaaiDPN              = "alameda-ai"
	AlamedaoperatorDPN        = "alameda-operator"
	AlamedadatahubDPN         = "alameda-datahub"
	AlamedaevictionerDPN      = "alameda-evictioner"
	AdmissioncontrollerDPN    = "admission-controller"
	AlamedarecommenderDPN     = "alameda-recommender"
	AlamedaexecutorDPN        = "alameda-executor"
	AlamedadispatcherDPN      = "alameda-ai-dispatcher"
	AlamedaRabbitMQDPN        = "alameda-rabbitmq"
	FedemeterDPN              = "fedemeter-api"
	GrafanaDPN                = "alameda-grafana"
	InfluxdbDPN               = "alameda-influxdb"
	AlamedaweavescopeDPN      = "alameda-weave-scope-app"
	AlamedaweavescopeProbeDPN = "alameda-weave-scope-cluster-agent"
	AlamedaanalyzerDPN        = "alameda-analyzer"
	AlamedaNotifierDPN        = "alameda-notifier"
	FederatoraiAgentDPN       = "federatorai-agent"
	//DaemonSet name
	AlamedaweavescopeAgentDS = "alameda-weave-scope-agent"
	//container name
	AlamedaaiCTN              = "alameda-ai-engine"
	AlamedaoperatorCTN        = "alameda-operator"
	AlamedadatahubCTN         = "alameda-datahub"
	AlamedaevictionerCTN      = "alameda-evictioner"
	AdmissioncontrollerCTN    = "admission-controller"
	AlamedarecommenderCTN     = "alameda-recommender"
	AlamedaexecutorCTN        = "alameda-executor"
	AlamedadispatcherCTN      = "ai-dispatcher"
	AlamedaRabbitMQCTN        = "rabbitmq"
	FedemeterCTN              = "fedemeter-api"
	FedemeterInfluxDBCTN      = "fedemeter-influxdb"
	GetTokenCTN               = "gettoken"
	GrafanaCTN                = "grafana"
	InfluxdbCTN               = "influxdb"
	AlamedaweavescopeCTN      = "alameda-weave-scope-app"
	AlamedaweavescopeProbeCTN = "alameda-weave-scope-cluster-agent"
	AlamedaweavescopeAgentCTN = "alameda-weave-scope-agent"
	AlamedaanalyzerCTN        = "alameda-analyzer"
	AlamedaNofitierCTN        = "alameda-notifier"
	FederatoraiAgentCTN       = "federatorai-agent"
	//Statefulset name
	FedemeterInflixDBSSN = "fedemeter-influxdb"
	//CRD NAME
	AlamedaScalerName         = "alamedascalers.autoscaling.containers.ai"
	AlamedaRecommendationName = "alamedarecommendations.autoscaling.containers.ai"
	// Service name
	AdmissionControllerServiceName  = "admission-controller"
	AlamedaAIServiceName            = "alameda-ai"
	AlamedaDatahubServiceName       = "alameda-datahub"
	AlamedaGrafanaServiceName       = "alameda-grafana"
	AlamedaInfluxdbServiceName      = "alameda-influxdb"
	AlamedaRabbitmqServiceName      = "alameda-rabbitmq"
	AlamedaWeaveScopeAppServiceName = "alameda-weave-scope-app"
	FedemeterInfluxdbServiceName    = "fedemeter-influxdb"
	FedemeterAPIServiceName         = "fedemeter-api"
	//CRD Version
	OriAlamedaOperatorVersion = "v0.3.8"
	//AlamedaService modify Prometheus's var
	OriginPrometheus_URL               = "https://prometheus-k8s.openshift-monitoring.svc:9091"
	OriginDeploymentPrometheusLocation = "ALAMEDA_DATAHUB_PROMETHEUS_URL"
	OriginComfigMapPrometheusLocation  = "prometheus.yaml"
	NamespaceService                   = "federatorai.svc"
	DefaultNamespace                   = "federatorai"
	NamespaceServiceAccount            = "serviceaccount:federatorai"
	//MountPath
	DataMountPath = "/var/lib"
	LogMountPath  = "/var/log"
	//Recommandation config
	OriginComfigMapRecommandation = "config.toml"
	//Execution config
	OriginComfigMapExecution = "config.yml"
	//fedemeter config
	OriginComfigMapFedemeterInfluxDBHost = "FEDEMETER_INFLUXDB_HOST"
	OriginComfigMapFedemeterDataHubHost  = "DATAHUB_HOST"
	//Delete Deployment When Modify ConfigMap or Service(Temporary strategy)
	GrafanaYaml            = "Deployment/alameda-grafanaDM.yaml"
	GrafanaDatasourcesName = "grafana-datasources"
)

Variables

var (
	//if disable resource protection
	Disable_operand_resource_protection = "false"

	//AlamedaScaler version
	AlamedaScalerVersion        = []string{"v1", "v2"}
	V1scalerOperatorVersionList = []string{"v0.3.6", "v0.3.7", "v0.3.8", "v0.3.9", "v0.3.10", "v0.3.11", "v0.3.12"}
)

Functions

func GetServiceAddress

func GetServiceAddress(svc *corev1.Service, portName string) (string, error)

GetServiceAddress returns address combining dns name with port number base on port name

func GetServiceDNS

func GetServiceDNS(svc *corev1.Service) string

GetServiceDNS returns service dns

func SetBootStrapImageStruct

func SetBootStrapImageStruct(dep *appsv1.Deployment, componentspec v1alpha1.AlamedaComponentSpec, ctn string)

func SetDaemonSetImagePullPolicy

func SetDaemonSetImagePullPolicy(ds *appsv1.DaemonSet, ctn string, imagePullPolicy corev1.PullPolicy)

func SetDaemonSetImageStruct

func SetDaemonSetImageStruct(ds *appsv1.DaemonSet, value interface{}, ctn string)

func SetImagePullPolicy

func SetImagePullPolicy(dep *appsv1.Deployment, ctn string, imagePullPolicy corev1.PullPolicy)

if user section schema set pullpolicy then AlamedaService set Containers image's pullpolicy

func SetImageStruct

func SetImageStruct(dep *appsv1.Deployment, value interface{}, ctn string)

if user set related image struct then AlamedaService set Containers image structure

func SetStatefulSetImagePullPolicy

func SetStatefulSetImagePullPolicy(sts *appsv1.StatefulSet, ctn string, imagePullPolicy corev1.PullPolicy)

func SetStatefulsetImageStruct

func SetStatefulsetImageStruct(ss *appsv1.StatefulSet, value interface{}, ctn string)

func SetStorageToMountPath

func SetStorageToMountPath(dep *appsv1.Deployment, storagestructs []v1alpha1.StorageSpec, ctn string, volumeName string, group GroupEnums)

if user set pvc then AlamedaService set pvc to Deployment's MountPath

func SetStorageToPersistentVolumeClaimSpec

func SetStorageToPersistentVolumeClaimSpec(pvc *corev1.PersistentVolumeClaim, storagestructs []v1alpha1.StorageSpec, pvctype v1alpha1.Usage)

if user set pvc then AlamedaService set PersistentVolumeClaimSpec

func SetStorageToVolumeSource

func SetStorageToVolumeSource(dep *appsv1.Deployment, storagestructs []v1alpha1.StorageSpec, volumeName string, group GroupEnums)

if user set pvc then AlamedaService set pvc to Deployment's VolumeSource

func StringInSlice

func StringInSlice(str string, list []string) bool

func StringSliceDelete

func StringSliceDelete(slice1 []string, slice2 []string) []string

StringSliceDelete removes elements in slice2 from slice1

Types

type GroupEnums

type GroupEnums string