Versions in this module Expand all Collapse all v0 v0.1.0 Oct 9, 2023 Changes in this version + const ControllerName + func ClearGeneratedFields(objmeta *metav1.ObjectMeta) + func ConvertPodListWithFilter(list []corev1.Pod, pass ObjectFilterFunction) []*corev1.Pod + func ConvertServiceList(list []corev1.Service) []*corev1.Service + func CreatedClustersCounterInc(clusterNamespace string, clusterType kubeclusterorgv1alpha1.ClusterType) + func DeletedClustersCounterInc(clusterNamespace string, clusterType kubeclusterorgv1alpha1.ClusterType) + func FailedClustersCounterInc(clusterNamespace string, clusterType kubeclusterorgv1alpha1.ClusterType) + func GenGeneralName(clusterName string, rtype kubeclusterorgv1alpha1.ReplicaType, index string) string + func GetReplicaTypes(...) []kubeclusterorgv1alpha1.ReplicaType + func KubeClusterControlledPodList(list []corev1.Pod, cluster metav1.Object) []*corev1.Pod + func RestartedClustersCounterInc(clusterNamespace string, clusterType kubeclusterorgv1alpha1.ClusterType) + type ClusterSchemaReconciler interface + Default func(kcluster *kubeclusterorgv1alpha1.KubeCluster) + GetDefaultContainerName func() string + IsController func(...) bool + ReconcileConfigMap func(kcluster *kubeclusterorgv1alpha1.KubeCluster, configMap *v1.ConfigMap) error + SetClusterSpec func(kcluster *kubeclusterorgv1alpha1.KubeCluster, template *v1.PodTemplateSpec, ...) error + UpdateClusterStatus func(kcluster *kubeclusterorgv1alpha1.KubeCluster, ...) + UpdateConfigMap func(kcluster *kubeclusterorgv1alpha1.KubeCluster, deepCopy *v1.ConfigMap) error + ValidateV1KubeCluster func(kcluster *kubeclusterorgv1alpha1.KubeCluster) error + type ControllerInterface interface + ControllerName func() string + DeleteCluster func(kcluster metav1.Object) error + GetAPIGroupVersion func() schema.GroupVersion + GetAPIGroupVersionKind func() schema.GroupVersionKind + GetClusterFromInformerCache func(namespace, name string) (metav1.Object, error) + GetConfigMapForCluster func(kcluster *kubeclusterorgv1alpha1.KubeCluster) (*v1.ConfigMap, error) + GetGroupNameLabelValue func() string + GetPodsForCluster func(kcluster *kubeclusterorgv1alpha1.KubeCluster) ([]*v1.Pod, error) + GetServiceSlices func(services []*v1.Service, replicas int, replica *log.Entry) [][]*v1.Service + GetServicesForCluster func(kcluster *kubeclusterorgv1alpha1.KubeCluster) ([]*v1.Service, error) + UpdateClusterStatus func(kcluster *kubeclusterorgv1alpha1.KubeCluster, ...) error + UpdateClusterStatusInApiServer func(kcluster metav1.Object, clusterStatus *kubeclusterorgv1alpha1.ClusterStatus) error + UpdateConfigMapInApiServer func(metav1.Object, *v1.ConfigMap) error + type ObjectFilterFunction func(obj metav1.Object) bool
Go to main page