Versions in this module Expand all Collapse all v0 v0.1.0 Oct 9, 2023 Changes in this version + var GenNonGangSchedulerSetupFunc = func() GangSchedulingSetupFunc + var GenSchedulerPluginsSetupFunc = func(c client.Client, gangSchedulerName string) GangSchedulingSetupFunc + var GenVolcanoSetupFunc = func(vci volcanoclient.Interface) GangSchedulingSetupFunc + var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc + func AddResourceList(list, req, limit v1.ResourceList) + func CalcPGMinResources(minMember int32, replicas map[v1alpha1.ReplicaType]*v1alpha1.ReplicaSpec, ...) *v1.ResourceList + type ClusterController struct + Config ClusterControllerConfiguration + ConfigMapControl control.ConfigMapControlInterface + Controller common.ControllerInterface + KubeClientSet kubeclientset.Interface + PodControl control.PodControlInterface + PodGroupControl control.PodGroupControlInterface + PodInformerSynced cache.InformerSynced + PodLister corelisters.PodLister + PriorityClassInformerSynced cache.InformerSynced + PriorityClassLister schedulinglisters.PriorityClassLister + Recorder record.EventRecorder + SchemaReconcilerManager map[cluster_schema.ClusterSchema]common.ClusterSchemaReconciler + SchemaReconcilerMutux sync.Mutex + ServiceControl control.ServiceControlInterface + ServiceInformerSynced cache.InformerSynced + ServiceLister corelisters.ServiceLister + WorkQueue workqueue.RateLimitingInterface + func (cc *ClusterController) CleanUpResources(runPolicy *v1alpha1.RunPolicy, runtimeObject runtime.Object, ...) error + func (cc *ClusterController) CleanupCluster(runPolicy *v1alpha1.RunPolicy, runtimeObject runtime.Object, ...) error + func (cc *ClusterController) CreateNewConfigMap(kcluster *v1alpha1.KubeCluster, ...) (*v1.ConfigMap, error) + func (cc *ClusterController) CreateNewPod(kcluster *kubeclusterorgv1alpha1.KubeCluster, ...) error + func (cc *ClusterController) CreateNewService(kcluster *kubeclusterorgv1alpha1.KubeCluster, ...) error + func (cc *ClusterController) DeletePdb(cluster metav1.Object) error + func (cc *ClusterController) DeletePodAndServices(runtimeObject runtime.Object, runPolicy *v1alpha1.RunPolicy, ...) error + func (cc *ClusterController) DeletePodGroup(cluster metav1.Object) error + func (cc *ClusterController) FilterPodsForReplicaType(pods []*corev1.Pod, replicaType string) ([]*corev1.Pod, error) + func (cc *ClusterController) FilterServicesForReplicaType(services []*corev1.Service, replicaType string) ([]*corev1.Service, error) + func (cc *ClusterController) GenLabels(clusterType string) map[string]string + func (cc *ClusterController) GenOwnerReference(obj metav1.Object) *metav1.OwnerReference + func (cc *ClusterController) GetPodSlices(pods []*v1.Pod, replicas int, logger *log.Entry) [][]*v1.Pod + func (cc *ClusterController) GetPortsFromClusterSpec(spec *v1alpha1.ReplicaSpec, defaultContainerName string) (map[string]int32, error) + func (cc *ClusterController) GetSchemaReconciler(clusterType v1alpha1.ClusterType) common.ClusterSchemaReconciler + func (cc *ClusterController) PastActiveDeadline(runPolicy *v1alpha1.RunPolicy, clusterStatus v1alpha1.ClusterStatus) bool + func (cc *ClusterController) PastBackoffLimit(clusterName string, runPolicy *v1alpha1.RunPolicy, ...) (bool, error) + func (cc *ClusterController) ReconcileConfigMap(kcluster *v1alpha1.KubeCluster) (*v1.ConfigMap, error) + func (cc *ClusterController) ReconcileKubeCluster(kcluster *v1alpha1.KubeCluster, ...) error + func (cc *ClusterController) ReconcilePods(kcluster *kubeclusterorgv1alpha1.KubeCluster, ...) error + func (cc *ClusterController) ReconcileServices(kcluster *kubeclusterorgv1alpha1.KubeCluster, ...) error + func (cc *ClusterController) RegisterSchema(schema cluster_schema.ClusterSchema, reconciler common.ClusterSchemaReconciler) error + func (cc *ClusterController) ResetExpectations(clusterKey string, replicas map[v1alpha1.ReplicaType]*v1alpha1.ReplicaSpec, ...) error + func (cc *ClusterController) SyncPdb(kcluster metav1.Object, minAvailableReplicas int32) (*policyapi.PodDisruptionBudget, error) + func (cc *ClusterController) SyncPodGroup(cluster metav1.Object, specFunc FillPodGroupSpecFunc) (metav1.Object, error) + type ClusterControllerConfiguration struct + GangScheduling GangScheduler + func (c *ClusterControllerConfiguration) EnableGangScheduling() bool + type FillPodGroupSpecFunc func(object metav1.Object) error + type GangScheduler string + const GangSchedulerNone + const GangSchedulerSchedulerPlugins + const GangSchedulerVolcano + type GangSchedulingSetupFunc func(jc *ClusterController) + type PriorityClassGetFunc func(string) (*schedulingv1.PriorityClass, error) + type ReplicaPriority struct + type ReplicasPriority []ReplicaPriority + func (p ReplicasPriority) Len() int + func (p ReplicasPriority) Less(i, j int) bool + func (p ReplicasPriority) Swap(i, j int)
Go to main page